Method List

Classes Methods Files

Search:

#== Deimos::Message
#== Deimos::SchemaClass::Base
#[] Deimos::SchemaClass::Record
#[]= Deimos::SchemaClass::Base
_disable_producer_classes Deimos
#_frk_failure_message Deimos::TestHelpers
#_hash_diff Deimos::TestHelpers
#add_fields Deimos::Message
#around_consume Deimos::Consume::MessageConsumption
#around_consume_batch Deimos::Consume::BatchConsumption
#as_json Deimos::SchemaClass::Base
#as_json Deimos::SchemaClass::Record
#assign_current_offset Deimos::Utils::LagReporter::ConsumerGroup
#assign_current_offset Deimos::Utils::LagReporter::Topic
#assign_key Deimos::ActiveRecordConsume::MessageConsumption
#async_publish Phobos::Producer::PublicAPI
#async_publish Phobos::Producer::ClassMethods::PublicAPI
#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
#compact_messages Deimos::Utils::DbProducer
compacted Deimos::ActiveRecordConsumer
#compute_lag Deimos::Utils::LagReporter::Topic
config Deimos::Producer
#config Deimos::SharedConfig::ClassMethods
#config Deimos::Utils::DbProducer
config_class= Deimos::Utils::MessageBankHandler
configure_producer_or_consumer Deimos
#consume Deimos::Utils::MessageBankHandler
consume Deimos::Utils::InlineConsumer
#consume Deimos::Consume::MessageConsumption
#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
#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::Consumer
#decode_key Deimos::SchemaBackends::Base
#decode_key Deimos::SchemaBackends::Mock
#decode_key Deimos::SchemaBackends::AvroBase
#decode_message Deimos::Consumer
#decode_payload Deimos::SchemaBackends::Base
#decode_payload Deimos::SchemaBackends::Mock
#decode_payload Deimos::SchemaBackends::AvroLocal
#decode_payload Deimos::SchemaBackends::AvroValidation
#decode_payload Deimos::SchemaBackends::AvroSchemaRegistry
#decode_schema Deimos::Utils::SchemaControllerMixin
decoded Deimos::KafkaMessage
#decoded_message Deimos::KafkaMessage
decoder Deimos::Consumer
decoder Deimos::KafkaMessage
#default Deimos::SchemaField
#delete_messages Deimos::Utils::DbProducer
#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::Base
#encode_key Deimos::SchemaBackends::Mock
#encode_key Deimos::SchemaBackends::AvroBase
#encode_payload Deimos::SchemaBackends::Base
#encode_payload Deimos::SchemaBackends::Mock
#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::Producer
#enum_values Deimos::SchemaField
execute Deimos::Backends::Db
execute Deimos::Backends::Base
execute Deimos::Backends::Test
execute Deimos::Backends::Kafka
execute Deimos::Backends::KafkaAsync
#fetch_record Deimos::ActiveRecordConsume::MessageConsumption
#fetch_results Deimos::Utils::DbPoller
field_type Deimos::SchemaBackends::Base
field_type Deimos::SchemaBackends::AvroBase
#finish Deimos::Tracing::Mock
#finish Deimos::Tracing::Datadog
#finish Deimos::Tracing::Provider
full_integration_test! Deimos::TestHelpers
#full_schema Deimos::SchemaClass::Record
#gauge Deimos::Metrics::Mock
#gauge Deimos::Metrics::Datadog
#gauge Deimos::Metrics::Provider
#generate Deimos::Generators::DbPollerGenerator
#generate Deimos::Generators::DbBackendGenerator
#generate Deimos::Generators::SchemaClassGenerator
#generate Deimos::Generators::ActiveRecordGenerator
generate_payload Deimos::ActiveRecordProducer
get_messages_for Deimos::Utils::InlineConsumer
heartbeat Deimos::KafkaTopicInfo
heartbeat Deimos::Utils::LagReporter
#histogram Deimos::Metrics::Mock
#histogram Deimos::Metrics::Datadog
#histogram Deimos::Metrics::Provider
#id Deimos::Utils::DbPoller
#id Deimos::Utils::DbProducer
#id Deimos::Utils::LagReporter::ConsumerGroup
#import_without_validations_or_callbacks Deimos::KafkaSource::ClassMethods
#increment Deimos::Metrics::Mock
#increment Deimos::Metrics::Datadog
#increment Deimos::Metrics::Provider
#initialize Deimos::Message
#initialize Deimos::Metrics::Mock
#initialize Deimos::Tracing::Mock
#initialize Deimos::Metrics::Datadog
#initialize Deimos::Tracing::Datadog
#initialize Deimos::Utils::DbPoller
#initialize Deimos::SchemaClass::Base
#initialize Deimos::Utils::DbProducer
#initialize Deimos::Utils::LagReporter::ConsumerGroup
#initialize Deimos::Utils::LagReporter::Topic
#initialize Deimos::SchemaField
#initialize Deimos::SchemaBackends::Base
#initialize Deimos::ActiveRecordConsumer
#initialize Deimos::SchemaBackends::AvroBase
#initialize Deimos::AvroSchemaCoercer
#initialize Deimos::ActiveRecordConsume::SchemaModelConverter
initialize_from_value Deimos::SchemaClass::Base
initialize_from_value Deimos::SchemaClass::Enum
initialize_from_value Deimos::SchemaClass::Record
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_config Deimos::SharedConfig::ClassMethods
key_decoder Deimos::Consumer
key_encoder Deimos::Producer
#key_schema Deimos::SchemaBackends::Base
#last_updated Deimos::Utils::DbPoller
load_generated_schema_classes Deimos
#load_schema Deimos::SchemaBackends::Base
#load_schema Deimos::SchemaBackends::AvroBase
lock Deimos::KafkaTopicInfo
#log_messages Deimos::Utils::DbProducer
#merge Deimos::SchemaClass::Base
#message= Deimos::KafkaMessage
message_processed Deimos::Utils::LagReporter
#migration_version Deimos::Generators::DbPollerGenerator
#migration_version Deimos::Generators::DbBackendGenerator
mock_backend Deimos::SchemaBackends::Base
mock_backend Deimos::SchemaBackends::AvroBase
#name Deimos::SchemaField
#namespace Deimos::SharedConfig::ClassMethods
#namespace Deimos::SchemaClass::Record
#namespace Deimos::SchemaBackends::Base
#namespace Deimos::Utils::SchemaControllerMixin::ClassMethods
#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::Message
partition_key Deimos::Producer
partition_key_for Deimos::Backends::Db
#payload Deimos::Message
#phobos_config Deimos::PhobosConfig
#phobos_config_file= Deimos::PhobosConfig
#phobos_message Deimos::KafkaMessage
ping_empty_topics Deimos::KafkaTopicInfo
poll_query Deimos::ActiveRecordProducer
#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_batch Deimos::Producer
#produce_messages Deimos::Utils::DbProducer
#producer_name Deimos::Message
producers_disabled? Deimos
publish Deimos::Producer
publish Deimos::Backends::Base
#publish Phobos::Producer::PublicAPI
#publish Phobos::Producer::ClassMethods::PublicAPI
publish_list Deimos::Producer
#record_attributes Deimos::ActiveRecordConsumer
record_class Deimos::ActiveRecordConsumer
record_class Deimos::ActiveRecordProducer
#record_key Deimos::ActiveRecordConsume::BatchConsumption
register_error Deimos::KafkaTopicInfo
#render_schema Deimos::Utils::SchemaControllerMixin
#report_lag Deimos::Utils::LagReporter::ConsumerGroup
#report_lag Deimos::Utils::LagReporter::Topic
#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
#retrieve_topics Deimos::Utils::DbProducer
#save_record Deimos::ActiveRecordConsume::MessageConsumption
#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::AvroBase
#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::TestHelpers
sent_messages Deimos::Backends::Test
#set_error Deimos::Tracing::Mock
#set_error Deimos::Tracing::Datadog
#set_error Deimos::Tracing::Provider
#should_run? Deimos::Utils::DbPoller
shutdown_producer Deimos::Backends::Kafka
#shutdown_producer Deimos::Utils::DbProducer
shutdown_producer Deimos::Backends::KafkaAsync
slice Deimos::ActiveRecordConsume::BatchSlicer
#sql_type Deimos::SchemaBackends::Base
#sql_type Deimos::SchemaBackends::AvroBase
#ssl_var_contents Deimos::PhobosConfig
#start Deimos::Tracing::Mock
#start Deimos::Tracing::Datadog
#start Deimos::Utils::DbPoller
#start Deimos::Tracing::Provider
#start Deimos::Utils::DbProducer
start Deimos::Utils::MessageBankHandler
start! Deimos::Utils::DbPoller
start_db_backend! Deimos
#start_listener Deimos::Utils::SeekListener
#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
#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::Mock
#time Deimos::Metrics::Datadog
#time Deimos::Metrics::Provider
#to_h Deimos::Message
#to_h Deimos::SchemaClass::Base
#to_h Deimos::PhobosConfig
#to_json Deimos::SchemaClass::Base
#to_s Deimos::SchemaClass::Base
#tombstone? Deimos::Message
#topic Deimos::Message
topic Deimos::Producer
#topic_name Deimos::Utils::LagReporter::Topic
#topics Deimos::Utils::LagReporter::ConsumerGroup
#type Deimos::SchemaField
unit_test! Deimos::TestHelpers
#unsubscribe Deimos::Instrumentation::ClassMethods
use? Deimos::Utils::SchemaClass
#validate Deimos::SchemaBackends::Base
#validate Deimos::SchemaBackends::Mock
#validate Deimos::SchemaBackends::AvroBase
validate_consumers Deimos
validate_db_backend Deimos
#validate_listeners! Phobos::CLI::Start
#validator Deimos::SchemaClass::Record
watched_attributes Deimos::Producer
#with_indifferent_access Deimos::SchemaClass::Record
wrap Deimos::Utils::DeadlockRetry