--- !ruby/object:Gem::Specification name: deimos-ruby version: !ruby/object:Gem::Version version: 1.24.0 platform: ruby authors: - Daniel Orner autorequire: bindir: bin cert_chain: [] date: 2024-02-26 00:00:00.000000000 Z dependencies: - !ruby/object:Gem::Dependency name: avro_turf requirement: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: '1.4' - - "<" - !ruby/object:Gem::Version version: '2' type: :runtime prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: '1.4' - - "<" - !ruby/object:Gem::Version version: '2' - !ruby/object:Gem::Dependency name: fig_tree requirement: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: 0.0.2 type: :runtime prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: 0.0.2 - !ruby/object:Gem::Dependency name: phobos requirement: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: '1.9' - - "<" - !ruby/object:Gem::Version version: '3.0' type: :runtime prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: '1.9' - - "<" - !ruby/object:Gem::Version version: '3.0' - !ruby/object:Gem::Dependency name: ruby-kafka requirement: !ruby/object:Gem::Requirement requirements: - - "<" - !ruby/object:Gem::Version version: '2' type: :runtime prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - "<" - !ruby/object:Gem::Version version: '2' - !ruby/object:Gem::Dependency name: sigurd requirement: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: 0.1.0 - - "<" - !ruby/object:Gem::Version version: '1.0' type: :runtime prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: 0.1.0 - - "<" - !ruby/object:Gem::Version version: '1.0' - !ruby/object:Gem::Dependency name: activerecord-import requirement: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: '0' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: '0' - !ruby/object:Gem::Dependency name: avro requirement: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '1.9' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '1.9' - !ruby/object:Gem::Dependency name: database_cleaner requirement: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '1.7' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '1.7' - !ruby/object:Gem::Dependency name: ddtrace requirement: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: '0.11' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: '0.11' - !ruby/object:Gem::Dependency name: dogstatsd-ruby requirement: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: '4.2' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: '4.2' - !ruby/object:Gem::Dependency name: guard requirement: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '2' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '2' - !ruby/object:Gem::Dependency name: guard-rspec requirement: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '4' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '4' - !ruby/object:Gem::Dependency name: guard-rubocop requirement: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '1' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '1' - !ruby/object:Gem::Dependency name: mysql2 requirement: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '0.5' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '0.5' - !ruby/object:Gem::Dependency name: pg requirement: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '1.1' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '1.1' - !ruby/object:Gem::Dependency name: rails requirement: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '6' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '6' - !ruby/object:Gem::Dependency name: rake requirement: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '13' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '13' - !ruby/object:Gem::Dependency name: rspec requirement: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '3' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '3' - !ruby/object:Gem::Dependency name: rspec_junit_formatter requirement: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '0.3' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '0.3' - !ruby/object:Gem::Dependency name: rspec-rails requirement: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '4' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '4' - !ruby/object:Gem::Dependency name: rspec-snapshot requirement: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '2.0' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '2.0' - !ruby/object:Gem::Dependency name: rubocop requirement: !ruby/object:Gem::Requirement requirements: - - '=' - !ruby/object:Gem::Version version: 0.89.0 type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - '=' - !ruby/object:Gem::Version version: 0.89.0 - !ruby/object:Gem::Dependency name: rubocop-rspec requirement: !ruby/object:Gem::Requirement requirements: - - '=' - !ruby/object:Gem::Version version: 1.42.0 type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - '=' - !ruby/object:Gem::Version version: 1.42.0 - !ruby/object:Gem::Dependency name: sord requirement: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: '5.0' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: '5.0' - !ruby/object:Gem::Dependency name: sqlite3 requirement: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '1.3' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '1.3' - !ruby/object:Gem::Dependency name: steep requirement: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '1.0' type: :development prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '1.0' description: email: - daniel.orner@wishabi.com executables: - console - deimos extensions: [] extra_rdoc_files: [] files: - ".circleci/config.yml" - ".github/workflows/ci.yml" - ".gitignore" - ".gitmodules" - ".rspec" - ".rubocop.yml" - ".rubocop_todo.yml" - ".ruby-version" - CHANGELOG.md - CODE_OF_CONDUCT.md - Dockerfile - Gemfile - Guardfile - LICENSE.md - README.md - Rakefile - Steepfile - bin/console - bin/deimos - deimos-ruby.gemspec - docker-compose.yml - docs/ARCHITECTURE.md - docs/CONFIGURATION.md - docs/DATABASE_BACKEND.md - docs/INTEGRATION_TESTS.md - docs/PULL_REQUEST_TEMPLATE.md - docs/UPGRADING.md - lib/deimos.rb - lib/deimos/active_record_consume/batch_consumption.rb - lib/deimos/active_record_consume/batch_record.rb - lib/deimos/active_record_consume/batch_record_list.rb - lib/deimos/active_record_consume/batch_slicer.rb - lib/deimos/active_record_consume/mass_updater.rb - lib/deimos/active_record_consume/message_consumption.rb - lib/deimos/active_record_consume/schema_model_converter.rb - lib/deimos/active_record_consumer.rb - lib/deimos/active_record_producer.rb - lib/deimos/backends/base.rb - lib/deimos/backends/db.rb - lib/deimos/backends/kafka.rb - lib/deimos/backends/kafka_async.rb - lib/deimos/backends/test.rb - lib/deimos/batch_consumer.rb - lib/deimos/config/configuration.rb - lib/deimos/config/phobos_config.rb - lib/deimos/consume/batch_consumption.rb - lib/deimos/consume/message_consumption.rb - lib/deimos/consumer.rb - lib/deimos/exceptions.rb - lib/deimos/instrumentation.rb - lib/deimos/kafka_message.rb - lib/deimos/kafka_source.rb - lib/deimos/kafka_topic_info.rb - lib/deimos/message.rb - lib/deimos/metrics/datadog.rb - lib/deimos/metrics/mock.rb - lib/deimos/metrics/provider.rb - lib/deimos/monkey_patches/phobos_cli.rb - lib/deimos/poll_info.rb - lib/deimos/producer.rb - lib/deimos/railtie.rb - lib/deimos/schema_backends/avro_base.rb - lib/deimos/schema_backends/avro_local.rb - lib/deimos/schema_backends/avro_schema_coercer.rb - lib/deimos/schema_backends/avro_schema_registry.rb - lib/deimos/schema_backends/avro_validation.rb - lib/deimos/schema_backends/base.rb - lib/deimos/schema_backends/mock.rb - lib/deimos/schema_class/base.rb - lib/deimos/schema_class/enum.rb - lib/deimos/schema_class/record.rb - lib/deimos/shared_config.rb - lib/deimos/test_helpers.rb - lib/deimos/tracing/datadog.rb - lib/deimos/tracing/mock.rb - lib/deimos/tracing/provider.rb - lib/deimos/utils/db_poller.rb - lib/deimos/utils/db_poller/base.rb - lib/deimos/utils/db_poller/state_based.rb - lib/deimos/utils/db_poller/time_based.rb - lib/deimos/utils/db_producer.rb - lib/deimos/utils/deadlock_retry.rb - lib/deimos/utils/inline_consumer.rb - lib/deimos/utils/lag_reporter.rb - lib/deimos/utils/schema_class.rb - lib/deimos/utils/schema_controller_mixin.rb - lib/deimos/version.rb - lib/generators/deimos/active_record/templates/migration.rb.tt - lib/generators/deimos/active_record/templates/model.rb.tt - lib/generators/deimos/active_record_generator.rb - lib/generators/deimos/bulk_import_id/templates/migration.rb.tt - lib/generators/deimos/bulk_import_id_generator.rb - lib/generators/deimos/db_backend/templates/migration - lib/generators/deimos/db_backend/templates/rails3_migration - lib/generators/deimos/db_backend_generator.rb - lib/generators/deimos/db_poller/templates/migration - lib/generators/deimos/db_poller/templates/rails3_migration - lib/generators/deimos/db_poller_generator.rb - lib/generators/deimos/schema_class/templates/schema_class.rb.tt - lib/generators/deimos/schema_class/templates/schema_enum.rb.tt - lib/generators/deimos/schema_class/templates/schema_record.rb.tt - lib/generators/deimos/schema_class_generator.rb - lib/tasks/deimos.rake - rbs_collection.lock.yaml - rbs_collection.yaml - regenerate_test_schema_classes.rb - sig/avro.rbs - sig/defs.rbs - sig/fig_tree.rbs - spec/active_record_batch_consumer_association_spec.rb - spec/active_record_batch_consumer_spec.rb - spec/active_record_consume/batch_consumption_spec.rb - spec/active_record_consume/batch_slicer_spec.rb - spec/active_record_consume/mass_updater_spec.rb - spec/active_record_consume/schema_model_converter_spec.rb - spec/active_record_consumer_spec.rb - spec/active_record_producer_spec.rb - spec/backends/base_spec.rb - spec/backends/db_spec.rb - spec/backends/kafka_async_spec.rb - spec/backends/kafka_spec.rb - spec/batch_consumer_spec.rb - spec/config/configuration_spec.rb - spec/consumer_spec.rb - spec/deimos_spec.rb - spec/generators/active_record_generator_spec.rb - spec/generators/schema_class/my_schema_spec.rb - spec/generators/schema_class/my_schema_with_circular_reference_spec.rb - spec/generators/schema_class/my_schema_with_complex_types_spec.rb - spec/generators/schema_class_generator_spec.rb - spec/handlers/my_batch_consumer.rb - spec/handlers/my_consumer.rb - spec/kafka_listener_spec.rb - spec/kafka_source_spec.rb - spec/kafka_topic_info_spec.rb - spec/message_spec.rb - spec/phobos.bad_db.yml - spec/phobos.yml - spec/producer_spec.rb - spec/rake_spec.rb - spec/schema_backends/avro_base_shared.rb - spec/schema_backends/avro_local_spec.rb - spec/schema_backends/avro_schema_registry_spec.rb - spec/schema_backends/avro_validation_spec.rb - spec/schema_backends/base_spec.rb - spec/schemas/com/my-namespace/Generated.avsc - spec/schemas/com/my-namespace/MyNestedSchema.avsc - spec/schemas/com/my-namespace/MySchema.avsc - spec/schemas/com/my-namespace/MySchemaCompound_key.avsc - spec/schemas/com/my-namespace/MySchemaId_key.avsc - spec/schemas/com/my-namespace/MySchemaWithBooleans.avsc - spec/schemas/com/my-namespace/MySchemaWithCircularReference.avsc - spec/schemas/com/my-namespace/MySchemaWithComplexTypes.avsc - spec/schemas/com/my-namespace/MySchemaWithDateTimes.avsc - spec/schemas/com/my-namespace/MySchemaWithId.avsc - spec/schemas/com/my-namespace/MySchemaWithUniqueId.avsc - spec/schemas/com/my-namespace/MySchema_key.avsc - spec/schemas/com/my-namespace/Wibble.avsc - spec/schemas/com/my-namespace/Widget.avsc - spec/schemas/com/my-namespace/WidgetTheSecond.avsc - spec/schemas/com/my-namespace/my-suborg/MyLongNamespaceSchema.avsc - spec/schemas/com/my-namespace/request/CreateTopic.avsc - spec/schemas/com/my-namespace/request/Index.avsc - spec/schemas/com/my-namespace/request/UpdateRequest.avsc - spec/schemas/com/my-namespace/response/CreateTopic.avsc - spec/schemas/com/my-namespace/response/Index.avsc - spec/schemas/com/my-namespace/response/UpdateResponse.avsc - spec/schemas/my_namespace/generated.rb - spec/schemas/my_namespace/my_long_namespace_schema.rb - spec/schemas/my_namespace/my_nested_schema.rb - spec/schemas/my_namespace/my_schema.rb - spec/schemas/my_namespace/my_schema_compound_key.rb - spec/schemas/my_namespace/my_schema_id_key.rb - spec/schemas/my_namespace/my_schema_key.rb - spec/schemas/my_namespace/my_schema_with_boolean.rb - spec/schemas/my_namespace/my_schema_with_circular_reference.rb - spec/schemas/my_namespace/my_schema_with_complex_type.rb - spec/schemas/my_namespace/my_schema_with_date_time.rb - spec/schemas/my_namespace/my_schema_with_id.rb - spec/schemas/my_namespace/my_schema_with_unique_id.rb - spec/schemas/my_namespace/my_updated_schema.rb - spec/schemas/my_namespace/request/create_topic.rb - spec/schemas/my_namespace/request/index.rb - spec/schemas/my_namespace/request/update_request.rb - spec/schemas/my_namespace/response/create_topic.rb - spec/schemas/my_namespace/response/index.rb - spec/schemas/my_namespace/response/update_response.rb - spec/schemas/my_namespace/wibble.rb - spec/schemas/my_namespace/widget.rb - spec/schemas/my_namespace/widget_the_second.rb - spec/snapshots/consumers-no-nest.snap - spec/snapshots/consumers.snap - spec/snapshots/consumers_and_producers-no-nest.snap - spec/snapshots/consumers_and_producers.snap - spec/snapshots/consumers_circular-no-nest.snap - spec/snapshots/consumers_circular.snap - spec/snapshots/consumers_complex_types-no-nest.snap - spec/snapshots/consumers_complex_types.snap - spec/snapshots/consumers_nested-no-nest.snap - spec/snapshots/consumers_nested.snap - spec/snapshots/namespace_folders.snap - spec/snapshots/namespace_map.snap - spec/snapshots/producers_with_key-no-nest.snap - spec/snapshots/producers_with_key.snap - spec/spec_helper.rb - spec/utils/db_poller_spec.rb - spec/utils/db_producer_spec.rb - spec/utils/deadlock_retry_spec.rb - spec/utils/inline_consumer_spec.rb - spec/utils/lag_reporter_spec.rb - spec/utils/platform_schema_validation_spec.rb - spec/utils/schema_controller_mixin_spec.rb - support/deimos-solo.png - support/deimos-with-name-next.png - support/deimos-with-name.png - support/flipp-logo.png homepage: '' licenses: - Apache-2.0 metadata: {} post_install_message: rdoc_options: [] require_paths: - lib required_ruby_version: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: '0' required_rubygems_version: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: '0' requirements: [] rubygems_version: 3.1.2 signing_key: specification_version: 4 summary: Kafka libraries for Ruby. test_files: - spec/active_record_batch_consumer_association_spec.rb - spec/active_record_batch_consumer_spec.rb - spec/active_record_consume/batch_consumption_spec.rb - spec/active_record_consume/batch_slicer_spec.rb - spec/active_record_consume/mass_updater_spec.rb - spec/active_record_consume/schema_model_converter_spec.rb - spec/active_record_consumer_spec.rb - spec/active_record_producer_spec.rb - spec/backends/base_spec.rb - spec/backends/db_spec.rb - spec/backends/kafka_async_spec.rb - spec/backends/kafka_spec.rb - spec/batch_consumer_spec.rb - spec/config/configuration_spec.rb - spec/consumer_spec.rb - spec/deimos_spec.rb - spec/generators/active_record_generator_spec.rb - spec/generators/schema_class/my_schema_spec.rb - spec/generators/schema_class/my_schema_with_circular_reference_spec.rb - spec/generators/schema_class/my_schema_with_complex_types_spec.rb - spec/generators/schema_class_generator_spec.rb - spec/handlers/my_batch_consumer.rb - spec/handlers/my_consumer.rb - spec/kafka_listener_spec.rb - spec/kafka_source_spec.rb - spec/kafka_topic_info_spec.rb - spec/message_spec.rb - spec/phobos.bad_db.yml - spec/phobos.yml - spec/producer_spec.rb - spec/rake_spec.rb - spec/schema_backends/avro_base_shared.rb - spec/schema_backends/avro_local_spec.rb - spec/schema_backends/avro_schema_registry_spec.rb - spec/schema_backends/avro_validation_spec.rb - spec/schema_backends/base_spec.rb - spec/schemas/com/my-namespace/Generated.avsc - spec/schemas/com/my-namespace/MyNestedSchema.avsc - spec/schemas/com/my-namespace/MySchema.avsc - spec/schemas/com/my-namespace/MySchemaCompound_key.avsc - spec/schemas/com/my-namespace/MySchemaId_key.avsc - spec/schemas/com/my-namespace/MySchemaWithBooleans.avsc - spec/schemas/com/my-namespace/MySchemaWithCircularReference.avsc - spec/schemas/com/my-namespace/MySchemaWithComplexTypes.avsc - spec/schemas/com/my-namespace/MySchemaWithDateTimes.avsc - spec/schemas/com/my-namespace/MySchemaWithId.avsc - spec/schemas/com/my-namespace/MySchemaWithUniqueId.avsc - spec/schemas/com/my-namespace/MySchema_key.avsc - spec/schemas/com/my-namespace/Wibble.avsc - spec/schemas/com/my-namespace/Widget.avsc - spec/schemas/com/my-namespace/WidgetTheSecond.avsc - spec/schemas/com/my-namespace/my-suborg/MyLongNamespaceSchema.avsc - spec/schemas/com/my-namespace/request/CreateTopic.avsc - spec/schemas/com/my-namespace/request/Index.avsc - spec/schemas/com/my-namespace/request/UpdateRequest.avsc - spec/schemas/com/my-namespace/response/CreateTopic.avsc - spec/schemas/com/my-namespace/response/Index.avsc - spec/schemas/com/my-namespace/response/UpdateResponse.avsc - spec/schemas/my_namespace/generated.rb - spec/schemas/my_namespace/my_long_namespace_schema.rb - spec/schemas/my_namespace/my_nested_schema.rb - spec/schemas/my_namespace/my_schema.rb - spec/schemas/my_namespace/my_schema_compound_key.rb - spec/schemas/my_namespace/my_schema_id_key.rb - spec/schemas/my_namespace/my_schema_key.rb - spec/schemas/my_namespace/my_schema_with_boolean.rb - spec/schemas/my_namespace/my_schema_with_circular_reference.rb - spec/schemas/my_namespace/my_schema_with_complex_type.rb - spec/schemas/my_namespace/my_schema_with_date_time.rb - spec/schemas/my_namespace/my_schema_with_id.rb - spec/schemas/my_namespace/my_schema_with_unique_id.rb - spec/schemas/my_namespace/my_updated_schema.rb - spec/schemas/my_namespace/request/create_topic.rb - spec/schemas/my_namespace/request/index.rb - spec/schemas/my_namespace/request/update_request.rb - spec/schemas/my_namespace/response/create_topic.rb - spec/schemas/my_namespace/response/index.rb - spec/schemas/my_namespace/response/update_response.rb - spec/schemas/my_namespace/wibble.rb - spec/schemas/my_namespace/widget.rb - spec/schemas/my_namespace/widget_the_second.rb - spec/snapshots/consumers-no-nest.snap - spec/snapshots/consumers.snap - spec/snapshots/consumers_and_producers-no-nest.snap - spec/snapshots/consumers_and_producers.snap - spec/snapshots/consumers_circular-no-nest.snap - spec/snapshots/consumers_circular.snap - spec/snapshots/consumers_complex_types-no-nest.snap - spec/snapshots/consumers_complex_types.snap - spec/snapshots/consumers_nested-no-nest.snap - spec/snapshots/consumers_nested.snap - spec/snapshots/namespace_folders.snap - spec/snapshots/namespace_map.snap - spec/snapshots/producers_with_key-no-nest.snap - spec/snapshots/producers_with_key.snap - spec/spec_helper.rb - spec/utils/db_poller_spec.rb - spec/utils/db_producer_spec.rb - spec/utils/deadlock_retry_spec.rb - spec/utils/inline_consumer_spec.rb - spec/utils/lag_reporter_spec.rb - spec/utils/platform_schema_validation_spec.rb - spec/utils/schema_controller_mixin_spec.rb