nulogy_message_bus_consumer-2.0.1

https://rubygems.org

nulogy_message_bus_consumer

quick gemspec

.gem

.gem metadata (gemspec)

.gemspec

allowed_push_host
https://rubygems.org/

id: 1329317

number: 2.0.1

platform: ruby

spec_sha256: 74ad61742835963c01eca068ec8ae24ea4196f3ccfc3655f66946b1a923daaab

sha256: 83808fd128d0fa63f058f03a04cf323f30f933f426d87ba108e6108d777a276b

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

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

position: 0

version_data_entries_count: 103

uploaded_at: 2023-11-17 16:52:59 UTC

indexed: true

has_extensions:

extensions:

Gem size: 31.5 KB

Version Data Entries

Total: 103

Unpacked size: 86.7 KB

Full NameModeUIDGIDMtimeLinknameSizeSHA
Rakefile10064400631 Bytesce5a40f9db724bfaf96a7a5b1f7bac81477ca65f3dcf0150bb2ab3eef4b07964
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.rb100644003.04 KBaa7e7f7fb6d3ffe3e4a081b9a97f1ed27ad59b361c54abfea1a42003e52a92f1
lib/nulogy_message_bus_consumer/clock.rb10064400249 Bytes4c16fe4378941210c9a96a109a76af082298d61269e85709af9eb017ca7cbd82
lib/nulogy_message_bus_consumer/config.rb10064400768 Bytesf7dc862b6ed4cdb8cd464e465d3a639227435798b009dd6ebf79a9ab3e756ee9
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.54 KB93c0543793bd3ef45bceb79c4fbb426137714df6e9b66eb2f3e0bf8811e01d61
lib/nulogy_message_bus_consumer/lag_tracker.rb100644001.26 KB554a449e6d2d9184b450c26bb8d7e143ebeaa77e42457ca60c526b9e0c8262c4
lib/nulogy_message_bus_consumer/message.rb100644001.5 KB1d7e0ddcee7df199bbea6bb97b1835f161f2e6b4c2b2f50143efcffff0fe690b
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.rb100644001.31 KBfcfb398d46f06598545b815dc01a14a63c4cd9dd1df1fbb0b70d8dbf76f1682e
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_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.rb10064400854 Bytesa869426cf62f3a989af396ec5d1857d35104c0b096a42b1ecf2a46e0051c634d
lib/nulogy_message_bus_consumer/steps/timed_task.rb100644001.18 KBc0ed27b3742d82634d04288eac806293598821c125a1d9533b7ffdb686e4dd03
lib/nulogy_message_bus_consumer/tasks/log_consumer_lag.rb100644001.64 KBd893b610a6f2d725fdfa2e8044b3696d59858857173ffef9c5d75a7215c16cc3
lib/nulogy_message_bus_consumer/tasks/prune_processed_messages.rb10064400969 Bytesac80f0b69e41237f57ee3b905db7fe933e7293081be54fece2113d491911764b
lib/nulogy_message_bus_consumer/tasks/supervise_consumer_lag.rb100644002.05 KBe7f7af31be0811cf7a118125f5457a69de711fb7a438879b047df17543753b50
lib/nulogy_message_bus_consumer/version.rb1006440056 Bytesacad4af5b1a14d9eb7d94bdda9d3fc396660dee03f8400d5f21ee61e11045636
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.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 KBf5378da8cb9ccdc6573fbc43ad1d8a817b976b906442a53b0d2a8e0abdd55853
spec/dummy/log/test.log100644000 Bytese3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855
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/end_to_end_spec.rb100644001.52 KB1db41e4660ea0d8979e557cfc0a35151ceafc7689539990bdb87e54a60214638
spec/integration/nulogy_message_bus_consumer/kafka_utils_spec.rb100644001.24 KBc09980773e7c834426c112a0f89c86747e3d2e937cb2c00b787d3c005980ee77
spec/integration/nulogy_message_bus_consumer/steps/commit_on_success_spec.rb100644005.19 KBcac655066f593bbc4c8cbe8bd93e6621395f299c0c53925436523e92c1210392
spec/integration/nulogy_message_bus_consumer/steps/connect_to_message_bus_spec.rb100644001.11 KBe0dd7427f1d39806aaf98f781cc75b71ed9bb30184cdc3e8090f4119c386b7ef
spec/integration/nulogy_message_bus_consumer/tasks/prune_processed_messages_spec.rb10064400867 Bytes2cf5844ea38339d6de215673e2c2224dfae8dd85c614ac53d948fb584f531abf
spec/integration/nulogy_message_bus_consumer/tasks/supervise_consumer_lag_spec.rb100644001.05 KBca7d16fe4390ed13b97df676291c65bc01e00075cc9587c7645f4c7987484fb9
spec/integration/test_topic_spec.rb100644001009 Bytes360e868cee59c0682931d298bb327661144b80bcfbaab1904f438f9d1082ffaf
spec/spec_helper.rb100644001.45 KBee09feeca59ab4e2c385cfa0fd64501809389f1dc038dd00481601450afc72cd
spec/support/kafka.rb100644001.77 KBca124bec562106ff8ddf2433b53fe606bfaeefde2ee33ca0b57d818c64bea5b5
spec/support/middleware_tap.rb10064400161 Bytes916e0b7feebd9412d33aaf5ee316fb581eae856fdb47215f94769fd20bd5cee8
spec/support/skip.rb10064400170 Bytes6ffeb23bc11936447756cb06c6a211beb9584bd304809b3a819cc3c6e4e87f22
spec/support/test_topic.rb100644001001 Bytes758b63cc8e26d94fcc9d2c19389e91eadbc1e4d8eaf5e2a498030568225146f5
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.rb100644002.27 KB21d3d4f8d1c134e8ac237d173603e5846cef57a23a532ab51c8f4bb6e06c4dc5
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/stream_messages_spec.rb100644001.21 KB1676d0f53debd8d3769f649522edb48cb79cee01936b7038bc3d6c38db74dae3
spec/unit/nulogy_message_bus_consumer/tasks/calculator_spec.rb100644001.59 KB688e67c8af4b2caa94b9d6bfe564317103adec3147ee37d4b5f4b3769fba57da
spec/unit/nulogy_message_bus_consumer_spec.rb10064400852 Bytesedceb22c885134564df35405831cbf786d45ff9e753a9876e523025c491ef792