.circleci/config.yml | 100644 | 0 | 0 | | | 1.77 KB | 869b32e9a2e402acc6815bd7343d2ab08dd9e6bafcd6035e7924b3e69a754cee |
.gitignore | 100644 | 0 | 0 | | | 707 Bytes | 23b16af589fd4638fa541b5f94b3e28c71287089369cdc4e02819ae6e1f4fc9f |
.gitmodules | 100644 | 0 | 0 | | | 0 Bytes | e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855 |
.rspec | 100644 | 0 | 0 | | | 89 Bytes | e433ee879fe95cf8100fcdc8d8b991c1f9bfc024ef4c8871f5c4abb49630ac94 |
.rubocop.yml | 100644 | 0 | 0 | | | 5.85 KB | 597b52344743f704b49adba43e35cdb153cf3ee89927c41761b1122160eacfd2 |
.ruby-gemset | 100644 | 0 | 0 | | | 7 Bytes | bfc6a4c370003f58f76b612e67004cf556209579e76f390a71bbd8e8ce3e98ae |
.ruby-version | 100644 | 0 | 0 | | | 6 Bytes | 99600f6a7bfe6c33ebd1a2518f44a861a67afc40c25da42bc622595716529584 |
CHANGELOG.md | 100644 | 0 | 0 | | | 2.84 KB | ac26feee02c96c4c82378801178688763f564539a44419c9e89d3fab14b6ffd4 |
CODE_OF_CONDUCT.md | 100644 | 0 | 0 | | | 3.29 KB | d67a1d40477ef0d2c60df0284350e6edfa349a60cc984a3ab7410a9a2e27c4a1 |
Dockerfile | 100644 | 0 | 0 | | | 788 Bytes | 10183acc12ab89e1981c6316fc6a4a398bf0fec4e7e0b75196e08eda13ae8e55 |
Gemfile | 100644 | 0 | 0 | | | 127 Bytes | 64e668a1976895a68b46579849a65d9c998959a350606d3597829a971bcb3143 |
Gemfile.lock | 100644 | 0 | 0 | | | 3.73 KB | 82ee764c261ebfca13b495f5554d248ae8822d25c92fdfaa194bc695ad6efc3b |
Guardfile | 100644 | 0 | 0 | | | 887 Bytes | 50e6482eca3db70546dd580a4d0b1c82172bef9e4bb28f4b7f064561c6eaffe3 |
LICENSE.md | 100644 | 0 | 0 | | | 10.2 KB | ec640150e03774d1b5264fb268f3829dc36745551109131ebf6dd0a59d5ec3eb |
README.md | 100644 | 0 | 0 | | | 30.4 KB | 30afc9fbf5ba6fe79bfa9b53566140c1fc2bbe76a464664be3c07102feee2361 |
Rakefile | 100644 | 0 | 0 | | | 276 Bytes | aeff547fd8d9cd7d8c1623ce9f05d1facf068b9e9f52849befc5e867b001094d |
bin/deimos | 100755 | 0 | 0 | | | 68 Bytes | 65500583cc0f73ab9cc1620ce10fdf916bcbe9027e2da75a9b782d63bbdd07dc |
deimos-ruby.gemspec | 100644 | 0 | 0 | | | 1.8 KB | 8fa6d772bd60b2b92098c56a045d783edda5fbf540746e7e6aa153e7456e89a7 |
docker-compose.yml | 100644 | 0 | 0 | | | 1.84 KB | 104e5a8f481232ea0d4b7816b66c112924b003a0b9a5f848faf51cff99d9e500 |
docs/DATABASE_BACKEND.md | 100644 | 0 | 0 | | | 8.02 KB | 92dc39c2a9e1afa5fe4565490ae26b3467c3e1902c20d61a610ee433ba8bdcaa |
docs/PULL_REQUEST_TEMPLATE.md | 100644 | 0 | 0 | | | 1.3 KB | 667fe167520567ceef441d2b98badefcb88013e2cdcc5f617c380180894f9a61 |
lib/deimos.rb | 100644 | 0 | 0 | | | 5.04 KB | fd08bc4a067568f34ef0e8805058b85fe7ae43f034a09ab03a907105900bbb5c |
lib/deimos/active_record_consumer.rb | 100644 | 0 | 0 | | | 3.18 KB | 18a8592ccf038c5e67e4f3c6fbf388ff68211d06765a839dd897915fb930427f |
lib/deimos/active_record_producer.rb | 100644 | 0 | 0 | | | 2.35 KB | 1202fd7aad21962eb689b8f6b38f03a44e9818981db54b763cf0be61cff294c1 |
lib/deimos/avro_data_coder.rb | 100644 | 0 | 0 | | | 2.47 KB | bd09fca79ed3dd891fe81db31228909d8a9184b53967160babb048a2c116f947 |
lib/deimos/avro_data_decoder.rb | 100644 | 0 | 0 | | | 1.04 KB | d62dd14aec1d78f6dc47d40d71d60b3eba26c02d6599e09f817c2b11c9cc4d95 |
lib/deimos/avro_data_encoder.rb | 100644 | 0 | 0 | | | 1.8 KB | d8dd73083a0b90a5ac08a7743413df23efa282a3145378a8b98a57bc3f90de92 |
lib/deimos/backends/db.rb | 100644 | 0 | 0 | | | 781 Bytes | 9579792c4015dc3e7e7714e853f418b15af79b795180848df7ab865fdc61ebe1 |
lib/deimos/backends/kafka.rb | 100644 | 0 | 0 | | | 920 Bytes | 9a704728f261df865f8af7fa34fdb28cefb8fd4858a04fda65cf3f6627c8e102 |
lib/deimos/backends/kafka_async.rb | 100644 | 0 | 0 | | | 896 Bytes | eca29d982fd8b1ba45e01bc601b8f239b5400259fc6e5769d1d6f6593c7c9cc1 |
lib/deimos/base_consumer.rb | 100644 | 0 | 0 | | | 3.04 KB | bd0045ffe71f18bdc7d19a010f8ebc5dec0f94bb7ca1dc060104405fec5efaae |
lib/deimos/batch_consumer.rb | 100644 | 0 | 0 | | | 4.36 KB | 008d7fbddd824b5ec05a4c30013e53eb8088dbe5e2c6e130be8dce031e614a10 |
lib/deimos/configuration.rb | 100644 | 0 | 0 | | | 3.52 KB | 7e70ef44cfe8ff5f7ad1c384ff10f78afcc34f14fd9c5b3e69ab275da350e416 |
lib/deimos/consumer.rb | 100644 | 0 | 0 | | | 2.98 KB | 7391c76f5b1394a9cf36fffaeb0af8676c47ab1c136553c77bce5c08f1d3317a |
lib/deimos/instrumentation.rb | 100644 | 0 | 0 | | | 2.04 KB | 2fb780e6cef6bea8d7b3fbe8c14d23a100a33e5217c9b70212944f82b12a8163 |
lib/deimos/kafka_message.rb | 100644 | 0 | 0 | | | 1.44 KB | fc97c2c049c08944fd1bbb510df04450703088bac99a36873997bec4d712e43a |
lib/deimos/kafka_source.rb | 100644 | 0 | 0 | | | 4.11 KB | 8bb219aec0d7046c6529a248e6ea9d1945054dcc6cc193e7dbaae1a21434363e |
lib/deimos/kafka_topic_info.rb | 100644 | 0 | 0 | | | 3.39 KB | e27cdaa71644962741e48a49b509a6603586b0ea7389e89024812903a207a362 |
lib/deimos/message.rb | 100644 | 0 | 0 | | | 1.89 KB | e5680b894afb8ba06ca5894508796acd8c62e4a09f1ea0a9241c1b2c01bc8db2 |
lib/deimos/metrics/datadog.rb | 100644 | 0 | 0 | | | 1.25 KB | ea2cb17701d454bb44a7961f971ac1f9da53b084fdc09817a355350c2e865de9 |
lib/deimos/metrics/mock.rb | 100644 | 0 | 0 | | | 1.06 KB | cb520e132adfedc80eb8b6f1b7a4bdc384815022cbde7bf81e7e36fac2489355 |
lib/deimos/metrics/provider.rb | 100644 | 0 | 0 | | | 1.26 KB | 04b18e3f17e03282850dd1fc113c40dd7475b2f5aa5a1e85d5b2816771a48021 |
lib/deimos/monkey_patches/phobos_cli.rb | 100644 | 0 | 0 | | | 955 Bytes | 8a782ad3f105c1f895627035a19369b00f2d1f5b33ed396c59a45fadbea8ee1e |
lib/deimos/monkey_patches/phobos_producer.rb | 100644 | 0 | 0 | | | 1.41 KB | 94002ed64f6a3ba4c35a10190f914134c5da11b9350f4a27ac5e3c7b969aadcf |
lib/deimos/monkey_patches/ruby_kafka_heartbeat.rb | 100644 | 0 | 0 | | | 2.31 KB | 99885eac81489c13b3e41d766d97cc34dcf65bea189bbec382fe69bdd5b8416a |
lib/deimos/monkey_patches/schema_store.rb | 100644 | 0 | 0 | | | 520 Bytes | 40e7ce3c4fd99fa9f5d78ac138393e7694920943ac57b0576f18a3aa93ff52a4 |
lib/deimos/producer.rb | 100644 | 0 | 0 | | | 7.33 KB | 0cf3a53fbbc5ce23f70e17cd211db90acc4fb1d4441227f7d8e70966828ea32b |
lib/deimos/publish_backend.rb | 100644 | 0 | 0 | | | 861 Bytes | d02923ce80b78a540295216952a3340e85f2ce843374a376eaba5008b3ba6ab9 |
lib/deimos/railtie.rb | 100644 | 0 | 0 | | | 151 Bytes | f96918432df8a010ab107e7f0609c044f40225d26c81821c32a88a8bb605077a |
lib/deimos/schema_coercer.rb | 100644 | 0 | 0 | | | 2.36 KB | 0356f42eae83d4ecf8afae1c8ec05978778debc06ded955f231eb031d4768d58 |
lib/deimos/shared_config.rb | 100644 | 0 | 0 | | | 1.85 KB | 88a4886bc6adbd16212834350e33d5bf886d8e35dae9dc37f0d5ad2385ec32fa |
lib/deimos/test_helpers.rb | 100644 | 0 | 0 | | | 17.3 KB | 4e89089085f57ba96c6af092502c9071073da0398a71722079d8a61059d6ddda |
lib/deimos/tracing/datadog.rb | 100644 | 0 | 0 | | | 749 Bytes | 14346e8619416f6dae3aeb7318479688f5b540058917607aceae7b9d3db9a05f |
lib/deimos/tracing/mock.rb | 100644 | 0 | 0 | | | 985 Bytes | ebbf00675312982f7cc1075ff52e1337925e78fbeb493c6bd34fb7b588ba9023 |
lib/deimos/tracing/provider.rb | 100644 | 0 | 0 | | | 925 Bytes | 576d57f082c0d78fc79ad37e5cffd533abd3b70d8613ce200c57d30d46a9903c |
lib/deimos/utils/db_producer.rb | 100644 | 0 | 0 | | | 6.2 KB | f083de29a2bb2b388e474d6af4c72839242a5301b7cfcd8f075ae5e4f9905867 |
lib/deimos/utils/executor.rb | 100644 | 0 | 0 | | | 3.47 KB | ef81f1a7642244f0ea7e08e9d11100dbeaa95d5410989265d6c3a6f774aa13b9 |
lib/deimos/utils/inline_consumer.rb | 100644 | 0 | 0 | | | 4.93 KB | 55d45342bced1e75d2a76b27e7284e040fcd967268271c86143a61ceb280ef29 |
lib/deimos/utils/lag_reporter.rb | 100644 | 0 | 0 | | | 5.64 KB | 54732b882557db5e97eecab05a188bec4d4fee8a363409baa0812fc3688389fc |
lib/deimos/utils/platform_schema_validation.rb | 100644 | 0 | 0 | | | 0 Bytes | e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855 |
lib/deimos/utils/signal_handler.rb | 100644 | 0 | 0 | | | 1.79 KB | ebc5dccfcd87214a02646b8c8aedf0987e63fef81a5bcf1f2b591670bdb550ff |
lib/deimos/version.rb | 100644 | 0 | 0 | | | 75 Bytes | d3c18a199441e2f6c9d0efbe5eab7a2c2763d074a9f66a4e4a4256a11c4a0e80 |
lib/generators/deimos/db_backend/templates/migration | 100644 | 0 | 0 | | | 820 Bytes | 7746b9f2bd1c26c8f1af72e031c1e6c930b0d87dff4306d30b5c9bc812e97b92 |
lib/generators/deimos/db_backend/templates/rails3_migration | 100644 | 0 | 0 | | | 909 Bytes | 37f2fae2aa2a179791de7a1c7fed02397ae3695755151a076f3cf24189e05382 |
lib/generators/deimos/db_backend_generator.rb | 100644 | 0 | 0 | | | 1.39 KB | 518ab8e79f044aee0cb8dcf60b48e799b48518889b3fcfb48fdc7045dc86e537 |
lib/tasks/deimos.rake | 100644 | 0 | 0 | | | 829 Bytes | 9e3d9671ce5a32c2eda492bdb882f6e4a39824ce0005c026ec140b7b5af09901 |
spec/active_record_consumer_spec.rb | 100644 | 0 | 0 | | | 3.85 KB | 2f4c4f5f5693e76e1552ff312861b3db89e1ffc8a88d5c6b171a4cc7799de2e0 |
spec/active_record_producer_spec.rb | 100644 | 0 | 0 | | | 3.25 KB | 5a48fbc5bfe7c5c1f0181283e99485a61ecf34a3efc3d9134711b68d90cd6a33 |
spec/avro_data_decoder_spec.rb | 100644 | 0 | 0 | | | 503 Bytes | 64c529c0c186ab125dd0b486c840ebf028e092e3850f99992158e6a05b109264 |
spec/avro_data_encoder_spec.rb | 100644 | 0 | 0 | | | 997 Bytes | 338c03c6cc17af96239d5f53786bc369ee5d5d38290f8e47c88ec8f1edf47c8e |
spec/backends/db_spec.rb | 100644 | 0 | 0 | | | 1.36 KB | 0439242f4377124493a6cdc95ba489128641cfb02591a83e9e7dc5332600f0c5 |
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 | | | 7.47 KB | ce0b381750b70da7e5e8d5333710279c703b5375399ba258811d6af1f071f905 |
spec/consumer_spec.rb | 100644 | 0 | 0 | | | 6.53 KB | fa9a3b79585678299cc855262fef1b8d761e6b8277dd8126b3f74dbe4599509f |
spec/deimos_spec.rb | 100644 | 0 | 0 | | | 7 KB | bc218272e1fae05f0f3fe3ab1279966515a906b82ef02a6ebc397af36ea3f643 |
spec/handlers/my_batch_consumer.rb | 100644 | 0 | 0 | | | 108 Bytes | 43e93d88cb45e795e6749f3e569f3d63dd8cb437709421e173b4dc0616867a12 |
spec/handlers/my_consumer.rb | 100644 | 0 | 0 | | | 98 Bytes | cce5fb3708803c9592d52befa6fb2c70bb39b52738bdd6712704538d5714242b |
spec/kafka_source_spec.rb | 100644 | 0 | 0 | | | 6.39 KB | 720c1ba4635ad100086a6d42f9583a2f2b2796149db38a10125c710a0aaf43b0 |
spec/kafka_topic_info_spec.rb | 100644 | 0 | 0 | | | 3.36 KB | a66de45aa2ea3cae131f9b83013298367db04270019b9e492d399444e1a54be6 |
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 | | | 14.7 KB | e0d80dece50181e575baaee5f056b6a6a1e5649d26009a99c271d2924254301f |
spec/publish_backend_spec.rb | 100644 | 0 | 0 | | | 338 Bytes | d58a07f930634aa21ba7fd71739e83336359a549367d386c5af26b1f7f3a5f47 |
spec/schemas/com/my-namespace/MySchema-key.avsc | 100644 | 0 | 0 | | | 215 Bytes | f8424d631ebb3e09098f38aa0c50417feef45866b33c167361ca34211169a381 |
spec/schemas/com/my-namespace/MySchema.avsc | 100644 | 0 | 0 | | | 295 Bytes | 6bdef945cff2737a248f5e28f852e770f271dfc1915e792110c762bce1fc6054 |
spec/schemas/com/my-namespace/MySchemaWithBooleans.avsc | 100644 | 0 | 0 | | | 313 Bytes | 484530c3cbef46b7eb1887c0c3ab2649363124c91388f78aefa6e1ddc5d870fc |
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/Widget.avsc | 100644 | 0 | 0 | | | 393 Bytes | 6139b39887c289d7b87bc3bf3a3517ca8af0fb1f790b67587c6f7e8d7ce826be |
spec/schemas/com/my-namespace/WidgetTheSecond.avsc | 100644 | 0 | 0 | | | 406 Bytes | 3c6844eb94d45f4b91a48280ed4937cae655be1c3e1be700a176fcf906fea51d |
spec/spec_helper.rb | 100644 | 0 | 0 | | | 5.71 KB | 9fe8338123ceab966bf747d8bcbffcada27293635a309437c41390136a69c450 |
spec/updateable_schema_store_spec.rb | 100644 | 0 | 0 | | | 1.28 KB | bbc6eba28b2bd4845b9793c2010b30b1042a51fc27f8aa73ceb3a3f19607f46e |
spec/utils/db_producer_spec.rb | 100644 | 0 | 0 | | | 17.6 KB | 1139dae5fa44b081f4329d11524aed907829661671cd83da3c570b0c7fc81263 |
spec/utils/executor_spec.rb | 100644 | 0 | 0 | | | 1.51 KB | f806ddbc499a5b2ade5d377b42e8fa55e862fed79452756d499e78dbc36d7cd5 |
spec/utils/lag_reporter_spec.rb | 100644 | 0 | 0 | | | 2.14 KB | dea75382478fba1a8c4f57bc2fb02f7b8e44075785f259ea5cfc6f18aa687538 |
spec/utils/platform_schema_validation_spec.rb | 100644 | 0 | 0 | | | 0 Bytes | e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855 |
spec/utils/signal_handler_spec.rb | 100644 | 0 | 0 | | | 427 Bytes | 69568cf03c1875ea87167252083fe58b6ce06504e3d550de0ba735148ef8f81e |
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 |