Method List

Classes Methods Files

Search:

#== Deimos::Message
_disable_producer_classes Deimos
#_frk_failure_message Deimos::TestHelpers
#_hash_diff Deimos::TestHelpers
#add_fields Deimos::Message
#add_schema AvroTurf::SchemaStore
#around_consume Deimos::Consumer
#assign_lag Deimos::Utils::LagReporter::Topic
#assign_lag Deimos::Utils::LagReporter::ConsumerGroup
#async_publish Phobos::Producer::PublicAPI
#async_publish Phobos::Producer::ClassMethods::PublicAPI
#avro_schema Deimos::AvroDataCoder
#before_consume Deimos::Consumer
#clear_kafka_messages! Deimos::TestHelpers
clear_lock Deimos::KafkaTopicInfo
#coerce Deimos::SchemaCoercer
#coerce_fields Deimos::Message
#compute_lag Deimos::Utils::LagReporter::Topic
#compute_lag Deimos::Utils::LagReporter::ConsumerGroup
#config Deimos::SharedConfig::ClassMethods
config Deimos
config Deimos::Producer
#config Deimos::AvroDataCoder
config_class= Deimos::Utils::MessageBankHandler
configure Deimos
configure_kafka_for_phobos Deimos
configure_loggers Deimos
consume Deimos::Utils::InlineConsumer
#consume Deimos::Utils::MessageBankHandler
#consume Deimos::Consumer
#consume Deimos::ActiveRecordConsumer
#consumer Kafka::Client
#consumer_group Deimos::Utils::LagReporter::Topic
#current_topic Deimos::Utils::DbProducer
#db_migrate_path Deimos::Generators::DbBackendGenerator
#decode Deimos::AvroDataDecoder
#decode_key Deimos::Consumer
#decode_key Deimos::AvroDataDecoder
#decode_local Deimos::AvroDataDecoder
#decoded_message Deimos::KafkaMessage
decoder Deimos::Consumer
#decoder Deimos::KafkaMessage
#deletion_payload Deimos::KafkaSource
#destroy_record Deimos::ActiveRecordConsumer
determine_backend_class Deimos::Producer
disable_producers Deimos
#disable_producers Deimos::Configuration
#encode Deimos::AvroDataEncoder
#encode_key Deimos::AvroDataEncoder
#encode_local Deimos::AvroDataEncoder
#encoded_hash Deimos::Message
#encoded_key Deimos::Message
#encoded_payload Deimos::Message
encoder Deimos::Producer
execute Deimos::Backends::Db
execute Deimos::PublishBackend
execute Deimos::Backends::KafkaAsync
execute Deimos::Backends::Kafka
#finish Deimos::Tracing::Provider
#finish Deimos::Tracing::Mock
#finish Deimos::Tracing::Datadog
#gauge Deimos::Metrics::Datadog
#gauge Deimos::Metrics::Provider
#gauge Deimos::Metrics::Mock
#generate Deimos::Generators::DbBackendGenerator
generate_payload Deimos::ActiveRecordProducer
get_messages_for Deimos::Utils::InlineConsumer
heartbeat Deimos::KafkaTopicInfo
heartbeat Deimos::Utils::LagReporter
#histogram Deimos::Metrics::Provider
#histogram Deimos::Metrics::Mock
#histogram Deimos::Metrics::Datadog
#id Deimos::Utils::LagReporter::ConsumerGroup
#id Deimos::Utils::DbProducer
#import_without_validations_or_callbacks Deimos::KafkaSource::ClassMethods
#increment Deimos::Metrics::Datadog
#increment Deimos::Metrics::Mock
#increment Deimos::Metrics::Provider
#initialize Deimos::Tracing::Mock
#initialize Deimos::Utils::SignalHandler
#initialize Deimos::Metrics::Mock
#initialize Deimos::SchemaCoercer
#initialize Deimos::Metrics::Datadog
#initialize Deimos::Message
#initialize Deimos::Utils::LagReporter::ConsumerGroup
#initialize Kafka::Heartbeat
#initialize Deimos::AvroDataCoder
#initialize Deimos::Utils::DbProducer
#initialize Deimos::Tracing::Datadog
#initialize Deimos::Configuration
#initialize Deimos::Utils::LagReporter::Topic
#initialize Deimos::Utils::Executor
#instrument Deimos::Instrumentation::ClassMethods
#kafka_config Deimos::KafkaSource::ClassMethods
#kafka_logger Deimos::Configuration
#kafka_producer Deimos::KafkaSource::ClassMethods
#kafka_producers Deimos::KafkaSource::ClassMethods
#key Deimos::Message
#key_config Deimos::SharedConfig::ClassMethods
key_decoder Deimos::Consumer
key_encoder Deimos::Producer
lock Deimos::KafkaTopicInfo
#logger Deimos::Configuration
#message= Deimos::KafkaMessage
message_processed Deimos::Utils::LagReporter
#metrics Deimos::Configuration
#migration_version Deimos::Generators::DbBackendGenerator
#namespace Deimos::AvroDataCoder
#namespace Deimos::SharedConfig::ClassMethods
#num_messages Deimos::Utils::SeekListener
offset_seek Deimos::Utils::LagReporter
partition_key Deimos::Producer
#partition_key Deimos::Message
#partition_offset_lags Deimos::Utils::LagReporter::Topic
#payload Deimos::Message
#phobos_config_changed? Deimos::Configuration
#phobos_config_file Deimos::Configuration
#phobos_logger Deimos::Configuration
#phobos_message Deimos::KafkaMessage
#process_next_messages Deimos::Utils::DbProducer
#process_topic Deimos::Utils::DbProducer
produce_batch Deimos::Producer
#produce_messages Deimos::Utils::DbProducer
#producer_name Deimos::Message
#producer_schema_namespace Deimos::Configuration
#producer_topic_prefix Deimos::Configuration
producers_disabled? Deimos
publish Deimos::PublishBackend
#publish Phobos::Producer::PublicAPI
publish Deimos::Producer
#publish Phobos::Producer::ClassMethods::PublicAPI
#publish_backend Deimos::Configuration
publish_list Deimos::Producer
#record_attributes Deimos::ActiveRecordConsumer
record_class Deimos::ActiveRecordConsumer
record_class Deimos::ActiveRecordProducer
register_error Deimos::KafkaTopicInfo
#report_lag Deimos::Configuration
#report_lag Deimos::Utils::LagReporter::Topic
#report_lag Deimos::Utils::LagReporter::ConsumerGroup
#reraise_consumer_errors Deimos::Configuration
reset Deimos::Utils::LagReporter
#retrieve_messages Deimos::Utils::DbProducer
#retrieve_topics Deimos::Utils::DbProducer
#run! Deimos::Utils::SignalHandler
#runners Deimos::Utils::Executor
#schema Deimos::AvroDataCoder
#schema Deimos::SharedConfig::ClassMethods
#schema_path Deimos::Configuration
#schema_registry_url Deimos::Configuration
#schema_store Deimos::AvroDataCoder
#schemas AvroTurf::SchemaStore
schemas_compatible? Deimos::TestHelpers
#seed_broker Deimos::Configuration
send_event Deimos::ActiveRecordProducer
send_events Deimos::ActiveRecordProducer
#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
send_produce_error Deimos::KafkaListener
sent_messages Deimos::TestHelpers
#set_error Deimos::Tracing::Mock
#set_error Deimos::Tracing::Provider
#set_error Deimos::Tracing::Datadog
shutdown_producer Deimos::Backends::Kafka
shutdown_producer Deimos::Backends::KafkaAsync
#shutdown_producer Deimos::Utils::DbProducer
#ssl_ca_cert Deimos::Configuration
#ssl_client_cert Deimos::Configuration
#ssl_client_cert_key Deimos::Configuration
#ssl_enabled Deimos::Configuration
ssl_var_contents Deimos
#start Deimos::Utils::DbProducer
#start Deimos::Tracing::Provider
start Deimos::Utils::MessageBankHandler
#start Deimos::Tracing::Datadog
#start Deimos::Utils::Executor
#start Deimos::Tracing::Mock
start_db_backend! Deimos
#start_listener Deimos::Utils::SeekListener
#stop Deimos::Utils::DbProducer
#stop Deimos::Utils::Executor
#stub_consumer Deimos::TestHelpers
#stub_producer Deimos::TestHelpers
#stub_producers_and_consumers! Deimos::TestHelpers
#subscribe Deimos::Instrumentation::ClassMethods
#test_consume_invalid_message Deimos::TestHelpers
#test_consume_message Deimos::TestHelpers
#time Deimos::Metrics::Datadog
#time Deimos::Metrics::Provider
#time Deimos::Metrics::Mock
#to_h Deimos::Message
topic Deimos::Producer
#topic Deimos::Message
#topic_name Deimos::Utils::LagReporter::Topic
#topics Deimos::Utils::LagReporter::ConsumerGroup
#tracer Deimos::Configuration
#trigger! Kafka::Heartbeat
#unsubscribe Deimos::Instrumentation::ClassMethods
validate_db_backend Deimos
#validate_listeners! Phobos::CLI::Start
#was_message_sent? Deimos::TestHelpers
watched_attributes Deimos::Producer