CHANGELOG.md | 100644 | 0 | 0 | | | 15.1 KB | d795dfa2207f257b409cf0bd0511a2bf94ebfe7ef78a2f8be1234eddc812667a |
.ruby-version | 100644 | 0 | 0 | | | 7 Bytes | c275e40850f193586ae377b9fbb9b60c05ba0c9c7352d218c3d81aca85bf58c0 |
.circleci/config.yml | 100644 | 0 | 0 | | | 2.04 KB | 722c9170c31deb669607753aae50a01bd72c1e7e150caf31cc3a59eef9a9179b |
.github/workflows/ci.yml | 100644 | 0 | 0 | | | 937 Bytes | faec1cd272f842c82b0656fc129bd13b5591e259fdd91b5be9f5c8f71361e029 |
.gitignore | 100644 | 0 | 0 | | | 743 Bytes | b46f316b19dac4ed7b82364116655048210deb6c41fd820b3f0d76542d4cddcf |
.gitmodules | 100644 | 0 | 0 | | | 0 Bytes | e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855 |
.rspec | 100644 | 0 | 0 | | | 89 Bytes | e433ee879fe95cf8100fcdc8d8b991c1f9bfc024ef4c8871f5c4abb49630ac94 |
.rubocop.yml | 100644 | 0 | 0 | | | 6.2 KB | 48f0e82c89d41ccfba3d1cfbac716c17bbdfe93f52d5f623d2b987c843e6385f |
.rubocop_todo.yml | 100644 | 0 | 0 | | | 11.3 KB | f0e8402934903ca544f86cfa23244eedf8b248ba8f53801cf0be15fe10887b16 |
CODE_OF_CONDUCT.md | 100644 | 0 | 0 | | | 3.29 KB | d67a1d40477ef0d2c60df0284350e6edfa349a60cc984a3ab7410a9a2e27c4a1 |
Dockerfile | 100644 | 0 | 0 | | | 788 Bytes | 10183acc12ab89e1981c6316fc6a4a398bf0fec4e7e0b75196e08eda13ae8e55 |
Gemfile | 100644 | 0 | 0 | | | 322 Bytes | 9951d028027fd409c5d0e56f7620fd2a220db855f7e261ca80f2e208437157a2 |
Guardfile | 100644 | 0 | 0 | | | 887 Bytes | 50e6482eca3db70546dd580a4d0b1c82172bef9e4bb28f4b7f064561c6eaffe3 |
LICENSE.md | 100644 | 0 | 0 | | | 10.2 KB | ec640150e03774d1b5264fb268f3829dc36745551109131ebf6dd0a59d5ec3eb |
README.md | 100644 | 0 | 0 | | | 42.9 KB | 6cddfa27096cfeb211524eff3dc1cf002746d61def81597d1eddf445734857ed |
Rakefile | 100644 | 0 | 0 | | | 236 Bytes | e437652bf66d75ca075b566c4bc2e7899bf52e7ce069ce02e5402b3253f56f64 |
Steepfile | 100644 | 0 | 0 | | | 111 Bytes | b5c1e39ff0257a4c091b6074a5b9d4fc408e02dd40e612b6cb3ff1efd22f428c |
bin/console | 100755 | 0 | 0 | | | 371 Bytes | f354b484a845d8204166b5abdb80aefbbf50af199e217e43ad7fa2f613082f86 |
bin/deimos | 100755 | 0 | 0 | | | 68 Bytes | 65500583cc0f73ab9cc1620ce10fdf916bcbe9027e2da75a9b782d63bbdd07dc |
deimos-ruby.gemspec | 100644 | 0 | 0 | | | 2.08 KB | c35cdcea55cf8e20ce8da382de80c168141feaaf6a8df67e89ba035ae2f435de |
docker-compose.yml | 100644 | 0 | 0 | | | 1.84 KB | 104e5a8f481232ea0d4b7816b66c112924b003a0b9a5f848faf51cff99d9e500 |
docs/ARCHITECTURE.md | 100644 | 0 | 0 | | | 6.34 KB | 68521968f8ba94e9547518c6db8b62920633fcf56c49d4d2167d0e48cd591f07 |
docs/CONFIGURATION.md | 100644 | 0 | 0 | | | 14.5 KB | 80683701edb590395dcb3b5d745d67af2c8f2caafc7696f40951bacc8c9e4629 |
docs/DATABASE_BACKEND.md | 100644 | 0 | 0 | | | 8.02 KB | e86d154b9c87bb7a45515fbede856b711252c7ac574df26b9fa02e12b9a70493 |
docs/INTEGRATION_TESTS.md | 100644 | 0 | 0 | | | 1.5 KB | 3d8b2f8f85a520839548da5735fd121faf849ad9b3281da4ea0e0f6092e8a7e1 |
docs/PULL_REQUEST_TEMPLATE.md | 100644 | 0 | 0 | | | 1.39 KB | 9d0e9610cd3b855973e782e2ea92ffe6c6ad2d084386e2ed11370a8de2bb6d85 |
docs/UPGRADING.md | 100644 | 0 | 0 | | | 3.17 KB | 57f6fbde969104ab9ef716fc16ac394db752954202929d168453515285bd30d6 |
lib/deimos.rb | 100644 | 0 | 0 | | | 3.38 KB | ea64cc97c3bf2c9b6ba2a0866d72da2f3c96b5951050a060c139e3fee2228030 |
lib/deimos/active_record_consume/batch_consumption.rb | 100644 | 0 | 0 | | | 5.9 KB | 9510abfbbebea6dfdd435486f19a4a3a8c20f0efb511d02924979833acd4de3e |
lib/deimos/active_record_consume/batch_slicer.rb | 100644 | 0 | 0 | | | 980 Bytes | 5640c31844225f14e4cc2ccfd4b475e911066952da60c6b561e489ea5aaaf4d9 |
lib/deimos/active_record_consume/message_consumption.rb | 100644 | 0 | 0 | | | 2.93 KB | 829dfc55b9fb5719636ea030d2adbfbc803793ce964ebe4b8c01e017ab080d4f |
lib/deimos/active_record_consume/schema_model_converter.rb | 100644 | 0 | 0 | | | 1.53 KB | 2786c8619f5139ac5d1d5b821b4b8082df9989b2a7f34d34f989fbd5433b4733 |
lib/deimos/active_record_consumer.rb | 100644 | 0 | 0 | | | 2.45 KB | 3b53169685610348b4f9655e5a7b79d100e247b9b2d0947e495505c7b6fdb682 |
lib/deimos/active_record_producer.rb | 100644 | 0 | 0 | | | 3.79 KB | 448e6c11bdaffb5a41420bc90e1f40b228f0b3dd5ab2d57770b8a28d4cb14ea1 |
lib/deimos/backends/base.rb | 100644 | 0 | 0 | | | 973 Bytes | d9d9da1cf211e99e9213042f8433561658e80c6b0cc33da499e731bf94ca13a4 |
lib/deimos/backends/db.rb | 100644 | 0 | 0 | | | 1.23 KB | 0ba8d9a110a34f269a59865131e6eb3904db160d441667f911f67aab04d5552a |
lib/deimos/backends/kafka.rb | 100644 | 0 | 0 | | | 925 Bytes | 8975edfef9d5b5b44a5b8baea673855ddb414db9b2734c7efc69fce32303c2d1 |
lib/deimos/backends/kafka_async.rb | 100644 | 0 | 0 | | | 901 Bytes | 61e898ac63e2c1299958ae8c32e885dbba2c636019141306691e27bfc1d2bb0a |
lib/deimos/backends/test.rb | 100644 | 0 | 0 | | | 446 Bytes | ab36a533ec4a3aaf9dcb7b911f1e09d146e56906e7b6700c7f07fc2631015682 |
lib/deimos/batch_consumer.rb | 100644 | 0 | 0 | | | 174 Bytes | 9ba902205fb096471ae594d9b985fc7ccb75e8c3bd2d49ef9818cfb7c81d8f4c |
lib/deimos/config/configuration.rb | 100644 | 0 | 0 | | | 16.2 KB | aca5f902f6607ab48c74612e0f42cde31fa5a381f2ceb117c751e801f0af3bc2 |
lib/deimos/config/phobos_config.rb | 100644 | 0 | 0 | | | 5.03 KB | c41de0cdcdbb83f4675b5df0de0b088736e728a1f6f5929d2b272f8604dc4e3d |
lib/deimos/consume/batch_consumption.rb | 100644 | 0 | 0 | | | 4.93 KB | e07b1b1d23a3dab2d8644fa9be82a1e6bc60bd4e6f442f4ac153d942dc6075b1 |
lib/deimos/consume/message_consumption.rb | 100644 | 0 | 0 | | | 3.15 KB | 2faffb22dc0d5c4f9fb0237523e40f5bedeaab571306d512ea5e398542c386ef |
lib/deimos/consumer.rb | 100644 | 0 | 0 | | | 3.79 KB | 6c1cb193df54d27be8ede328f90d44d06faa79cd96352264be52e2917de9b8f0 |
lib/deimos/instrumentation.rb | 100644 | 0 | 0 | | | 2.44 KB | 7094630d3949d38514e4589c87d08a224b84d80def5a9783fc8c154c8ffc1a41 |
lib/deimos/kafka_message.rb | 100644 | 0 | 0 | | | 1.59 KB | b4c069c377dc2b295563b039ca1b23444d68cd0d37cecbeed85aa37ec0c8e4f3 |
lib/deimos/kafka_source.rb | 100644 | 0 | 0 | | | 4.6 KB | b01af2e73c632984c272fec65cb7a0c8665b761dde31a0186acfbf850a8d1024 |
lib/deimos/kafka_topic_info.rb | 100644 | 0 | 0 | | | 4.23 KB | c65b2fc89657b648b49c1215bf0573551043e6586f9a18edefb395e3d44f3fb9 |
lib/deimos/message.rb | 100644 | 0 | 0 | | | 2.4 KB | 0746a641f28a45634a6434b07cdd54688fe0a282d4e1f77f124a3ab4d0146f74 |
lib/deimos/metrics/datadog.rb | 100644 | 0 | 0 | | | 1.3 KB | 8944f347ccf8fc3a9236f0c5cd3350a391e4ea7cc5bef9e720c79ea29d5867bd |
lib/deimos/metrics/mock.rb | 100644 | 0 | 0 | | | 1.13 KB | 0940943848c853c09472cc8259a6303bab8ab67227b55b30c1f0a200a8c2c028 |
lib/deimos/metrics/provider.rb | 100644 | 0 | 0 | | | 1.33 KB | 2e556417cb61d752a8e656ffcbefbca346e2fbdf393b5af7f9ee472c3871437a |
lib/deimos/monkey_patches/phobos_cli.rb | 100644 | 0 | 0 | | | 967 Bytes | 15022e0daec9d59a1d201f9d8201a476307e57e64ecdfe032f412b919075b1f8 |
lib/deimos/monkey_patches/phobos_producer.rb | 100644 | 0 | 0 | | | 1.43 KB | 9f1f7b7cfd746fd9a5e9432090eaac1958d98924cb69467af6cefb9eb847e632 |
lib/deimos/poll_info.rb | 100644 | 0 | 0 | | | 232 Bytes | cd45f5538ae1413eb9dca7f5ba9a3bc7878a7f11ebe6477d51a1dcddb848b084 |
lib/deimos/producer.rb | 100644 | 0 | 0 | | | 7.91 KB | 01c5f23e249e90f75c540492b1eaef2a9ad0da1d3eca3a4b096d95e3d6f3a8a9 |
lib/deimos/railtie.rb | 100644 | 0 | 0 | | | 151 Bytes | f96918432df8a010ab107e7f0609c044f40225d26c81821c32a88a8bb605077a |
lib/deimos/schema_backends/avro_base.rb | 100644 | 0 | 0 | | | 6.05 KB | dfc858a44efa59589944747b6a7ed4045703be6158bf8a8cc3a4e123912f284b |
lib/deimos/schema_backends/avro_local.rb | 100644 | 0 | 0 | | | 719 Bytes | 0fbb4d03cb72de746d55e44425f2a988dae33c0bd834c67f474241f69376ea23 |
lib/deimos/schema_backends/avro_schema_coercer.rb | 100644 | 0 | 0 | | | 2.85 KB | 9187c5efdded79e6d05703a2b4422f74638c12e0ec9c1b135268344a8f1648ca |
lib/deimos/schema_backends/avro_schema_registry.rb | 100644 | 0 | 0 | | | 1.05 KB | 3ec0612c4dae75944a93bff0cc3a403c1bee8f6f3d242d190a1e6f13a6c35b62 |
lib/deimos/schema_backends/avro_validation.rb | 100644 | 0 | 0 | | | 493 Bytes | c950e6d5f449162cb97d3134264b161b7dea99bf9f8c16f7dd9bdf7bfa2c1aba |
lib/deimos/schema_backends/base.rb | 100644 | 0 | 0 | | | 5.51 KB | d565f1ff5c1962bd42a4d3d6a985d69550c9e28b54d5ae7d6fb62e6261494ae1 |
lib/deimos/schema_backends/mock.rb | 100644 | 0 | 0 | | | 928 Bytes | bf39784ee9acc7758060e438a06d170410493d23663dd2fd321daf738c90a3cf |
lib/deimos/schema_class/base.rb | 100644 | 0 | 0 | | | 1.28 KB | 3fe0869521c366361f390382d2471fbf40b1f1420fd314fbfe12e8f40ce835a8 |
lib/deimos/schema_class/enum.rb | 100644 | 0 | 0 | | | 1001 Bytes | bfd90ab817346b0e1454146cc0edd22b80c5d6c8bc2c8706ba27437d72fbef63 |
lib/deimos/schema_class/record.rb | 100644 | 0 | 0 | | | 2.17 KB | 2d6f6d3f87b4623727996a03f6e544d9134514e1c576cb1d593c346721bade58 |
lib/deimos/shared_config.rb | 100644 | 0 | 0 | | | 2.1 KB | bed863e156b2f69420d2d383ed8800337da294dc294238ec30fc008ad943940d |
lib/deimos/test_helpers.rb | 100644 | 0 | 0 | | | 14.8 KB | b7f9bc132381dcc339f170888d935819078c2948e01ed0f10cc9c80f2c25168c |
lib/deimos/tracing/datadog.rb | 100644 | 0 | 0 | | | 966 Bytes | fbbe3a2ec64c07d05f05325d73b02098aaae916dfc5d8a2871673edc39609ae4 |
lib/deimos/tracing/mock.rb | 100644 | 0 | 0 | | | 1.16 KB | 0971d96fea7a1dd5f80d91a3062ec3d969e5d384fb82c3cc619f77ac4be6674a |
lib/deimos/tracing/provider.rb | 100644 | 0 | 0 | | | 1.26 KB | 5ecb8ca14359b6c2f5bc663cde53818d73d8be8519ec3ed7034375c97b30e8bc |
lib/deimos/utils/db_poller.rb | 100644 | 0 | 0 | | | 6.76 KB | 552707c4ba3950447c58020c5846c3c3c2353a1476458a3eeebeeac6d5e73dbb |
lib/deimos/utils/db_producer.rb | 100644 | 0 | 0 | | | 8.55 KB | 1f4683a63580d4d274bdf329c205d956e196e94ccf3e8e2d59eb83ecda6632e4 |
lib/deimos/utils/deadlock_retry.rb | 100644 | 0 | 0 | | | 2.3 KB | ac281ed62a0737b48c985591b0e4ce6d46cbbd84aead7f63598badcaabdff1ca |
lib/deimos/utils/inline_consumer.rb | 100644 | 0 | 0 | | | 5.39 KB | fea51216c53cc0a71cf24f6ad0ec4666752b53bf8506b914faac818fdf23a1ca |
lib/deimos/utils/lag_reporter.rb | 100644 | 0 | 0 | | | 5.86 KB | fb6831bd1187c30072d3146ee41959a427c9567c5052637abb98d74a99213762 |
lib/deimos/utils/schema_class.rb | 100644 | 0 | 0 | | | 1.46 KB | be66029d07c910cf176c45c1f3d5de428118b1e0bd6b453350ade91dc0534182 |
lib/deimos/utils/schema_controller_mixin.rb | 100644 | 0 | 0 | | | 4.27 KB | 4f4151e4584ab5eafae18044628b1eca0921cdd838ad14313e963e26d0b2fad7 |
lib/deimos/version.rb | 100644 | 0 | 0 | | | 70 Bytes | 09914c93b169662ba5ba4aa22b40bf20f18aa7b5f489abff8d79a7685df373f0 |
lib/generators/deimos/active_record/templates/migration.rb.tt | 100644 | 0 | 0 | | | 887 Bytes | 639b8384b68619f1f1e70101bb01b05ae1152dddb68841655332877450d49859 |
lib/generators/deimos/active_record/templates/model.rb.tt | 100644 | 0 | 0 | | | 223 Bytes | 0a9337f3ffe94fa7a1cc54ad92a78a2b602b9040340348f316855ff141ee2f5a |
lib/generators/deimos/active_record_generator.rb | 100644 | 0 | 0 | | | 2.23 KB | b01a51bbc3d2b5a55f91352dfd11d0f7de9c45f5d47142382ebbd7bf03af847f |
lib/generators/deimos/db_backend/templates/migration | 100644 | 0 | 0 | | | 856 Bytes | 2d7aec9956b0b90c88e95f3cc6b77c9e1bcf46f683cc543b210edbae3abadae9 |
lib/generators/deimos/db_backend/templates/rails3_migration | 100644 | 0 | 0 | | | 945 Bytes | 0412ecf932c3534cdaac90ee80e21f2b9fc56713045c5a860295b68452fa658d |
lib/generators/deimos/db_backend_generator.rb | 100644 | 0 | 0 | | | 1.41 KB | bdcec64470b9f12e08263b2b2ad5c3a35e012c6692bcde6ab31a7295c01ca3b6 |
lib/generators/deimos/db_poller/templates/migration | 100644 | 0 | 0 | | | 311 Bytes | c4d4e014dc29ec8d5051c23b30d66cf3b728b03c512df64fe6a321fbb8ec3d11 |
lib/generators/deimos/db_poller/templates/rails3_migration | 100644 | 0 | 0 | | | 369 Bytes | b542b4372ce652d09dafcab24c8991669f9cbc79be9b25102d90685225448a75 |
lib/generators/deimos/db_poller_generator.rb | 100644 | 0 | 0 | | | 1.41 KB | d45f45acfe985f74fd0e9fe9d76561401e98ab1ef4441f96ccc4a71e57ab5e60 |
lib/generators/deimos/schema_class/templates/schema_class.rb.tt | 100644 | 0 | 0 | | | 244 Bytes | 469db575b7bdd425ea0d6609497b099cefbc97b8208ed2c128be38a6078d2ac5 |
lib/generators/deimos/schema_class/templates/schema_enum.rb.tt | 100644 | 0 | 0 | | | 426 Bytes | 1755fb720fca5aa6b5441ef240ae2a8ab29cf1df22b16ab947c7aa975bf358ec |
lib/generators/deimos/schema_class/templates/schema_record.rb.tt | 100644 | 0 | 0 | | | 2.6 KB | 8bdba3f9a5f5be756c8d54ed4805e91d70b4b82ff545b48afe933ac6ba4cb29b |
lib/generators/deimos/schema_class_generator.rb | 100644 | 0 | 0 | | | 12.7 KB | 346a97cc3409382f68c32f10a034e8c6ca1d84b7429d0386976c61b5f8406b0c |
lib/tasks/deimos.rake | 100644 | 0 | 0 | | | 1.27 KB | 71a2944edac167f56fd25e06cf27a8afe4c3f4c11664a7b91a380f6c09e60e16 |
rbs_collection.lock.yaml | 100644 | 0 | 0 | | | 4.16 KB | 28d45977866789ff4d9098d8db836d5c0602a8fbb832c9b5f7f90c5a900bd875 |
rbs_collection.yaml | 100644 | 0 | 0 | | | 357 Bytes | a52ef96a6a2d748e9da0177ba804871c016b3a26b0c1f64da64b01afe4c36e26 |
regenerate_test_schema_classes.rb | 100755 | 0 | 0 | | | 1.65 KB | bb7fd7836dd69c3a3fc1e08ad55e9146e9c0c1937caf049b55e554b72d681653 |
sig/avro.rbs | 100644 | 0 | 0 | | | 132 Bytes | 2ad24b2fb312f6668050030ba850a439b63667106ee80db75f13634d59a3eb24 |
sig/defs.rbs | 100644 | 0 | 0 | | | 61.9 KB | b675d35f4bc1d2199bd35beb9f2afe3c6de4a8a26e1c8aef8c3997be9bf0d9fe |
sig/fig_tree.rbs | 100644 | 0 | 0 | | | 19 Bytes | fc8996e817e55b2e4ea54940a4044d17719e1f370eeaa323f218002953b225c1 |
spec/active_record_batch_consumer_spec.rb | 100644 | 0 | 0 | | | 14.2 KB | 3782726ed9b153e045ccf3e598d00e6766abf7feb6cd374d48ab98b117694f8b |
spec/active_record_consume/batch_slicer_spec.rb | 100644 | 0 | 0 | | | 1.42 KB | 6a32af21334b1625a3d428568cadf79533dbbe97cf30bacbdf88e230c294dab8 |
spec/active_record_consume/schema_model_converter_spec.rb | 100644 | 0 | 0 | | | 3.22 KB | fc07e4c706cef72dafc3ae3607949d16789a9a9b34ea8d75dec5b8b62a797729 |
spec/active_record_consumer_spec.rb | 100644 | 0 | 0 | | | 6.7 KB | 5121ff73a1824b4929fec4aea369fdee713db0b326148abaa379b4a8b5a05f23 |
spec/active_record_producer_spec.rb | 100644 | 0 | 0 | | | 3.85 KB | 8fc702b065a50d6d0c552bfba76ff70525ec74501e667131357151dbd73f0cce |
spec/backends/base_spec.rb | 100644 | 0 | 0 | | | 338 Bytes | 7c5504d96ccfca82e5cafed64d3f3a14861dc62beee385bbdd79aada1e305242 |
spec/backends/db_spec.rb | 100644 | 0 | 0 | | | 1.84 KB | 8a9a6fec6fc79e612001774e0dbeca1b1fa08c67d03b361a1d48ae72eb956d14 |
spec/backends/kafka_async_spec.rb | 100644 | 0 | 0 | | | 487 Bytes | 630daf958caa06e0085e06a68664cb08bd16ee6f81276f00ac878919caafd573 |
spec/backends/kafka_spec.rb | 100644 | 0 | 0 | | | 475 Bytes | f03bf11e9d0735ba1a4779b1cb41da29cc5830a71e844c8754c4edb7cdb99ec8 |
spec/batch_consumer_spec.rb | 100644 | 0 | 0 | | | 8.3 KB | 2de82dabf415f0582e0495863cbc1ddcb1b22f0249b4021f7d6d296c927b4f13 |
spec/config/configuration_spec.rb | 100644 | 0 | 0 | | | 8.67 KB | bbeb69d4764a372d2d1b742be6ab59827485187323d2f5d259bede2cde441801 |
spec/consumer_spec.rb | 100644 | 0 | 0 | | | 8.49 KB | d4b51a20cf8775967018904619a511f9e9ce5f12c2b75c4f07f6f6fb6eb9b6c2 |
spec/deimos_spec.rb | 100644 | 0 | 0 | | | 5.53 KB | f16f57b0d877b8c1df21ce0958da125f070bc780bc83a7492a01b8a153f70da9 |
spec/generators/active_record_generator_spec.rb | 100644 | 0 | 0 | | | 1.62 KB | e61ab6010e7c863a8bca68bd631f7c1ea91aeba66ebde00e828e01a5c499d000 |
spec/generators/schema_class/my_schema_spec.rb | 100644 | 0 | 0 | | | 605 Bytes | 4f466a37529cb4e4dec15b3de25dc7eae554fcefef689c7f9934f020a081bc98 |
spec/generators/schema_class/my_schema_with_circular_reference_spec.rb | 100644 | 0 | 0 | | | 2.58 KB | f33316a1c5aa8b91fc74d7be30d1657aa6d396ee93b0a42135ff349f08a36d90 |
spec/generators/schema_class/my_schema_with_complex_types_spec.rb | 100644 | 0 | 0 | | | 8.89 KB | aa7c4cf404fb60ada751e502e1e42fd47274e0c67ca593feebc8c1fbcf86e668 |
spec/generators/schema_class_generator_spec.rb | 100644 | 0 | 0 | | | 7.55 KB | a2f20ec6a8eca4ad508113a3327c37ccf6195e3b65683682e3991e2d1e0d4897 |
spec/handlers/my_batch_consumer.rb | 100644 | 0 | 0 | | | 167 Bytes | 2872c8c13dc2d659b0f4a856d4b5099df722515731d2da32cf7f586b1bae8788 |
spec/handlers/my_consumer.rb | 100644 | 0 | 0 | | | 156 Bytes | ebe1eec70a7259b37629759dce8c0048ecf02d419a756806c11b3930db4c5270 |
spec/kafka_listener_spec.rb | 100644 | 0 | 0 | | | 1.79 KB | 9be6f072d9efa504fda4a4006220f86c9b1720b8833c3004432c1ac9df5f15eb |
spec/kafka_source_spec.rb | 100644 | 0 | 0 | | | 15.4 KB | ddb5037fe02bb55378463a32e822b6f0757b88a2c6abadd7ffcdaf13122a57d1 |
spec/kafka_topic_info_spec.rb | 100644 | 0 | 0 | | | 4.7 KB | 099b404425f412e9f666c21aa71f7652bf5f3be21ff2fa70a0d06a2b133b514c |
spec/message_spec.rb | 100644 | 0 | 0 | | | 614 Bytes | cf09cb2479066e7ed5ba1c09a6549f5493d9866aafc603a615445c896b6d9b57 |
spec/phobos.bad_db.yml | 100644 | 0 | 0 | | | 2.71 KB | 3fb0825ab623a3e2d54b615271ce5ebaa45877d2998793f97dfa668dfbe23ffe |
spec/phobos.yml | 100644 | 0 | 0 | | | 2.85 KB | 9c88eec2c7df4cb61f289b300f0c5a66d50ac9369185f8743419d4047a3664bc |
spec/producer_spec.rb | 100644 | 0 | 0 | | | 23.8 KB | 6e79c13ceb168bca7b13734e0ca23f834148ea0e92b3fffe5dae1e62f5a9a348 |
spec/rake_spec.rb | 100644 | 0 | 0 | | | 490 Bytes | ccc5550fd49a04001778e360d0c6b827179a604efb1a6e35f3dd39b1025fd8cb |
spec/schema_backends/avro_base_shared.rb | 100644 | 0 | 0 | | | 5.69 KB | 410da57d7d967bf728aff1097485df3d541a2fcb9df7ccb10c12666094a0c3cf |
spec/schema_backends/avro_local_spec.rb | 100644 | 0 | 0 | | | 1022 Bytes | e43610861cf5c39f6b8a389de11546ed509ab6f281b57aa889816c93e0404cc2 |
spec/schema_backends/avro_schema_registry_spec.rb | 100644 | 0 | 0 | | | 1.01 KB | 35175ca10ba0f0c7758020e9462b6ddaa29b85edbb68388c8a9b4725cd65eb15 |
spec/schema_backends/avro_validation_spec.rb | 100644 | 0 | 0 | | | 604 Bytes | 5fe51e6d67a2a3fee9911a923181b10e78f0d7d49280d9d9890a9c95c4a998b5 |
spec/schema_backends/base_spec.rb | 100644 | 0 | 0 | | | 1.15 KB | 4d22b4f18617b77239b04b5bd375cc526acffc78d51608f93d40ce7a8198c12a |
spec/schemas/com/my-namespace/Generated.avsc | 100644 | 0 | 0 | | | 1.26 KB | acfd121f717a912889fd0a07ded92dcb5dba4d77cd68cc9dfc29b7b51e1b1bd6 |
spec/schemas/com/my-namespace/MyNestedSchema.avsc | 100644 | 0 | 0 | | | 1.27 KB | 10df87d69ac17135167ffd00d2b39351ace30c6d905d3c9bc3cd02ab52472cc6 |
spec/schemas/com/my-namespace/MySchema.avsc | 100644 | 0 | 0 | | | 295 Bytes | 6bdef945cff2737a248f5e28f852e770f271dfc1915e792110c762bce1fc6054 |
spec/schemas/com/my-namespace/MySchemaCompound_key.avsc | 100644 | 0 | 0 | | | 322 Bytes | b3100596a5929165b878825ef8f93362992fa309c064edc3c26b031cf93d46bb |
spec/schemas/com/my-namespace/MySchemaId_key.avsc | 100644 | 0 | 0 | | | 181 Bytes | e6a794ba4eab0d54c4de4b37cc8cda6e7c52a7795e1933f455637e19a7934e7b |
spec/schemas/com/my-namespace/MySchemaWithBooleans.avsc | 100644 | 0 | 0 | | | 313 Bytes | 484530c3cbef46b7eb1887c0c3ab2649363124c91388f78aefa6e1ddc5d870fc |
spec/schemas/com/my-namespace/MySchemaWithCircularReference.avsc | 100644 | 0 | 0 | | | 821 Bytes | 858651fb335d00ca640fc7cc53d3904f517298f8df34769737ec3a473560161c |
spec/schemas/com/my-namespace/MySchemaWithComplexTypes.avsc | 100644 | 0 | 0 | | | 2.21 KB | d13c115b4bd4cb8b19b39e9c3f10e9db6491be2e11bfad61cf11204b163a3176 |
spec/schemas/com/my-namespace/MySchemaWithDateTimes.avsc | 100644 | 0 | 0 | | | 611 Bytes | 829ce9c70effa5798b972489ea3ab8275c61b06c1a16b0f87954d6ceef831ff3 |
spec/schemas/com/my-namespace/MySchemaWithId.avsc | 100644 | 0 | 0 | | | 475 Bytes | 140c9820f33af437703349b69cd13b1a19f08cab2644ae977a2ce1056110159c |
spec/schemas/com/my-namespace/MySchemaWithUniqueId.avsc | 100644 | 0 | 0 | | | 534 Bytes | a701a8b9bf675d2a7f88722dd41266d3cbf39f56ae533b5a5b293f49595c0819 |
spec/schemas/com/my-namespace/MySchema_key.avsc | 100644 | 0 | 0 | | | 215 Bytes | a1cac473e4b8d37f7ddc398afd583ddb49a348f0643d73aa6000d7e776a3832d |
spec/schemas/com/my-namespace/Wibble.avsc | 100644 | 0 | 0 | | | 658 Bytes | 1098b65bb774e4ad258655757862b8a0f7832ada4e5197173490eefe20e07f32 |
spec/schemas/com/my-namespace/Widget.avsc | 100644 | 0 | 0 | | | 393 Bytes | 6139b39887c289d7b87bc3bf3a3517ca8af0fb1f790b67587c6f7e8d7ce826be |
spec/schemas/com/my-namespace/WidgetTheSecond.avsc | 100644 | 0 | 0 | | | 406 Bytes | 3c6844eb94d45f4b91a48280ed4937cae655be1c3e1be700a176fcf906fea51d |
spec/schemas/com/my-namespace/request/CreateTopic.avsc | 100644 | 0 | 0 | | | 173 Bytes | cdfc3b1fd784cfcfa40b85ec2b382b61b6fb66913bb0bf720329b01db092ec97 |
spec/schemas/com/my-namespace/request/Index.avsc | 100644 | 0 | 0 | | | 167 Bytes | 3743df8134b80587fc37eb808b7e66b75a00234ca19bd1569fb81fb3aeb126a0 |
spec/schemas/com/my-namespace/request/UpdateRequest.avsc | 100644 | 0 | 0 | | | 182 Bytes | 55f883d8401038ea810e40b65ad23ec4673dc6284673398b6b44e3f140f849c7 |
spec/schemas/com/my-namespace/response/CreateTopic.avsc | 100644 | 0 | 0 | | | 175 Bytes | d9ad4a264a37f4e0002cc2874560124a246a98299948139c2a3f2aa0912db479 |
spec/schemas/com/my-namespace/response/Index.avsc | 100644 | 0 | 0 | | | 169 Bytes | 9e34013a3d2faad47a51cc370d58b225a2ff837094d4afd522061cd2642203bc |
spec/schemas/com/my-namespace/response/UpdateResponse.avsc | 100644 | 0 | 0 | | | 185 Bytes | f3a6fbe7fe9bad4575d39d3eb0e02453970c75da0e9ba238c2d8adadd397b8f5 |
spec/schemas/my_namespace/generated.rb | 100644 | 0 | 0 | | | 3.61 KB | 060ba8e7e4b2c47004d8734066d84504c18f9f76a120ed47f334ce761ed9acee |
spec/schemas/my_namespace/my_nested_schema.rb | 100644 | 0 | 0 | | | 3.13 KB | 03115ff45b422353e472a726a54b4221146e6e015b0e35a7dbb5d0be85136516 |
spec/schemas/my_namespace/my_schema.rb | 100644 | 0 | 0 | | | 1.34 KB | 88552ecc5628083ffe160d062c20f77de49733ed6147bd063d1d06cc00cb49c5 |
spec/schemas/my_namespace/my_schema_compound_key.rb | 100644 | 0 | 0 | | | 872 Bytes | a7c83e6548d02a2f0b3bbbd51572872429714bfcd4091c0aebbdf229630ab2ed |
spec/schemas/my_namespace/my_schema_id_key.rb | 100644 | 0 | 0 | | | 670 Bytes | 75f1b3381bec0b35ae74390b3863818f2249d576e5f0e592fd76b09a167e1b39 |
spec/schemas/my_namespace/my_schema_key.rb | 100644 | 0 | 0 | | | 693 Bytes | 5354f7d2b460914a966cc5b46177f17d43aab636687d41402aae3c14eb350d47 |
spec/schemas/my_namespace/my_schema_with_boolean.rb | 100644 | 0 | 0 | | | 873 Bytes | 30b20643afec9a073068e821cc1e5c75ad1dd6c3244cbee87a8cde0f9956a30a |
spec/schemas/my_namespace/my_schema_with_circular_reference.rb | 100644 | 0 | 0 | | | 1.77 KB | d59e7692d9075e019a3bb293d25ac1e1280a548178ea185ef94af477a3c758c7 |
spec/schemas/my_namespace/my_schema_with_complex_type.rb | 100644 | 0 | 0 | | | 5.95 KB | c444b77602d8ab003121a91ac483d3c6a2db177be0a4ae4dee258cc99329102b |
spec/schemas/my_namespace/my_schema_with_date_time.rb | 100644 | 0 | 0 | | | 1.37 KB | 523ce442e3d7ba87263862a42f8239b532c7292f1f2f51cd3c7c6b1fdc836fb7 |
spec/schemas/my_namespace/my_schema_with_id.rb | 100644 | 0 | 0 | | | 1.14 KB | 8ac0fa65cc3b48189b8fab63bb33a5457d7e9891f90210ef5803b8b3ee3da70a |
spec/schemas/my_namespace/my_schema_with_unique_id.rb | 100644 | 0 | 0 | | | 1.27 KB | 01288f43c6292ca1c31a2d9ff853befcf7a3e153bf576b02e580ff01f6c224b5 |
spec/schemas/my_namespace/wibble.rb | 100644 | 0 | 0 | | | 1.9 KB | 59d89d180cfb71e81b2a1a5a6e4b7fb9c33bd44eeceae3deb49f0c73f21f1730 |
spec/schemas/my_namespace/widget.rb | 100644 | 0 | 0 | | | 1.22 KB | 1796c00fc7a7f771ed6dc08934b7b8c46f32a8f0dd0875fb5754028766d704b5 |
spec/schemas/my_namespace/widget_the_second.rb | 100644 | 0 | 0 | | | 1.27 KB | bfd65f22ee17b208f68c7ae66033677ea790ee868e70748d7015f2bfb33acdd2 |
spec/schemas/request/create_topic.rb | 100644 | 0 | 0 | | | 721 Bytes | 43dce1e65b2783350565f9e3bead7a13079b50fbd6bd2ae392baa7a58af9e1e7 |
spec/schemas/request/index.rb | 100644 | 0 | 0 | | | 703 Bytes | 820ceba4c3bcc4a56274dab318873aa838371c3410a6bf68277cc540e976d7e9 |
spec/schemas/request/update_request.rb | 100644 | 0 | 0 | | | 769 Bytes | 831dbec81b967f45d88e6ed9a8c79a5ed79a771214c729aa3bc99039d09e794a |
spec/schemas/response/create_topic.rb | 100644 | 0 | 0 | | | 730 Bytes | f436c684f1641008e24af7d7fb6b6e9c1fd31da954e94be00852961971b86e07 |
spec/schemas/response/index.rb | 100644 | 0 | 0 | | | 712 Bytes | 99850930e021e066c7ca421f6d0ca61f425e4eca39a95741ee1b00b131afb189 |
spec/schemas/response/update_response.rb | 100644 | 0 | 0 | | | 781 Bytes | 4be8d0652b141c54b4779c267d7fd4a88e6af0c826c93445e206d6489e7534cd |
spec/snapshots/consumers-no-nest.snap | 100644 | 0 | 0 | | | 29.4 KB | ca33c285daef8be376f30b57fd82b0d7bf052d373f26ab902b2390a375c681a6 |
spec/snapshots/consumers.snap | 100644 | 0 | 0 | | | 29.6 KB | a84d94bfa28468c2e36923beb61511366bb4ac8f29038a6ea630353472a96f88 |
spec/snapshots/consumers_and_producers-no-nest.snap | 100644 | 0 | 0 | | | 30 KB | 49b88b8d055eedda54d68d138e4fed462f91611f749a476d01e2c323fc32b6fc |
spec/snapshots/consumers_and_producers.snap | 100644 | 0 | 0 | | | 30.2 KB | d53d471a30e3f2f8ce795077a316841fcc420f7af11995492cd926951403dbc6 |
spec/snapshots/consumers_circular-no-nest.snap | 100644 | 0 | 0 | | | 29.4 KB | d85e92af9c362b6ebd74865087fe9b0435fe0182a07dbe21d3047e6c443ee9df |
spec/snapshots/consumers_circular.snap | 100644 | 0 | 0 | | | 29.6 KB | d4263800781e02d336f38cd60413a53f4a9a711c9608bf5a1a4f70dbd8d58658 |
spec/snapshots/consumers_complex_types-no-nest.snap | 100644 | 0 | 0 | | | 29.4 KB | b6397b66c2afe53b7e9473c1c7394470e7cd38af51a5cc59732be8fd9df6898a |
spec/snapshots/consumers_complex_types.snap | 100644 | 0 | 0 | | | 29.6 KB | aedd2ae6706f061f7727463c31bf6bb6d218d153e54fad36f2c76de060a39b6e |
spec/snapshots/consumers_nested-no-nest.snap | 100644 | 0 | 0 | | | 29.4 KB | bb7df9cc4b9e22803f7427e6be875529ffd44815d0bd2a8fbc5f8fd4d0df4e3f |
spec/snapshots/consumers_nested.snap | 100644 | 0 | 0 | | | 29.6 KB | 9f22f2aae3cdd101747c92c16b36540e997bf4ed6b082cf75a4204b040491eeb |
spec/snapshots/namespace_folders.snap | 100644 | 0 | 0 | | | 32.4 KB | 7354d4b9ba728cc8e269b32cec50160cfc99359363b0bf87f46fc2ec3db80688 |
spec/snapshots/producers_with_key-no-nest.snap | 100644 | 0 | 0 | | | 29.8 KB | 6bd1d0518dfb438d106558ced3d04fa208b40a60222e56b0e24e216f5420d96c |
spec/snapshots/producers_with_key.snap | 100644 | 0 | 0 | | | 30 KB | 94e83e66c6155c69b295afcf29c1ef2faa9d385cb38ca9944a9aace8d1707ed4 |
spec/spec_helper.rb | 100644 | 0 | 0 | | | 7.25 KB | e74050d320809d84b6633982a4a9480b21713fc8fa9f3de11688d85372812950 |
spec/utils/db_poller_spec.rb | 100644 | 0 | 0 | | | 12.5 KB | 9b82b83bc478fdf9c27ddd62665c7745b2bc9bea275244310d91ec499bdd3687 |
spec/utils/db_producer_spec.rb | 100644 | 0 | 0 | | | 23.1 KB | 3dbbf41e53f15a0d767646ac0873d600f1181e9874962e9afecc8df6ce439cd7 |
spec/utils/deadlock_retry_spec.rb | 100644 | 0 | 0 | | | 2.08 KB | 72bf2b9275c128ec98dcba87255f5eb382562f2344b8c4b91e01cddee592cd68 |
spec/utils/inline_consumer_spec.rb | 100644 | 0 | 0 | | | 1.15 KB | 8c3fcb87912f5627b0c6229334e5b77c59dab8f078bfe1630ed0978628b00732 |
spec/utils/lag_reporter_spec.rb | 100644 | 0 | 0 | | | 2.83 KB | ec82735a14045051e6cb0e1d917ad00db04ec3e21221a63c953a553ff5d316a5 |
spec/utils/platform_schema_validation_spec.rb | 100644 | 0 | 0 | | | 0 Bytes | e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855 |
spec/utils/schema_controller_mixin_spec.rb | 100644 | 0 | 0 | | | 3.35 KB | 36b78539e42313bd5cf20d42a66e6b571360e3130c13c19cfdef2f90cb46d384 |
support/deimos-solo.png | 100644 | 0 | 0 | | | 5.54 KB | b8725b135adf304359a1dffab043e76731a8ca5d90dc1e7c2cb724d3fc55440e |
support/deimos-with-name-next.png | 100644 | 0 | 0 | | | 3.83 KB | df61f8d14d0d791a79c8ae31b9f66624587e37774946447f8361888cf25ee933 |
support/deimos-with-name.png | 100644 | 0 | 0 | | | 5.01 KB | b15aceec18b4ff651ff670dd463876962e197fa1a77ed2dcc05e676da8ac843e |
support/flipp-logo.png | 100644 | 0 | 0 | | | 31.2 KB | 7642e7dcbe060481d57a38e90e8012efc7a85b45e7a9f56addbe0b74c2ea7f77 |