Method List

Classes Methods Files

Search:

#== Deimos::SchemaClass::Base
#== Deimos::Message
#== Deimos::SchemaClass::Enum
#[] Deimos::SchemaClass::Record
#[]= Deimos::SchemaClass::Base
#active_span Deimos::Tracing::Provider
#active_span Deimos::Tracing::Datadog
#active_span Deimos::Tracing::Mock
#add_fields Deimos::Message
#around_consume Deimos::Consume::MessageConsumption
#around_consume_batch Deimos::Consume::BatchConsumption
#as_json Deimos::SchemaClass::Enum
#as_json Deimos::SchemaClass::Base
#assign_current_offset Deimos::Utils::LagReporter::ConsumerGroup
#assign_current_offset Deimos::Utils::LagReporter::Topic
#assign_key Deimos::ActiveRecordConsume::MessageConsumption
#associations Deimos::ActiveRecordConsume::BatchRecord
#associations Deimos::ActiveRecordConsume::BatchRecordList
#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
class_for_config Deimos::Utils::DbPoller
#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::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::DbProducer
compacted Deimos::ActiveRecordConsumer
#compute_lag Deimos::Utils::LagReporter::Topic
#config Deimos::Utils::DbProducer
config Deimos::Producer
#config Deimos::Utils::DbPoller::Base
#config Deimos::SharedConfig::ClassMethods
config_class= Deimos::Utils::MessageBankHandler
consume Deimos::Utils::InlineConsumer
#consume Deimos::Consume::MessageConsumption
#consume Deimos::Utils::MessageBankHandler
#consume Deimos::ActiveRecordConsume::MessageConsumption
#consume_batch Deimos::Consume::BatchConsumption
#consume_batch Deimos::ActiveRecordConsume::BatchConsumption
#consumer_group Deimos::Utils::LagReporter::Topic
content_type Deimos::SchemaBackends::Base
content_type Deimos::SchemaBackends::AvroBase
#convert Deimos::ActiveRecordConsume::SchemaModelConverter
#create_poll_info Deimos::Utils::DbPoller::TimeBased
#create_poll_info Deimos::Utils::DbPoller::Base
#current_batch Deimos::Utils::DbPoller::PollStatus
#current_topic Deimos::Utils::DbProducer
#db_migrate_path Deimos::Generators::DbPollerGenerator
#db_migrate_path Deimos::Generators::DbBackendGenerator
decode Deimos
#decode Deimos::SchemaBackends::Base
#decode_key Deimos::SchemaBackends::AvroBase
#decode_key Deimos::SchemaBackends::Base
#decode_key Deimos::Consumer
#decode_key Deimos::SchemaBackends::Mock
#decode_message Deimos::Consumer
#decode_payload Deimos::SchemaBackends::AvroValidation
#decode_payload Deimos::SchemaBackends::AvroSchemaRegistry
#decode_payload Deimos::SchemaBackends::Base
#decode_payload Deimos::SchemaBackends::AvroLocal
#decode_payload Deimos::SchemaBackends::Mock
#decode_schema Deimos::Utils::SchemaControllerMixin
decoded Deimos::KafkaMessage
#decoded_message Deimos::KafkaMessage
decoder Deimos::Consumer
decoder Deimos::KafkaMessage
#default Deimos::SchemaField
#default_cols Deimos::ActiveRecordConsume::MassUpdater
#default_keys Deimos::ActiveRecordConsume::MassUpdater
#delete_messages Deimos::Utils::DbProducer
#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::SchemaBackends::Base
#encode_key Deimos::SchemaBackends::Mock
#encode_key Deimos::SchemaBackends::AvroBase
#encode_key Deimos::SchemaBackends::Base
#encode_payload Deimos::SchemaBackends::AvroValidation
#encode_payload Deimos::SchemaBackends::AvroSchemaRegistry
#encode_payload Deimos::SchemaBackends::AvroLocal
#encode_payload Deimos::SchemaBackends::Mock
#encode_payload Deimos::SchemaBackends::Base
#encoded_hash Deimos::Message
#encoded_key Deimos::Message
#encoded_payload Deimos::Message
encoder Deimos::Producer
#enum_values Deimos::SchemaField
execute Deimos::Backends::Db
execute Deimos::Backends::Kafka
execute Deimos::Backends::Test
execute Deimos::Backends::Base
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::Datadog
#finish Deimos::Tracing::Mock
#finish Deimos::Tracing::Provider
full_integration_test! Deimos::TestHelpers
#full_schema Deimos::SchemaClass::Record
#gauge Deimos::Metrics::Datadog
#gauge Deimos::Metrics::Mock
#gauge Deimos::Metrics::Provider
#generate Deimos::Generators::SchemaClassGenerator
#generate Deimos::Generators::DbPollerGenerator
#generate Deimos::Generators::ActiveRecordGenerator
#generate Deimos::Generators::DbBackendGenerator
#generate Deimos::Generators::BulkImportIdGenerator
generate_payload Deimos::ActiveRecordProducer
get_messages_for Deimos::Utils::InlineConsumer
#get_tag Deimos::Tracing::Datadog
#get_tag Deimos::Tracing::MockSpan
#get_tag Deimos::Tracing::Mock
#get_tag Deimos::Tracing::Provider
handle_exception_with_messages Deimos::KafkaListener
#handle_message_too_large Deimos::Utils::DbPoller::Base
#headers Deimos::Message
heartbeat Deimos::Utils::LagReporter
heartbeat Deimos::KafkaTopicInfo
#histogram Deimos::Metrics::Datadog
#histogram Deimos::Metrics::Mock
#histogram Deimos::Metrics::Provider
#id Deimos::Utils::LagReporter::ConsumerGroup
#id Deimos::Utils::DbPoller::Base
#id Deimos::Utils::DbProducer
#import_associations Deimos::ActiveRecordConsume::MassUpdater
#increment Deimos::Metrics::Datadog
#increment Deimos::Metrics::Mock
#increment Deimos::Metrics::Provider
#initialize Deimos::Tracing::Datadog
#initialize Deimos::Metrics::Datadog
#initialize Deimos::ActiveRecordConsumer
#initialize Deimos::Tracing::Mock
#initialize Deimos::ActiveRecordConsume::BatchRecord
#initialize Deimos::Tracing::MockSpan
#initialize Deimos::Metrics::Mock
#initialize Deimos::SchemaBackends::AvroBase
#initialize Deimos::Utils::DbPoller::Base
#initialize Deimos::SchemaBackends::Base
#initialize Deimos::Message
#initialize Deimos::ActiveRecordConsume::MassUpdater
#initialize Deimos::ActiveRecordConsume::BatchRecordList
#initialize Deimos::Utils::DbProducer
#initialize Deimos::SchemaField
#initialize Deimos::Utils::LagReporter::ConsumerGroup
#initialize Deimos::SchemaClass::Enum
#initialize Deimos::SchemaClass::Base
#initialize Deimos::AvroSchemaCoercer
#initialize Deimos::ActiveRecordConsume::SchemaModelConverter
#initialize Deimos::Utils::LagReporter::Topic
initialize_from_value Deimos::SchemaClass::Record
initialize_from_value Deimos::SchemaClass::Enum
initialize_from_value Deimos::SchemaClass::Base
#inspect Deimos::SchemaClass::Base
instance Deimos::Utils::SchemaClass
#instrument Deimos::Instrumentation::ClassMethods
#kafka_config Deimos::KafkaSource::ClassMethods
#kafka_producers Deimos::KafkaSource::ClassMethods
kafka_test! Deimos::TestHelpers
#key Deimos::Message
#key_cols Deimos::ActiveRecordConsume::MassUpdater
#key_config Deimos::SharedConfig::ClassMethods
key_decoder Deimos::Consumer
key_encoder Deimos::Producer
#key_schema Deimos::SchemaBackends::Base
klass Deimos::Utils::SchemaClass
#klass Deimos::ActiveRecordConsume::BatchRecordList
#klass Deimos::ActiveRecordConsume::BatchRecord
#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_identifier Deimos::Utils::DbPoller::Base
#log_messages Deimos::Utils::DbProducer
#mass_update Deimos::ActiveRecordConsume::MassUpdater
max_db_batch_size Deimos::ActiveRecordConsumer
#merge Deimos::SchemaClass::Record
#message= Deimos::KafkaMessage
message_processed Deimos::Utils::LagReporter
#messages_processed Deimos::Utils::DbPoller::PollStatus
#migration_version Deimos::Generators::DbBackendGenerator
#migration_version Deimos::Generators::DbPollerGenerator
mock_backend Deimos::SchemaBackends::Base
mock_backend Deimos::SchemaBackends::AvroBase
modules_for Deimos::Utils::SchemaClass
#name Deimos::SchemaField
#namespace Deimos::SharedConfig::ClassMethods
#namespace Deimos::Utils::SchemaControllerMixin::ClassMethods
#namespace Deimos::SchemaClass::Record
#namespace Deimos::SchemaBackends::Base
#namespaces Deimos::Utils::SchemaControllerMixin::ClassMethods
#num_messages Deimos::Utils::SeekListener
offset_seek Deimos::Utils::LagReporter
#parse_namespace Deimos::Utils::SchemaControllerMixin
#partition_current_offsets Deimos::Utils::LagReporter::Topic
partition_key Deimos::Producer
#partition_key Deimos::Message
partition_key_for Deimos::Backends::Db
#payload Deimos::Message
#phobos_config Deimos::PhobosConfig
#phobos_message Deimos::KafkaMessage
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::DbProducer
#process_topic Deimos::Utils::DbProducer
#process_topic_batch Deimos::Utils::DbProducer
#process_updates Deimos::Utils::DbPoller::Base
#process_updates Deimos::Utils::DbPoller::TimeBased
#process_updates Deimos::Utils::DbPoller::StateBased
produce_batch Deimos::Producer
#produce_messages Deimos::Utils::DbProducer
#producer_classes Deimos::Utils::DbPoller::Base
#producer_name Deimos::Message
producers Deimos::Utils::DbPoller::Base
producers_disabled? Deimos
publish Deimos::Backends::Base
publish Deimos::Producer
publish_list Deimos::Producer
#record Deimos::ActiveRecordConsume::BatchRecord
#record_attributes Deimos::ActiveRecordConsumer
record_class Deimos::ActiveRecordConsumer
record_class Deimos::ActiveRecordProducer
#records Deimos::ActiveRecordConsume::BatchRecordList
register_error Deimos::KafkaTopicInfo
#render_schema Deimos::Utils::SchemaControllerMixin
replace_associations Deimos::ActiveRecordConsumer
#report Deimos::Utils::DbPoller::PollStatus
#report_lag Deimos::Utils::LagReporter::Topic
#report_lag Deimos::Utils::LagReporter::ConsumerGroup
#request_namespace Deimos::Utils::SchemaControllerMixin::ClassMethods
reset Deimos::Utils::LagReporter
#reset! Deimos::PhobosConfig
#response_namespace Deimos::Utils::SchemaControllerMixin::ClassMethods
#retrieve_messages Deimos::Utils::DbProducer
#retrieve_poll_info Deimos::Utils::DbPoller::Base
#retrieve_topics Deimos::Utils::DbProducer
#save_record Deimos::ActiveRecordConsume::MessageConsumption
#save_records_to_database Deimos::ActiveRecordConsume::MassUpdater
#schema Deimos::SharedConfig::ClassMethods
#schema Deimos::SchemaBackends::Base
#schema Deimos::SchemaClass::Record
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::SchemaBackends::AvroBase
#schema_fields Deimos::SchemaClass::Record
#schema_fields Deimos::SchemaBackends::Mock
#schema_fields Deimos::SchemaBackends::Base
#schema_format? Deimos::Utils::SchemaControllerMixin
#schema_mapping Deimos::Utils::SchemaControllerMixin::ClassMethods
#schema_store Deimos::SchemaBackends::AvroBase
#schemas Deimos::Utils::SchemaControllerMixin::ClassMethods
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::Backends::Test
sent_messages Deimos::TestHelpers
#set_error Deimos::Tracing::Provider
#set_error Deimos::Tracing::Datadog
#set_error Deimos::Tracing::Mock
#set_tag Deimos::Tracing::Provider
#set_tag Deimos::Tracing::Datadog
#set_tag Deimos::Tracing::Mock
#set_tag Deimos::Tracing::MockSpan
#should_run? Deimos::Utils::DbPoller::Base
shutdown_producer Deimos::Backends::KafkaAsync
#shutdown_producer Deimos::Utils::DbProducer
shutdown_producer Deimos::Backends::Kafka
slice Deimos::ActiveRecordConsume::BatchSlicer
#sql_type Deimos::SchemaBackends::AvroBase
#sql_type Deimos::SchemaBackends::Base
#ssl_var_contents Deimos::PhobosConfig
start Deimos::Utils::MessageBankHandler
#start Deimos::Utils::DbPoller::Base
#start Deimos::Utils::DbProducer
#start Deimos::Tracing::Provider
#start Deimos::Tracing::Datadog
#start Deimos::Tracing::Mock
start! Deimos::Utils::DbPoller
start_db_backend! Deimos
#start_listener Deimos::Utils::SeekListener
#stop Deimos::Utils::DbPoller::Base
#stop Deimos::Utils::DbProducer
#sub_records Deimos::ActiveRecordConsume::BatchRecord
#subscribe Deimos::Instrumentation::ClassMethods
#symbols Deimos::SchemaClass::Enum
#test_consume_batch Deimos::TestHelpers
#test_consume_batch_invalid_message Deimos::TestHelpers
#test_consume_invalid_message Deimos::TestHelpers
#test_consume_message Deimos::TestHelpers
#time Deimos::Metrics::Provider
#time Deimos::Metrics::Datadog
#time Deimos::Metrics::Mock
#to_h Deimos::PhobosConfig
#to_h Deimos::SchemaClass::Record
#to_h Deimos::Message
#to_s Deimos::SchemaClass::Enum
#tombstone? Deimos::Message
#tombstone_key Deimos::SchemaClass::Record
topic Deimos::Producer
#topic Deimos::Message
#topic_name Deimos::Utils::LagReporter::Topic
#topics Deimos::Utils::LagReporter::ConsumerGroup
#touch_info Deimos::Utils::DbPoller::TimeBased
#tracer Deimos::Tracing::Datadog
#type Deimos::SchemaField
unit_test! Deimos::TestHelpers
#unsubscribe Deimos::Instrumentation::ClassMethods
use? Deimos::Utils::SchemaClass
#validate Deimos::SchemaBackends::AvroBase
#validate Deimos::SchemaBackends::Base
#validate Deimos::SchemaBackends::Mock
#validate_import_id! Deimos::ActiveRecordConsume::BatchRecord
#validate_listeners! Phobos::CLI::Start
#validate_producer_class Deimos::Utils::DbPoller::Base
#validator Deimos::SchemaClass::Record
#value Deimos::SchemaClass::Enum
watched_attributes Deimos::Producer
#with_indifferent_access Deimos::SchemaClass::Record
wrap Deimos::Utils::DeadlockRetry