nulogy_message_bus_consumer-1.0.0.alpha

https://rubygems.org

allowed_push_host: https://rubygems.org/

id: 1329315

number: 1.0.0.alpha

platform: ruby

spec_sha256: 16a8869678ddd25ee60c4a50c01aa2b76258f0990da78970c0855ecc82f782da

sha256: f742743d5f8d19a8d81c35a33206ef72ce45725b4bc7a7b3f5d90196c9306d9b

created_at: 2024-05-13 08:34:04 UTC

updated_at: 2024-06-13 21:41:01 UTC

position: 3

version_data_entries_count: 28

uploaded_at: 2021-04-13 16:55:54 UTC

indexed: true

has_extensions:

extensions:

Gem size: 12 KB

Version Data Entries

Total: 28

Unpacked size: 21.5 KB

Full Name	Mode	Size	SHA
Rakefile	100644	767 Bytes	31618e946e4ac3dc0d82f65325dab6dcd5a75c19a978894cc5f1d45c7b3504f6
config/credentials/message-bus-us-east-1.key	100644	33 Bytes	dbc428d2dabe9bc8592f7e91177436dac8fd1aa9ad1a13f79dadd3b6036ee5be
config/credentials/message-bus-us-east-1.yml.enc	100644	464 Bytes	9ead12605e5bc64311b721fb8e02e83d290f605beef4dd981174657c0dbfb6e0
config/routes.rb	100644	52 Bytes	a1112209ee9040aef03eca066328ef27c64abf65c53cde3355d9fd0b0133d968
db/migrate/20200509095105_create_message_bus_processed_messages.rb	100644	225 Bytes	69b2daf866b90d81c41dad441481c5aea50ed982d4cbbefcd5216b4db8331395
lib/nulogy_message_bus_consumer.rb	100644	2.63 KB	e5b445fb64d2c03243d4cf6cce1cc8e790e27328dc97eab933261e76f0ade7ce
lib/nulogy_message_bus_consumer/clock.rb	100644	249 Bytes	4c16fe4378941210c9a96a109a76af082298d61269e85709af9eb017ca7cbd82
lib/nulogy_message_bus_consumer/config.rb	100644	485 Bytes	510fc9de8f4b8f7bd46f5e402fe583347e604bd293335ebaed8dea68792f89ed
lib/nulogy_message_bus_consumer/deployment/ecs.rb	100644	536 Bytes	a3354e04f670aaa463883a6347410fa3c0e8a974c590a0819645a3f5ded5778f
lib/nulogy_message_bus_consumer/engine.rb	100644	122 Bytes	6cd9f9e804de63dcadcadbaaac23a6df7a82f38230ef1b2471cee3d2db67cd40
lib/nulogy_message_bus_consumer/handlers/log_unprocessed_messages.rb	100644	387 Bytes	000c048bf7e559169ab55b2e66480681e47ea1b41bb51b1df9cf27e06db5ea49
lib/nulogy_message_bus_consumer/kafka_utils.rb	100644	1.49 KB	95d5afa62a0d3c46df4a0733b2ac0983b86e193bb624eb4b33cb297d7400c8d8
lib/nulogy_message_bus_consumer/lag_tracker.rb	100644	1.26 KB	554a449e6d2d9184b450c26bb8d7e143ebeaa77e42457ca60c526b9e0c8262c4
lib/nulogy_message_bus_consumer/message.rb	100644	1.43 KB	9bf7f830f382b742fc20ae1e80f878865b55957a4ba3cf22a3bfdc603d4e5bfa
lib/nulogy_message_bus_consumer/null_logger.rb	100644	139 Bytes	8c715d4a40fc8823a1eb807e967b3fe56b352770ea03012762dd4fa3afeeec82
lib/nulogy_message_bus_consumer/pipeline.rb	100644	1.1 KB	9b1a56ae419973927e6990907b5a7c501d2faef865b05081cf7a0b5a48c5c6c4
lib/nulogy_message_bus_consumer/processed_message.rb	100644	143 Bytes	1cda010c1f52dfa8cfb89dfd1c6518521f534e7e66af7d5e053f9a23ff7ba7a7
lib/nulogy_message_bus_consumer/steps/commit_on_success.rb	100644	892 Bytes	babe89461e335133b6a6f3c622b28e8cbf6b6c0938e2a9ea972a87659d2b1d8d
lib/nulogy_message_bus_consumer/steps/connect_to_message_bus.rb	100644	1.33 KB	cd82f3c272e61ca3d7717e2cb5f7c9d28fed2ef75503e73e36743ff33a0fb96b
lib/nulogy_message_bus_consumer/steps/deduplicate_messages.rb	100644	1.02 KB	35ed1fcacf0960bdde9a11f7dee69b10db7fd983d58155ab2698ba9ea76859cc
lib/nulogy_message_bus_consumer/steps/log_consumer_lag.rb	100644	1.53 KB	3bc2461203f367335a9a686dc4d0bb10a5259548dde7b7064e8e52111d52821c
lib/nulogy_message_bus_consumer/steps/log_messages.rb	100644	1.13 KB	3a7d81d80f9edf017120a54c2d567e1b7e637938937e7cd8c0e014fbc2cd5855
lib/nulogy_message_bus_consumer/steps/seek_beginning_of_topic.rb	100644	207 Bytes	d8d9997fbc70e506ad436da11723be93bec226bd9d0d04b9ec5d426bfc6f8aec
lib/nulogy_message_bus_consumer/steps/stream_messages.rb	100644	568 Bytes	83b39e407abf6a15cb8743470ba76ef446343a6d8d4950317850e105de6d35f0
lib/nulogy_message_bus_consumer/steps/stream_messages_until_none_are_left.rb	100644	630 Bytes	f7c90ebef88404f2abc76058b7190efd7daae384f983bc9b6bd19f650cfb082d
lib/nulogy_message_bus_consumer/steps/supervise_consumer_lag.rb	100644	2.24 KB	29e9fee2480777fb2301b72c7af4bf5ba7fd132a73b93106529431d26c86da1e
lib/nulogy_message_bus_consumer/version.rb	100644	69 Bytes	eb503d3284886b51de5a731e969e66aea14441aad1aea6505c074b2153cdac1e
lib/tasks/engine/message_bus_consumer.rake	100644	503 Bytes	16dd7b047d0ccbc6ff53bbf6556323bb0ce7780e24104ffe008f02b3e50ff1fc