Table of Contents - deimos-ruby-1.11.2 Documentation
Pages
Classes and Modules
- Deimos
- Deimos::ActiveRecordConsume
- Deimos::ActiveRecordConsume::BatchConsumption
- Deimos::ActiveRecordConsume::BatchSlicer
- Deimos::ActiveRecordConsume::MessageConsumption
- Deimos::ActiveRecordConsume::SchemaModelConverter
- Deimos::ActiveRecordConsumer
- Deimos::ActiveRecordProducer
- Deimos::AvroSchemaCoercer
- Deimos::Backends
- Deimos::Backends::Base
- Deimos::Backends::Db
- Deimos::Backends::Kafka
- Deimos::Backends::KafkaAsync
- Deimos::Backends::Test
- Deimos::BatchConsumer
- Deimos::Consume
- Deimos::Consume::BatchConsumption
- Deimos::Consume::MessageConsumption
- Deimos::Consumer
- Deimos::FigTree
- Deimos::FigTree::ConfigStruct
- Deimos::Generators
- Deimos::Generators::ActiveRecordGenerator
- Deimos::Generators::DbBackendGenerator
- Deimos::Generators::DbPollerGenerator
- Deimos::Instrumentation
- Deimos::Instrumentation::ClassMethods
- Deimos::KafkaListener
- Deimos::KafkaMessage
- Deimos::KafkaSource
- Deimos::KafkaSource::ClassMethods
- Deimos::KafkaTopicInfo
- Deimos::Message
- Deimos::Metrics
- Deimos::Metrics::Datadog
- Deimos::Metrics::Mock
- Deimos::Metrics::Provider
- Deimos::PhobosConfig
- Deimos::PollInfo
- Deimos::Producer
- Deimos::Railtie
- Deimos::SchemaBackends
- Deimos::SchemaBackends::AvroBase
- Deimos::SchemaBackends::AvroLocal
- Deimos::SchemaBackends::AvroSchemaRegistry
- Deimos::SchemaBackends::AvroValidation
- Deimos::SchemaBackends::Base
- Deimos::SchemaBackends::Mock
- Deimos::SchemaField
- Deimos::SharedConfig
- Deimos::SharedConfig::ClassMethods
- Deimos::TestHelpers
- Deimos::Tracing
- Deimos::Tracing::Datadog
- Deimos::Tracing::Mock
- Deimos::Tracing::Provider
- Deimos::Utils
- Deimos::Utils::DbPoller
- Deimos::Utils::DbProducer
- Deimos::Utils::DeadlockRetry
- Deimos::Utils::InlineConsumer
- Deimos::Utils::InlineConsumer::frk_consumer
- Deimos::Utils::LagReporter
- Deimos::Utils::LagReporter::ConsumerGroup
- Deimos::Utils::LagReporter::Topic
- Deimos::Utils::MessageBankHandler
- Deimos::Utils::SchemaControllerMixin
- Deimos::Utils::SchemaControllerMixin::ClassMethods
- Deimos::Utils::SeekListener
- Phobos
- Phobos::CLI
- Phobos::CLI::Start
- Phobos::Producer
- Phobos::Producer::ClassMethods
- Phobos::Producer::ClassMethods::PublicAPI
- Phobos::Producer::PublicAPI
Methods
- ::_encode_key — Deimos::Producer
- ::_process_message — Deimos::Producer
- ::_retrieve_key — Deimos::Producer
- ::clear_lock — Deimos::KafkaTopicInfo
- ::compacted — Deimos::ActiveRecordConsumer
- ::config — Deimos::Producer
- ::config_class= — Deimos::Utils::MessageBankHandler
- ::consume — Deimos::Utils::InlineConsumer
- ::content_type — Deimos::SchemaBackends::Base
- ::decoded — Deimos::KafkaMessage
- ::decoder — Deimos::Consumer
- ::decoder — Deimos::KafkaMessage
- ::determine_backend_class — Deimos::Producer
- ::disable_producers — Deimos
- ::encoder — Deimos::Producer
- ::execute — Deimos::Backends::Base
- ::execute — Deimos::Backends::Test
- ::full_integration_test! — Deimos::TestHelpers
- ::generate_payload — Deimos::ActiveRecordProducer
- ::get_messages_for — Deimos::Utils::InlineConsumer
- ::heartbeat — Deimos::KafkaTopicInfo
- ::heartbeat — Deimos::Utils::LagReporter
- ::kafka_test! — Deimos::TestHelpers
- ::key_decoder — Deimos::Consumer
- ::key_encoder — Deimos::Producer
- ::lock — Deimos::KafkaTopicInfo
- ::message_processed — Deimos::Utils::LagReporter
- ::mock_backend — Deimos::SchemaBackends::Base
- ::new — Deimos::ActiveRecordConsume::SchemaModelConverter
- ::new — Deimos::ActiveRecordConsumer
- ::new — Deimos::Message
- ::new — Deimos::SchemaBackends::AvroBase
- ::new — Deimos::AvroSchemaCoercer
- ::new — Deimos::SchemaField
- ::new — Deimos::SchemaBackends::Base
- ::new — Deimos::Utils::DbPoller
- ::new — Deimos::Utils::DbProducer
- ::new — Deimos::Utils::LagReporter::ConsumerGroup
- ::new — Deimos::Utils::LagReporter::Topic
- ::offset_seek — Deimos::Utils::LagReporter
- ::partition_key — Deimos::Producer
- ::ping_empty_topics — Deimos::KafkaTopicInfo
- ::poll_query — Deimos::ActiveRecordProducer
- ::produce_batch — Deimos::Producer
- ::publish — Deimos::Backends::Base
- ::publish — Deimos::Producer
- ::publish_list — Deimos::Producer
- ::record_class — Deimos::ActiveRecordConsumer
- ::record_class — Deimos::ActiveRecordProducer
- ::register_error — Deimos::KafkaTopicInfo
- ::reset — Deimos::Utils::LagReporter
- ::schema_backend — Deimos
- ::schema_backend_class — Deimos
- ::send_event — Deimos::ActiveRecordProducer
- ::send_events — Deimos::ActiveRecordProducer
- ::send_produce_error — Deimos::KafkaListener
- ::sent_messages — Deimos::Backends::Test
- ::sent_messages — Deimos::TestHelpers
- ::shutdown_producer — Deimos::Backends::Kafka
- ::shutdown_producer — Deimos::Backends::KafkaAsync
- ::slice — Deimos::ActiveRecordConsume::BatchSlicer
- ::start! — Deimos::Utils::DbPoller
- ::start_db_backend! — Deimos
- ::topic — Deimos::Producer
- ::unit_test! — Deimos::TestHelpers
- ::watched_attributes — Deimos::Producer
- ::wrap — Deimos::Utils::DeadlockRetry
- #== — Deimos::Message
- #_coerce_field — Deimos::ActiveRecordConsume::SchemaModelConverter
- #_error — Deimos::Consumer
- #_hash_diff — Deimos::TestHelpers
- #_is_float_string? — Deimos::AvroSchemaCoercer
- #_is_integer_string? — Deimos::AvroSchemaCoercer
- #_is_to_s_defined? — Deimos::AvroSchemaCoercer
- #_report_time_delayed — Deimos::Consumer
- #_with_span — Deimos::Consumer
- #add_fields — Deimos::Message
- #assign_current_offset — Deimos::Utils::LagReporter::ConsumerGroup
- #assign_current_offset — Deimos::Utils::LagReporter::Topic
- #assign_key — Deimos::ActiveRecordConsume::MessageConsumption
- #avro_turf — Deimos::SchemaBackends::AvroLocal
- #avro_turf_messaging — Deimos::SchemaBackends::AvroSchemaRegistry
- #coerce — Deimos::SchemaBackends::Base
- #coerce_field — Deimos::SchemaBackends::Base
- #coerce_field — Deimos::SchemaBackends::Mock
- #coerce_fields — Deimos::Message
- #coerce_record — Deimos::AvroSchemaCoercer
- #coerce_type — Deimos::AvroSchemaCoercer
- #coerce_union — Deimos::AvroSchemaCoercer
- #compact_messages — Deimos::Utils::DbProducer
- #compact_messages — Deimos::ActiveRecordConsume::BatchConsumption
- #compute_lag — Deimos::Utils::LagReporter::Topic
- #config — Deimos::Utils::DbProducer
- #config — Deimos::SharedConfig::ClassMethods
- #consume_batch — Deimos::ActiveRecordConsume::BatchConsumption
- #convert — Deimos::ActiveRecordConsume::SchemaModelConverter
- #db_migrate_path — Deimos::Generators::ActiveRecordGenerator
- #db_migrate_path — Deimos::Generators::DbBackendGenerator
- #db_migrate_path — Deimos::Generators::DbPollerGenerator
- #decode — Deimos::SchemaBackends::Base
- #decode_key — Deimos::Consumer
- #decode_key — Deimos::SchemaBackends::AvroBase
- #decode_key — Deimos::SchemaBackends::Base
- #decode_key — Deimos::SchemaBackends::Mock
- #decode_payload — Deimos::SchemaBackends::AvroLocal
- #decode_payload — Deimos::SchemaBackends::AvroSchemaRegistry
- #decode_payload — Deimos::SchemaBackends::AvroValidation
- #decode_payload — Deimos::SchemaBackends::Base
- #decode_payload — Deimos::SchemaBackends::Mock
- #decoded_message — Deimos::KafkaMessage
- #delete_messages — Deimos::Utils::DbProducer
- #deleted_query — Deimos::ActiveRecordConsume::BatchConsumption
- #deletion_payload — Deimos::KafkaSource
- #encode — Deimos::SchemaBackends::Base
- #encode_key — Deimos::SchemaBackends::AvroBase
- #encode_key — Deimos::SchemaBackends::Base
- #encode_key — Deimos::SchemaBackends::Mock
- #encode_payload — Deimos::SchemaBackends::AvroLocal
- #encode_payload — Deimos::SchemaBackends::AvroSchemaRegistry
- #encode_payload — Deimos::SchemaBackends::AvroValidation
- #encode_payload — Deimos::SchemaBackends::Base
- #encode_payload — Deimos::SchemaBackends::Mock
- #encoded_hash — Deimos::Message
- #fatal_error? — Deimos::Consumer
- #fetch_record — Deimos::ActiveRecordConsume::MessageConsumption
- #fetch_results — Deimos::Utils::DbPoller
- #fields — Deimos::Generators::ActiveRecordGenerator
- #finish — Deimos::Tracing::Provider
- #gauge — Deimos::Metrics::Provider
- #generate — Deimos::Generators::DbBackendGenerator
- #generate — Deimos::Generators::DbPollerGenerator
- #histogram — Deimos::Metrics::Provider
- #import_without_validations_or_callbacks — Deimos::KafkaSource::ClassMethods
- #increment — Deimos::Metrics::Provider
- #kafka_config — Deimos::KafkaSource::ClassMethods
- #kafka_producers — Deimos::KafkaSource::ClassMethods
- #key_columns — Deimos::ActiveRecordConsume::BatchConsumption
- #key_config — Deimos::SharedConfig::ClassMethods
- #last_updated — Deimos::Utils::DbPoller
- #log_messages — Deimos::Utils::DbProducer
- #message= — Deimos::KafkaMessage
- #migration_version — Deimos::Generators::ActiveRecordGenerator
- #migration_version — Deimos::Generators::DbBackendGenerator
- #migration_version — Deimos::Generators::DbPollerGenerator
- #namespace — Deimos::Generators::ActiveRecordGenerator
- #namespace — Deimos::SharedConfig::ClassMethods
- #namespace — Deimos::Utils::SchemaControllerMixin::ClassMethods
- #namespaces — Deimos::Utils::SchemaControllerMixin::ClassMethods
- #phobos_message — Deimos::KafkaMessage
- #process_batch — Deimos::Utils::DbPoller
- #process_message? — Deimos::ActiveRecordConsumer
- #process_next_messages — Deimos::Utils::DbProducer
- #process_topic — Deimos::Utils::DbProducer
- #process_topic_batch — Deimos::Utils::DbProducer
- #process_updates — Deimos::Utils::DbPoller
- #produce_messages — Deimos::Utils::DbProducer
- #record_attributes — Deimos::ActiveRecordConsumer
- #record_key — Deimos::ActiveRecordConsume::BatchConsumption
- #remove_records — Deimos::ActiveRecordConsume::BatchConsumption
- #report_lag — Deimos::Utils::LagReporter::ConsumerGroup
- #report_lag — Deimos::Utils::LagReporter::Topic
- #request_namespace — Deimos::Utils::SchemaControllerMixin::ClassMethods
- #response_namespace — Deimos::Utils::SchemaControllerMixin::ClassMethods
- #retrieve_messages — Deimos::Utils::DbProducer
- #retrieve_poll_info — Deimos::Utils::DbPoller
- #retrieve_topics — Deimos::Utils::DbProducer
- #schema — Deimos::Generators::ActiveRecordGenerator
- #schema — Deimos::SharedConfig::ClassMethods
- #schema_base — Deimos::Generators::ActiveRecordGenerator
- #schema_fields — Deimos::SchemaBackends::Base
- #schema_fields — Deimos::SchemaBackends::Mock
- #schema_mapping — Deimos::Utils::SchemaControllerMixin::ClassMethods
- #schemas — Deimos::Utils::SchemaControllerMixin::ClassMethods
- #send_kafka_event_on_create — Deimos::KafkaSource
- #send_kafka_event_on_destroy — Deimos::KafkaSource
- #send_kafka_event_on_update — Deimos::KafkaSource
- #send_pending_metrics — Deimos::Utils::DbProducer
- #set_error — Deimos::Tracing::Provider
- #should_run? — Deimos::Utils::DbPoller
- #shutdown_producer — Deimos::Utils::DbProducer
- #sql_type — Deimos::SchemaBackends::Base
- #start — Deimos::Tracing::Provider
- #start — Deimos::Utils::DbPoller
- #start — Deimos::Utils::DbProducer
- #stop — Deimos::Utils::DbPoller
- #stop — Deimos::Utils::DbProducer
- #stub_batch_consumer — Deimos::TestHelpers
- #stub_consumer — Deimos::TestHelpers
- #stub_producer — Deimos::TestHelpers
- #stub_producers_and_consumers! — Deimos::TestHelpers
- #table_class — Deimos::Generators::ActiveRecordGenerator
- #time — Deimos::Metrics::Provider
- #to_h — Deimos::Message
- #to_h — Deimos::PhobosConfig
- #tombstone? — Deimos::Message
- #uncompacted_update — Deimos::ActiveRecordConsume::BatchConsumption
- #update_database — Deimos::ActiveRecordConsume::BatchConsumption
- #upsert_records — Deimos::ActiveRecordConsume::BatchConsumption
- #validate — Deimos::SchemaBackends::Base
- #validate — Deimos::SchemaBackends::Mock