Method List

Classes Methods Files

Search:

#== Deimos::Message
#== Deimos::SchemaClass::Base
#== Deimos::SchemaClass::Enum
#[] Deimos::SchemaClass::Record
#[]= Deimos::SchemaClass::Base
#_deimos_setup_transcoders Deimos::SchemaRoute::Topic
_encode_key Deimos::ProducerMiddleware
_payloads Deimos::Logging
_process_message Deimos::ProducerMiddleware
_retrieve_key Deimos::ProducerMiddleware
#active_span Deimos::Tracing::Mock
#active_span Deimos::Tracing::Datadog
#active_span Deimos::Tracing::Provider
#add_fields Deimos::Message
#array_clear Karafka::Routing::Builder
#as_json Deimos::SchemaClass::Base
#as_json Deimos::SchemaClass::Enum
#assign_associations Deimos::ActiveRecordConsume::MassUpdater
#assign_key Deimos::ActiveRecordConsume::MessageConsumption
#associations Deimos::ActiveRecordConsume::BatchRecord
#associations Deimos::ActiveRecordConsume::BatchRecordList
#backend Deimos::Transcoder
#batch_records Deimos::ActiveRecordConsume::BatchRecordList
#batches_errored Deimos::Utils::DbPoller::PollStatus
#batches_processed Deimos::Utils::DbPoller::PollStatus
#bulk_import_column Deimos::ActiveRecordConsume::BatchRecord
#bulk_import_column Deimos::ActiveRecordConsume::BatchRecordList
#bulk_import_id Deimos::ActiveRecordConsume::BatchRecord
#bulk_import_id_column Deimos::ActiveRecordConsumer
#bulk_import_id_generator Deimos::ActiveRecordConsumer
#call Deimos::Transcoder
call Deimos::ProducerMiddleware
class_for_config Deimos::Utils::DbPoller
#clear Karafka::Routing::Builder
#clear_kafka_messages! Deimos::TestHelpers
clear_lock Deimos::KafkaTopicInfo
#coerce Deimos::SchemaBackends::Base
#coerce_field Deimos::SchemaBackends::Base
#coerce_field Deimos::SchemaBackends::Mock
#coerce_field Deimos::SchemaBackends::Plain
#coerce_field Deimos::SchemaBackends::AvroBase
#coerce_fields Deimos::Message
#coerce_record Deimos::AvroSchemaCoercer
#coerce_type Deimos::AvroSchemaCoercer
#coerce_union Deimos::AvroSchemaCoercer
#columns Deimos::ActiveRecordConsume::MassUpdater
#compact_messages Deimos::Utils::OutboxProducer
compacted Deimos::ActiveRecordConsumer
#config Deimos::SharedConfig::ClassMethods
#config Deimos::Utils::DbPoller::Base
#config Deimos::Utils::OutboxProducer
config Deimos::ActiveRecordProducer
#consume Deimos::Consumer
#consume_batch Deimos::Consume::BatchConsumption
#consume_batch Deimos::ActiveRecordConsume::BatchConsumption
#consume_message Deimos::Consume::MessageConsumption
#consume_message Deimos::ActiveRecordConsume::MessageConsumption
content_type Deimos::SchemaBackends::Base
content_type Deimos::SchemaBackends::AvroBase
#convert Deimos::ActiveRecordConsume::SchemaModelConverter
#converter Deimos::ActiveRecordConsumer
#create_poll_info Deimos::Utils::DbPoller::Base
#create_poll_info Deimos::Utils::DbPoller::TimeBased
#current_batch Deimos::Utils::DbPoller::PollStatus
#current_topic Deimos::Utils::OutboxProducer
#db_migrate_path Deimos::Generators::DbPollerGenerator
#db_migrate_path Deimos::Generators::OutboxBackendGenerator
decode Deimos
#decode Deimos::SchemaBackends::Base
#decode_key Deimos::Transcoder
#decode_key Deimos::SchemaBackends::Base
#decode_key Deimos::SchemaBackends::Mock
#decode_key Deimos::SchemaBackends::Plain
#decode_key Deimos::SchemaBackends::AvroBase
decode_message Deimos
#decode_message Deimos::Transcoder
#decode_message_hash Deimos::Transcoder
#decode_payload Deimos::SchemaBackends::Base
#decode_payload Deimos::SchemaBackends::Mock
#decode_payload Deimos::SchemaBackends::Plain
#decode_payload Deimos::SchemaBackends::AvroLocal
#decode_payload Deimos::SchemaBackends::AvroValidation
#decode_payload Deimos::SchemaBackends::AvroSchemaRegistry
decoded Deimos::KafkaMessage
#decoded_message Deimos::KafkaMessage
decoder Deimos::KafkaMessage
#default Deimos::SchemaField
#default_cols Deimos::ActiveRecordConsume::MassUpdater
#default_keys Deimos::ActiveRecordConsume::MassUpdater
#defaults Builder
#delete_messages Deimos::Utils::OutboxProducer
#delete_old_records Deimos::ActiveRecordConsume::BatchRecordList
#deletion_payload Deimos::KafkaSource
#destroy_record Deimos::ActiveRecordConsume::MessageConsumption
determine_backend_class Deimos::Producer
disable_producers Deimos
encode Deimos
#encode Deimos::Transcoder
#encode Deimos::SchemaBackends::Base
#encode_key Deimos::Transcoder
#encode_key Deimos::SchemaBackends::Base
#encode_key Deimos::SchemaBackends::Mock
#encode_key Deimos::SchemaBackends::Plain
#encode_key Deimos::SchemaBackends::AvroBase
#encode_payload Deimos::SchemaBackends::Base
#encode_payload Deimos::SchemaBackends::Mock
#encode_payload Deimos::SchemaBackends::Plain
#encode_payload Deimos::SchemaBackends::AvroLocal
#encode_payload Deimos::SchemaBackends::AvroValidation
#encode_payload Deimos::SchemaBackends::AvroSchemaRegistry
#encoded_hash Deimos::Message
#encoded_key Deimos::Message
#encoded_payload Deimos::Message
encoder Deimos::ActiveRecordProducer
#enum_values Deimos::SchemaField
execute Deimos::Backends::Base
execute Deimos::Backends::Test
execute Deimos::Backends::Kafka
execute Deimos::Backends::Outbox
execute Deimos::Backends::KafkaAsync
#fetch_record Deimos::ActiveRecordConsume::MessageConsumption
#fetch_results Deimos::Utils::DbPoller::TimeBased
#fetch_results Deimos::Utils::DbPoller::StateBased
field_type Deimos::SchemaBackends::Base
field_type Deimos::SchemaBackends::AvroBase
#fill_primary_keys! Deimos::ActiveRecordConsume::BatchRecordList
#filter! Deimos::ActiveRecordConsume::BatchRecordList
#finalize_batch Deimos::Utils::DbPoller::StateBased
#finish Deimos::Tracing::Mock
#finish Deimos::Tracing::Datadog
#finish Deimos::Tracing::Provider
#full_schema Deimos::SchemaClass::Record
#gauge Deimos::Metrics::Mock
#gauge Deimos::Metrics::Datadog
#gauge Deimos::Metrics::Provider
#generate Deimos::Generators::V2Generator
#generate Deimos::Generators::DbPollerGenerator
#generate Deimos::Generators::SchemaClassGenerator
#generate Deimos::Generators::ActiveRecordGenerator
#generate Deimos::Generators::BulkImportIdGenerator
#generate Deimos::Generators::OutboxBackendGenerator
#generate_key_schema Deimos::SchemaBackends::Base
#generate_key_schema Deimos::SchemaBackends::Mock
#generate_key_schema Deimos::SchemaBackends::Plain
#generate_key_schema Deimos::SchemaBackends::AvroBase
generate_key_schemas Deimos
generate_payload Deimos::ActiveRecordProducer
#get_tag Deimos::Tracing::Mock
#get_tag Deimos::Tracing::MockSpan
#get_tag Deimos::Tracing::Datadog
#get_tag Deimos::Tracing::Provider
#handle_message_too_large Deimos::Utils::DbPoller::Base
#headers Deimos::Message
heartbeat Deimos::KafkaTopicInfo
#histogram Deimos::Metrics::Mock
#histogram Deimos::Metrics::Datadog
#histogram Deimos::Metrics::Provider
#id Deimos::Utils::DbPoller::Base
#id Deimos::Utils::OutboxProducer
#import_associations Deimos::ActiveRecordConsume::MassUpdater
included Deimos::TestHelpers
#increment Deimos::Metrics::Mock
#increment Deimos::Metrics::Datadog
#increment Deimos::Metrics::Provider
#initialize Deimos::Message
#initialize Deimos::Transcoder
#initialize Deimos::Metrics::Mock
#initialize Deimos::Tracing::Mock
#initialize Deimos::Tracing::MockSpan
#initialize Deimos::Metrics::Datadog
#initialize Deimos::Tracing::Datadog
#initialize Deimos::SchemaClass::Base
#initialize Deimos::SchemaClass::Enum
#initialize Matcher
#initialize Deimos::SchemaField
#initialize Deimos::SchemaBackends::Base
#initialize Deimos::Utils::DbPoller::Base
#initialize Deimos::Utils::OutboxProducer
#initialize Deimos::ActiveRecordConsumer
#initialize Deimos::SchemaBackends::AvroBase
#initialize Deimos::ActiveRecordConsume::BatchRecord
#initialize Deimos::ActiveRecordConsume::MassUpdater
#initialize Deimos::AvroSchemaCoercer
#initialize Deimos::ActiveRecordConsume::BatchRecordList
#initialize Deimos::ActiveRecordConsume::SchemaModelConverter
initialize_from_value Deimos::SchemaClass::Base
initialize_from_value Deimos::SchemaClass::Enum
initialize_from_value Deimos::SchemaClass::Record
#inspect Deimos::SchemaClass::Base
#inspect Deimos::Generators::V2Generator::ProcString
instance Deimos::Utils::SchemaClass
#kafka_config Deimos::KafkaSource::ClassMethods
#kafka_producers Deimos::KafkaSource::ClassMethods
karafka_config Deimos::Producer
karafka_config_for Deimos
karafka_configs Deimos
#karafka_message Deimos::KafkaMessage
#key Deimos::Message
#key_cols Deimos::ActiveRecordConsume::MassUpdater
#key_config Deimos::SharedConfig::ClassMethods
#key_converter Deimos::ActiveRecordConsumer
#key_decoder Deimos::ActiveRecordConsumer
#key_field Deimos::Transcoder
#key_schema Deimos::SchemaBackends::Base
klass Deimos::Utils::SchemaClass
#klass Deimos::ActiveRecordConsume::BatchRecord
#klass Deimos::ActiveRecordConsume::BatchRecordList
#last_updated Deimos::Utils::DbPoller::TimeBased
load_generated_schema_classes Deimos
#load_schema Deimos::SchemaBackends::Base
#load_schema Deimos::SchemaBackends::AvroBase
lock Deimos::KafkaTopicInfo
log_add Deimos::Logging
log_debug Deimos::Logging
log_error Deimos::Logging
#log_identifier Deimos::Utils::DbPoller::Base
log_info Deimos::Logging
#log_messages Deimos::Utils::OutboxProducer
log_warn Deimos::Logging
#mass_update Deimos::ActiveRecordConsume::MassUpdater
max_db_batch_size Deimos::ActiveRecordConsumer
#merge Deimos::SchemaClass::Record
#message= Deimos::KafkaMessage
messages_log_text Deimos::Logging
#messages_processed Deimos::Utils::DbPoller::PollStatus
metadata_log_text Deimos::Logging
#method_missing Matcher
#migration_version Deimos::Generators::DbPollerGenerator
#migration_version Deimos::Generators::OutboxBackendGenerator
mock_backend Deimos::SchemaBackends::Base
mock_backend Deimos::SchemaBackends::AvroBase
modules_for Deimos::Utils::SchemaClass
#name Deimos::SchemaField
#namespace Deimos::SharedConfig::ClassMethods
#namespace Deimos::SchemaClass::Record
#namespace Deimos::SchemaBackends::Base
normalize_message Deimos::TestHelpers
#partition_key Deimos::Message
partition_key Deimos::Producer
partition_key_for Deimos::Backends::Outbox
#payload Deimos::Message
ping_empty_topics Deimos::KafkaTopicInfo
poll_query Deimos::ActiveRecordProducer
post_process Deimos::ActiveRecordProducer
#primary_keys Deimos::ActiveRecordConsume::BatchRecordList
#process_and_touch_info Deimos::Utils::DbPoller::TimeBased
#process_batch Deimos::Utils::DbPoller::Base
#process_batch_with_span Deimos::Utils::DbPoller::Base
#process_message? Deimos::ActiveRecordConsumer
#process_next_messages Deimos::Utils::OutboxProducer
#process_topic Deimos::Utils::OutboxProducer
#process_topic_batch Deimos::Utils::OutboxProducer
#process_updates Deimos::Utils::DbPoller::Base
#process_updates Deimos::Utils::DbPoller::TimeBased
#process_updates Deimos::Utils::DbPoller::StateBased
produce Deimos::Producer
produce_batch Deimos::Producer
#produce_messages Deimos::Utils::OutboxProducer
#producer_classes Deimos::Utils::DbPoller::Base
producers Deimos::Utils::DbPoller::Base
producers_disabled? Deimos
publish Deimos::Producer
publish Deimos::Backends::Base
publish_list Deimos::Producer
quote_time Deimos::KafkaTopicInfo
#record Deimos::ActiveRecordConsume::BatchRecord
#record_attributes Deimos::ActiveRecordConsumer
record_class Deimos::ActiveRecordConsumer
record_class Deimos::ActiveRecordProducer
#records Deimos::ActiveRecordConsume::BatchRecordList
#redraw Karafka::Routing::Builder
register_error Deimos::KafkaTopicInfo
#replace_associations Deimos::ActiveRecordConsumer
#replay_on Matcher
#report Deimos::Utils::DbPoller::PollStatus
#retrieve_messages Deimos::Utils::OutboxProducer
#retrieve_poll_info Deimos::Utils::DbPoller::Base
#retrieve_topics Deimos::Utils::OutboxProducer
#save_associations_first Deimos::ActiveRecordConsumer
#save_associations_first Deimos::ActiveRecordConsume::MassUpdater
#save_record Deimos::ActiveRecordConsume::MessageConsumption
#save_records_to_database Deimos::ActiveRecordConsume::MassUpdater
#schema Deimos::SharedConfig::ClassMethods
#schema Deimos::SchemaClass::Record
#schema Deimos::SchemaBackends::Base
schema_backend Deimos
schema_backend_class Deimos
schema_base_class Deimos::SchemaBackends::AvroBase
#schema_class_config Deimos::SharedConfig::ClassMethods
schema_classname Deimos::SchemaBackends::AvroBase
#schema_fields Deimos::SchemaClass::Record
#schema_fields Deimos::SchemaBackends::Base
#schema_fields Deimos::SchemaBackends::Mock
#schema_fields Deimos::SchemaBackends::Plain
#schema_fields Deimos::SchemaBackends::AvroBase
#schema_store Deimos::SchemaBackends::AvroBase
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::OutboxProducer
#sent_messages Deimos::TestHelpers
sent_messages Deimos::TestHelpers
sent_messages Deimos::Backends::Test
#set_error Deimos::Tracing::Mock
#set_error Deimos::Tracing::Datadog
#set_error Deimos::Tracing::Provider
#set_tag Deimos::Tracing::Mock
#set_tag Deimos::Tracing::MockSpan
#set_tag Deimos::Tracing::Datadog
#set_tag Deimos::Tracing::Provider
setup_karafka Deimos
#setup_karafka Deimos::Metrics::Datadog
#setup_waterdrop Deimos::Metrics::Datadog
#should_run? Deimos::Utils::DbPoller::Base
slice Deimos::ActiveRecordConsume::BatchSlicer
#sql_type Deimos::SchemaBackends::Base
#sql_type Deimos::SchemaBackends::AvroBase
#start Deimos::Tracing::Mock
#start Deimos::Tracing::Datadog
#start Deimos::Tracing::Provider
#start Deimos::Utils::DbPoller::Base
#start Deimos::Utils::OutboxProducer
start! Deimos::Utils::DbPoller
start_outbox_backend! Deimos
#stop Deimos::Utils::DbPoller::Base
#stop Deimos::Utils::OutboxProducer
#sub_records Deimos::ActiveRecordConsume::BatchRecord
#symbols Deimos::SchemaClass::Enum
#test_consume_batch Deimos::TestHelpers
#test_consume_message Deimos::TestHelpers
#time Deimos::Metrics::Mock
#time Deimos::Metrics::Datadog
#time Deimos::Metrics::Provider
#to_h Deimos::Message
#to_h Deimos::SchemaClass::Record
#to_s Deimos::SchemaClass::Enum
#tombstone? Deimos::Message
#tombstone_key Deimos::SchemaClass::Record
#topic Deimos::Message
topic Deimos::Producer
#topic= ConsumerGroup
topic_for_consumer Deimos
#touch_info Deimos::Utils::DbPoller::TimeBased
#tracer Deimos::Tracing::Datadog
#type Deimos::SchemaField
unit_test! Deimos::TestHelpers
#validate Deimos::SchemaBackends::Base
#validate Deimos::SchemaBackends::Mock
#validate Deimos::SchemaBackends::Plain
#validate Deimos::SchemaBackends::AvroBase
#validate_import_id! Deimos::ActiveRecordConsume::BatchRecord
validate_key_config Deimos::ProducerMiddleware
#validate_producer_class Deimos::Utils::DbPoller::Base
#validator Deimos::SchemaClass::Record
#value Deimos::SchemaClass::Enum
watched_attributes Deimos::ActiveRecordProducer
#with_indifferent_access Deimos::SchemaClass::Record
wrap Deimos::Utils::DeadlockRetry