nulogy_message_bus_consumer-0.5.0

https://rubygems.org

nulogy_message_bus_consumer

quick gemspec

.gem

.gem metadata (gemspec)

.gemspec

allowed_push_host
https://rubygems.org/

id: 1329313

number: 0.5.0

platform: ruby

spec_sha256: 557e901afa6d1f2401e6cd8dab5e8de79004457090057c1c3e96a455cf369a67

sha256: 7b9b9821d6b143e84ff3f93077985be7dde8f359c9ce8837d796e0028bdf9356

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

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

position: 5

version_data_entries_count: 102

uploaded_at: 2021-04-15 17:57:36 UTC

indexed: true

has_extensions:

extensions:

Gem size: 59 KB

Version Data Entries

Total: 102

Unpacked size: 659 KB

Full NameModeUIDGIDMtimeLinknameSizeSHA
Rakefile10064400767 Bytes31618e946e4ac3dc0d82f65325dab6dcd5a75c19a978894cc5f1d45c7b3504f6
config/credentials/message-bus-us-east-1.key1006440033 Bytesdbc428d2dabe9bc8592f7e91177436dac8fd1aa9ad1a13f79dadd3b6036ee5be
config/credentials/message-bus-us-east-1.yml.enc10064400464 Bytes9ead12605e5bc64311b721fb8e02e83d290f605beef4dd981174657c0dbfb6e0
config/routes.rb1006440052 Bytesa1112209ee9040aef03eca066328ef27c64abf65c53cde3355d9fd0b0133d968
db/migrate/20200509095105_create_message_bus_processed_messages.rb10064400225 Bytes69b2daf866b90d81c41dad441481c5aea50ed982d4cbbefcd5216b4db8331395
lib/nulogy_message_bus_consumer.rb100644002.63 KBe5b445fb64d2c03243d4cf6cce1cc8e790e27328dc97eab933261e76f0ade7ce
lib/nulogy_message_bus_consumer/clock.rb10064400249 Bytes4c16fe4378941210c9a96a109a76af082298d61269e85709af9eb017ca7cbd82
lib/nulogy_message_bus_consumer/config.rb10064400485 Bytes510fc9de8f4b8f7bd46f5e402fe583347e604bd293335ebaed8dea68792f89ed
lib/nulogy_message_bus_consumer/deployment/ecs.rb10064400536 Bytesa3354e04f670aaa463883a6347410fa3c0e8a974c590a0819645a3f5ded5778f
lib/nulogy_message_bus_consumer/engine.rb10064400122 Bytes6cd9f9e804de63dcadcadbaaac23a6df7a82f38230ef1b2471cee3d2db67cd40
lib/nulogy_message_bus_consumer/handlers/log_unprocessed_messages.rb10064400387 Bytes000c048bf7e559169ab55b2e66480681e47ea1b41bb51b1df9cf27e06db5ea49
lib/nulogy_message_bus_consumer/kafka_utils.rb100644001.49 KB95d5afa62a0d3c46df4a0733b2ac0983b86e193bb624eb4b33cb297d7400c8d8
lib/nulogy_message_bus_consumer/lag_tracker.rb100644001.26 KB554a449e6d2d9184b450c26bb8d7e143ebeaa77e42457ca60c526b9e0c8262c4
lib/nulogy_message_bus_consumer/message.rb100644001.47 KB7241a75eb135e7b043b0a05c26894f7e385b1adfbc6b8767fbdd5028ead3a68b
lib/nulogy_message_bus_consumer/null_logger.rb10064400139 Bytes8c715d4a40fc8823a1eb807e967b3fe56b352770ea03012762dd4fa3afeeec82
lib/nulogy_message_bus_consumer/pipeline.rb100644001.1 KB9b1a56ae419973927e6990907b5a7c501d2faef865b05081cf7a0b5a48c5c6c4
lib/nulogy_message_bus_consumer/processed_message.rb10064400143 Bytes1cda010c1f52dfa8cfb89dfd1c6518521f534e7e66af7d5e053f9a23ff7ba7a7
lib/nulogy_message_bus_consumer/steps/commit_on_success.rb10064400892 Bytesbabe89461e335133b6a6f3c622b28e8cbf6b6c0938e2a9ea972a87659d2b1d8d
lib/nulogy_message_bus_consumer/steps/connect_to_message_bus.rb100644001.33 KBcd82f3c272e61ca3d7717e2cb5f7c9d28fed2ef75503e73e36743ff33a0fb96b
lib/nulogy_message_bus_consumer/steps/deduplicate_messages.rb100644001.02 KB35ed1fcacf0960bdde9a11f7dee69b10db7fd983d58155ab2698ba9ea76859cc
lib/nulogy_message_bus_consumer/steps/log_consumer_lag.rb100644001.53 KB3bc2461203f367335a9a686dc4d0bb10a5259548dde7b7064e8e52111d52821c
lib/nulogy_message_bus_consumer/steps/log_messages.rb100644001.13 KB3a7d81d80f9edf017120a54c2d567e1b7e637938937e7cd8c0e014fbc2cd5855
lib/nulogy_message_bus_consumer/steps/seek_beginning_of_topic.rb10064400207 Bytesd8d9997fbc70e506ad436da11723be93bec226bd9d0d04b9ec5d426bfc6f8aec
lib/nulogy_message_bus_consumer/steps/stream_messages.rb10064400568 Bytes83b39e407abf6a15cb8743470ba76ef446343a6d8d4950317850e105de6d35f0
lib/nulogy_message_bus_consumer/steps/stream_messages_until_none_are_left.rb10064400630 Bytesf7c90ebef88404f2abc76058b7190efd7daae384f983bc9b6bd19f650cfb082d
lib/nulogy_message_bus_consumer/steps/supervise_consumer_lag.rb100644002.24 KB29e9fee2480777fb2301b72c7af4bf5ba7fd132a73b93106529431d26c86da1e
lib/nulogy_message_bus_consumer/version.rb1006440056 Bytes8b37f8fa21626fdd7576690673627dba6e885fabc2f5506dd90f2603fd879402
lib/tasks/engine/message_bus_consumer.rake10064400503 Bytes16dd7b047d0ccbc6ff53bbf6556323bb0ce7780e24104ffe008f02b3e50ff1fc
spec/dummy/Rakefile10064400227 Bytes895c6a69d01c14f0dd437c0eb44914754006ce317807264ca7ffbd1c79a91ebf
spec/dummy/app/assets/config/manifest.js1006440096 Bytes247f47df5e486475513efd76ce8fc90ee798568fe97a7ec9291eea0daed48b84
spec/dummy/app/assets/stylesheets/application.css10064400736 Bytesa63c83d31995d61cb5a658d5e5ee02cc80232bb2ac87c8d12cfc28036f82c8e3
spec/dummy/app/channels/application_cable/channel.rb1006440079 Bytes38d579eae4970bc9bb298cc8d4bfb0e4d6390d94e5d4e3068be6c8479c5551ed
spec/dummy/app/channels/application_cable/connection.rb1006440085 Bytesd7498ba24c43e669bdbf01d29b058514fe3c4a26d439992e54a8e56acd07a8fb
spec/dummy/app/controllers/application_controller.rb1006440057 Bytesc7279227656b36b3500f97e5331b497f88eb66f60f0b7d8a2e2a69c65bf9130d
spec/dummy/app/helpers/application_helper.rb1006440029 Bytesf77fac5ea412dbed92c4524fe0ed180acb2b7239f84daf758da989032301f5c8
spec/dummy/app/javascript/packs/application.js10064400725 Bytes910b6a0488690c942d062715f9d34f2bf10510e00c996d91eb025487edb73251
spec/dummy/app/jobs/application_job.rb10064400269 Bytesd51e125007521b0f59765422cf3cf949b59b2054cdac6567a95b4a7aeaf1d722
spec/dummy/app/mailers/application_mailer.rb10064400102 Bytes51b58ee6215d29f50f4f35b309e849766e40f584016e48ec9ea66558ab352fa7
spec/dummy/app/models/application_record.rb1006440078 Bytes20cec87060a568766c09d755b1ba38e7ed776d7f6030515217096f4f4777525e
spec/dummy/app/views/layouts/application.html.erb10064400225 Bytes6c0c91a0b4959256f6932256968c3ba13f792b9b60ddd878372d9727c29a2034
spec/dummy/app/views/layouts/mailer.html.erb10064400229 Bytesb98faac075c83b69e9a6b8fbde96eb19f9801e38f42ab42a725501153c895acb
spec/dummy/app/views/layouts/mailer.text.erb1006440013 Bytes51353f9de3a26d4b28f7db91152bf56d31cfa9e4bd3c834680772a63cd374698
spec/dummy/bin/rails10075500141 Bytes0862d7bc09d5ed61785d677ef2dba10ce285387d4d5d9e3d90d97630e3f69ab6
spec/dummy/bin/rake1007550090 Bytes5943c3811dc345727b5f330b599c4c6c45abc04816dd8f4201aeed88cf268cb3
spec/dummy/bin/setup100755001008 Bytes1404025ec00ad659fdf92a67110c79b4308ae449d42f9644540f46088c9062cb
spec/dummy/config.ru10064400130 Bytescbe0ec16f1e549896caf326b044f317e1d9d8f08183eca963d401315b571a45c
spec/dummy/config/application.rb10064400924 Bytesf646579b5105e27454e88ec1a98f088320d41acf13b4d725d62cb86472b92ceb
spec/dummy/config/boot.rb10064400233 Bytes5ef0b8a63c58fcb518aebb9af65486665a653263d144ce9d0eaf943bf88c4ae5
spec/dummy/config/cable.yml10064400186 Bytesd33bd48c809fa9a1c3f1e32dce263d9e4115c5b6e7c6a9e7facbbf20ee0648b5
spec/dummy/config/credentials/message-bus-us-east-1.key1006440032 Bytes4a2ec4a89ec3d90bdecf8c6d2340552fea9711f79afcfaf4e2bf4d1bbb8ae9cb
spec/dummy/config/credentials/message-bus-us-east-1.yml.enc12075500../../../../config/credentials/message-bus-us-east-1.yml.enc0 Bytese3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855
spec/dummy/config/database.yml10064400810 Bytes2aa4e4fe91b56fff44511fb559a031a2b477939bdff012227aef263acb720f4d
spec/dummy/config/environment.rb10064400128 Bytes73b2e731e02cedb9dc0335e1a35c3a2b7738032e3aa7e62ac32cbb8432b43c69
spec/dummy/config/environments/development.rb100644002.19 KB8ff0fdf38e47b276e0d35929fdaec69a956239a70cc5adf0e7aa8d4d3449083a
spec/dummy/config/environments/production.rb100644004.87 KBcafb64ae02e521e53fcb1e7f0f6aba86dbef76f9307e1aa5b7c4427720e095fa
spec/dummy/config/environments/test.rb100644001.91 KBe8200df88ac0d546b8df4275acb5f0881ad6f57854f7071a0575e9ee8703fb15
spec/dummy/config/initializers/application_controller_renderer.rb10064400216 Bytes2da60f6ea41acdb4d85b965e7cedca0ab6ae9d45d44de9c15d8eeff44f05dac0
spec/dummy/config/initializers/assets.rb10064400502 Bytes1bc46e7ff46dcab8e5418d48e6af5eb199c5449e8d51e735ce1effdb4aacbe76
spec/dummy/config/initializers/backtrace_silencers.rb10064400404 Bytes12656d43090727d98c72bed6ba153b501ae0b7fdc5f20cfd64b5ab8a8bfa87a8
spec/dummy/config/initializers/content_security_policy.rb100644001.19 KBc9cc90a518737ac0965eb166061cbb4cac06152cefaf30bfd35ee11d4e85f96f
spec/dummy/config/initializers/cookies_serializer.rb10064400244 Bytes94782fa044850c5e6ec02c87eab7df522e2d589d4ba8d746bbf30fe63c9da23a
spec/dummy/config/initializers/filter_parameter_logging.rb10064400194 Byteseb293cbcac26012fb63489b355b7a68df2e0f5006abe79e2128752f40514aaf4
spec/dummy/config/initializers/inflections.rb10064400647 Bytesa2045e2ce03f29305e052a9236ff41d4c7d4d171c0fa5bf8cfbc958edd307df6
spec/dummy/config/initializers/message_bus_consumer.rb10064400183 Bytesc3329a283b83b60c8636edb37a149c104f75f00767a6d9b30bdc9fc0546bfff0
spec/dummy/config/initializers/mime_types.rb10064400156 Bytes47b40f15fe7b4cb01fd6a72377cfcc2c12d4a92b2cb72dca4d66005cddcccc94
spec/dummy/config/initializers/wrap_parameters.rb10064400485 Bytes7021fb9d3b221ade976a6c4574c004d906f4f61df64d914c574588cdaf04457c
spec/dummy/config/locales/en.yml10064400849 Bytes2de6f1a48e24e30802cdb539f3981fde4ad365b15787577f0d86983bb6e85b22
spec/dummy/config/puma.rb100644001.52 KB19aef85f834286e4d803fb3d2cf2826acd0def99a40016467925181d71781fac
spec/dummy/config/routes.rb10064400112 Bytese8c24c4944ace50aaf717244ff0e1ff6608b179c50eb191a7151e8c41c7c0901
spec/dummy/config/spring.rb1006440097 Bytesd9230eead11d6acf33c163518fccb90a3b96451d57a0685011020688c19e4cec
spec/dummy/config/storage.yml100644001.07 KB88082bbc96463336f95d17ed9ef787c85639f4159ddf1a525dd99261993b3222
spec/dummy/db/schema.rb100644001.03 KB72c78f771921002a7c84e9ec4e7838e0f643e775f538faf301934f8ecebde20f
spec/dummy/log/development.log10064400310 Bytese2a8909ba2575c9b6b9b100e96ed3251ca8cee3cf9272be888655c947de736bd
spec/dummy/log/production.log100644002.89 KB88596d5adcacbde166894d720b96f94c97e48da846a2e6031b1741ed147091c8
spec/dummy/log/test.log10064400575 KBb0ed100200eaaaf6fae027dc0618df90234a07d64c5bb1c43cf8f3287ef1dcbc
spec/dummy/public/404.html100644001.68 KB41e6541b07f9c3b306a517917eedb53d7c7bfa006faf6673aaad98c9d96f7023
spec/dummy/public/422.html100644001.67 KB848f8a124ddb3a76d24a7eca39f93cef89c4fba00e0cd0b2f0af37433fb88e89
spec/dummy/public/500.html100644001.6 KBef38a03155fab5fa59fe6c823f948893fe260204a87860c55522cdeb5672c959
spec/dummy/public/apple-touch-icon-precomposed.png100644000 Bytese3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855
spec/dummy/public/apple-touch-icon.png100644000 Bytese3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855
spec/dummy/public/favicon.ico100644000 Bytese3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855
spec/dummy/tmp/development_secret.txt10064400128 Bytesa1a23aba2b9bbd5318d40372b59fdeac36586461b61ae7645cdec681e92759a7
spec/integration/nulogy_message_bus_consumer/auditor_spec.rb100644001.38 KBfeb84e45de536850f84cb78bccc081fb3f4a0f9e8cfca4d1543436a62171d291
spec/integration/nulogy_message_bus_consumer/kafka_utils_spec.rb100644001.21 KBde22f46e5af001af59641ec8c0db0fd6d873177238021387b0e75e14e5a6d83a
spec/integration/nulogy_message_bus_consumer/steps/commit_on_success_spec.rb100644005.08 KBa50c164733ad45f4eeaf1b435b5d68b54a4d38a789626d86c8aaf1cd62ce43e5
spec/integration/nulogy_message_bus_consumer/steps/connect_to_message_bus_spec.rb100644001.5 KB46a0c2627ed75641651ee963575bf555f5c2731388db9a5d61c48293fbe686cb
spec/integration/nulogy_message_bus_consumer/steps/supervise_consumer_lag_spec.rb100644001.5 KBbdc5aae0df0560e3260758e1f6e9f76645c511f071fd20ddadb2d7f95c41204a
spec/integration/test_topic_spec.rb10064400933 Bytes67139eaacd6292ccaccf543f3cf1064a1f99b82bf0a20b93b41d5df36a6ff545
spec/spec_helper.rb100644001.43 KB2ca5054f0fa713cfb7ef999830907d73b405fac69cbdc015708d798bd49eaae4
spec/support/kafka.rb100644001.59 KBabc978ab3437082c0ec8a421917aabcdb04f5c240d92f755282eb26185d33410
spec/support/middleware_tap.rb10064400161 Bytes916e0b7feebd9412d33aaf5ee316fb581eae856fdb47215f94769fd20bd5cee8
spec/support/test_topic.rb10064400976 Bytesbcb7c3282eae4dd66e1dd0002eda93429124d84369e5e4475211a46525075952
spec/unit/nulogy_message_bus_consumer/config_spec.rb10064400491 Bytes3aa5a75110ac40a707e0f7eaa5ac12d483363d33171ec4e8da8b4f5dfe338a6a
spec/unit/nulogy_message_bus_consumer/lag_tracker.rb10064400995 Bytes7964bc6ef82e73d2551f49c148f5f7476a34ea16bf0060f1ddb332fa1f01ff31
spec/unit/nulogy_message_bus_consumer/message_spec.rb100644002.29 KB81c6b1e1ae757de38bbdd3b4c62a77d1783c192b42279c08e2fefe27e6c0e430
spec/unit/nulogy_message_bus_consumer/pipeline_spec.rb100644001.37 KB15b5ba3d4c37bfab8b59ce777841aa4f9c4ff08365d56977012d4fd760fb3b98
spec/unit/nulogy_message_bus_consumer/steps/commit_on_success_spec.rb100644001.9 KB70b2646838f5118830412ff9712308f8760acbce66a6241ea8ea4a236eadb984
spec/unit/nulogy_message_bus_consumer/steps/deduplicate_messages_spec.rb100644001.71 KB914ef6b610a56dc945fbddaa65940d4e7c3764c0c06f27fa00d35630e0ef7ecb
spec/unit/nulogy_message_bus_consumer/steps/log_messages_spec.rb100644002.07 KBcd75433c82e7ef1db577e5e0a04345b4a1d0cc254bb63fe897267acb473c6452
spec/unit/nulogy_message_bus_consumer/steps/monitor_replication_lag/calculator_spec.rb100644001.38 KB52ba08f2d50bfde04b7484d1df3154c97fca1e236c892bc175f718c6f907b2ed
spec/unit/nulogy_message_bus_consumer/steps/stream_messages_spec.rb100644001.21 KB1676d0f53debd8d3769f649522edb48cb79cee01936b7038bc3d6c38db74dae3
spec/unit/nulogy_message_bus_consumer_spec.rb10064400852 Bytesedceb22c885134564df35405831cbf786d45ff9e753a9876e523025c491ef792