Method List

Classes Methods Files

Search:

#<< Dionysus::Consumer::WorkersGroup
#add_attributes_mapping_for_model Dionysus::Consumer::Config
#add_to_schedule Dionysus::Producer::Outbox::DatadogLatencyReporterScheduler
#aggregate_root? Dionysus::Consumer::DionysusEvent
#app_initialized! Dionysus::Checks::HealthCheck
#app_stopped! Dionysus::Checks::HealthCheck
#as_json Dionysus::Producer::DeletedRecordSerializer
#as_json Dionysus::Producer::ModelSerializer
#assign_attributes_from_dionysus Dionysus::Consumer::SynchronizableModel
#association_name_for_observable Dionysus::Producer::Registry::Registration::Topic::ModelRegistration
attribute Dionysus::Producer::ModelSerializer
attributes Dionysus::Producer::ModelSerializer
#attributes Dionysus::Consumer::Deserializer::DeserializedRecord
#attributes_mapping_for_model Dionysus::Consumer::Config
#attributes_mapping_for_models Dionysus::Consumer::Config
backoff_for Dionysus::Utils::ExponentialBackoff
#calculate Dionysus::Producer::Outbox::LatencyTracker
#call Dionysus::Producer::BaseResponder
call Dionysus::Producer::Outbox::DuplicatesFilter
call Dionysus::Producer::BaseResponder
#call Dionysus::Producer::Outbox::RecordsProcessor
#call Dionysus::Consumer::SyncedData::AssignColumnsFromSyncedData
#call Dionysus::Producer::Outbox::DuplicatesFilter
#call Dionysus::Consumer::ParamsBatchTransformations::RemoveDuplicatesStrategy
#call Dionysus::Producer::Outbox::Producer
#canceled_at Dionysus::Consumer::Deserializer::SerializedRecord
capture_exception Dionysus::Utils::NullErrorHandler
capture_message Dionysus::Utils::NullErrorHandler
#changeset Dionysus::Producer::Outbox::Publishable
check Dionysus::Checks::HealthCheck
check Dionysus::Producer::Outbox::HealthCheck
#check Dionysus::Checks::HealthCheck
#check Dionysus::Producer::Outbox::HealthCheck
#concurrency Dionysus::Consumer::Registry::Registration::Topic
configuration Dionysus::Producer
configuration Dionysus::Consumer
configure Dionysus::Producer
configure Dionysus::Consumer
connection_pool Dionysus::Utils::NullTransactionProvider
#consumer Dionysus::Consumer::Registry::Registration::Topic
#consumer_base_class Dionysus::Consumer::Config
#consumer_base_class Dionysus::Consumer::Registry::Registration::Topic
consumer_registry Dionysus
#consumers Dionysus::Consumer::Registry::Registration
#created Dionysus::Producer::Outbox::EventName
#created? Dionysus::Consumer::DionysusEvent
#created_at Dionysus::Consumer::Deserializer::SerializedRecord
#created_event? Dionysus::Producer::Outbox::Model
#data Dionysus::Consumer::Deserializer
#database_connection_provider Dionysus::Producer::Config
#datadog_statsd_client Dionysus::Producer::Config
declare Dionysus::Producer
declare Dionysus::Consumer
declared_attributes Dionysus::Producer::ModelSerializer
declared_to_many_relationships Dionysus::Producer::ModelSerializer
declared_to_one_relationships Dionysus::Producer::ModelSerializer
#default_partition_key Dionysus::Producer::Config
default_sidekiq_queue Dionysus::Producer::Config
default_sidekiq_queue Dionysus::Consumer::Config
#deserialize Dionysus::Consumer::Deserializer
#deserializer Dionysus::Consumer::Registry::Registration
#deserializer_klass Dionysus::Consumer::Registry::Registration
#deserializer_klass Dionysus::Consumer::Registry::Registration::Topic
#destroyed Dionysus::Producer::Outbox::EventName
#destroyed? Dionysus::Consumer::DionysusEvent
#dionysus_publish_updates_after_soft_delete? Dionysus::Producer::Outbox::ActiveRecordPublishable
enable_outbox_worker_healthcheck Dionysus
enqueue Dionysus::Consumer::SyncedData::AssignColumnsFromSyncedDataJob
enqueue Dionysus::Producer::Genesis::Streamer::BaseJob
#enqueue_batch Dionysus::Utils::SidekiqBatchedJobDistributor
#error Dionysus::Producer::Outbox::Model
#error_handler Dionysus::Producer::Config
#event_bus Dionysus::Consumer::Config
#event_bus Dionysus::Producer::Config
#event_name Dionysus::Consumer::DionysusEvent
#events Dionysus::Monitor
#expected_has_many_relationships Dionysus::Consumer::Deserializer::SerializedRecord
#expected_has_one_relationships Dionysus::Consumer::Deserializer::SerializedRecord
#expiry_time_in_seconds Dionysus::Producer::Outbox::HealthCheck
#expiry_time_in_seconds Dionysus::Checks::HealthCheck
#extensions_block Dionysus::Consumer::Registry::Registration::Topic
#failed? Dionysus::Producer::Outbox::Model
#for_event_type Dionysus::Producer::Outbox::EventName
for_model Dionysus::Utils::NullModelFactory
#generate Dionysus::Consumer::KarafkaConsumerGenerator
#generate Dionysus::Producer::KarafkaResponderGenerator
#generic_event? Dionysus::Consumer::DionysusEvent
#genesis_consistency_safety_delay Dionysus::Producer::Config
#genesis_replica? Dionysus::Producer::Registry::Registration::Topic
#genesis_to_s Dionysus::Producer::Registry::Registration::Topic
#handle_error Dionysus::Producer::Outbox::Model
#has? Dionysus::Consumer::Deserializer::SerializedRecord
#has_canceled_at? Dionysus::Consumer::Deserializer::SerializedRecord
#has_created_at? Dionysus::Consumer::Deserializer::SerializedRecord
has_many Dionysus::Producer::ModelSerializer
#has_many Dionysus::Consumer::Deserializer::DeserializedRecord
#has_one Dionysus::Consumer::Deserializer::DeserializedRecord
has_one Dionysus::Producer::ModelSerializer
#has_synced_canceled_at? Dionysus::Consumer::Deserializer::DeserializedRecord
#has_updated_at? Dionysus::Consumer::Deserializer::SerializedRecord
health_check Dionysus
health_check= Dionysus
#hermes_event_producer Dionysus::Producer::Config
high_priority_sidekiq_queue Dionysus::Producer::Config
#high_priority_sidekiq_queue Dionysus::Producer::Config
#hostname Dionysus::Checks::HealthCheck
#hostname Dionysus::Producer::Outbox::HealthCheck
#id Dionysus::Producer::Outbox::Runner
#id Dionysus::Consumer::Deserializer::SerializedRecord
#ignore_message? Dionysus::Utils::DefaultMessageFilter
#initialize Dionysus::Consumer::Registry::Registration
#initialize Dionysus::Consumer::Registry
#initialize Dionysus::Producer::Genesis::CannotExecuteGenesisForModelThatIsOnlyDependency
#initialize Dionysus::Producer::Genesis
#initialize Dionysus::Consumer::Deserializer::SerializedRecord
#initialize Dionysus::Checks::HealthCheck
#initialize Dionysus::Producer::Outbox::DuplicatesFilter
#initialize Dionysus::Producer::Outbox
#initialize Dionysus::Producer::Genesis::Streamer
#initialize Dionysus::Producer::Outbox::Publisher
#initialize Dionysus::Utils::SidekiqBatchedJobDistributor
#initialize Dionysus::Producer::Outbox::RecordsProcessor
#initialize Dionysus::Producer::ModelSerializer
#initialize Dionysus::Producer::Outbox::DatadogLatencyReporterScheduler
#initialize Dionysus::Consumer::ParamsBatchProcessor
#initialize Dionysus::Producer::Outbox::TombstonePublisher
#initialize Dionysus::Producer::Serializer
#initialize Dionysus::Producer::Registry::Validator
#initialize Dionysus::Consumer::SynchronizableModel
#initialize Dionysus::Producer::Outbox::LatencyTracker
#initialize Dionysus::Producer::Key
#initialize Dionysus::TopicName
#initialize Dionysus::Producer::Outbox::Runner
#initialize Dionysus::Consumer::BatchEventsPublisher
#initialize Dionysus::Utils::DefaultMessageFilter
#initialize Dionysus::Producer::Outbox::Producer
#initialize Dionysus::Producer::Outbox::HealthCheck
#initialize Dionysus::Monitor::UnknownEventError
#initialize Dionysus::Monitor
#initialize Dionysus::Producer::Outbox::Publishable
#initialize Dionysus::Consumer::Persistor
#initialize Dionysus::Consumer::Deserializer::DeserializedRecord
#initialize Dionysus::Consumer::Deserializer
#initialize Dionysus::Producer::BaseResponder
#initialize Dionysus::Producer::Registry::Registration::Topic
#initialize Dionysus::Consumer::WorkersGroup
#initialize Dionysus::Producer::Registry::Registration::Topic::ModelRegistration
#initialize Dionysus::Consumer::DionysusEvent
#initialize Dionysus::Producer::PartitionKey
#initialize Dionysus::Producer::Outbox::EventName
#initialize Dionysus::Producer::Registry::Registration
#initialize Dionysus::Producer::Outbox::DatadogLatencyReporter
#initialize Dionysus::Producer::Registry
#initialize Dionysus::Consumer::Registry::Registration::Topic
#initialize Dionysus::Consumer::SyncedData::AssignColumnsFromSyncedData
initialize_application! Dionysus
inject_routing! Dionysus
#insert_created Dionysus::Producer::Outbox
#insert_destroyed Dionysus::Producer::Outbox
#insert_updated Dionysus::Producer::Outbox
instrument Dionysus::Utils::NullInstrumenter
#instrumenter Dionysus::Producer::Config
#instrumenter Dionysus::Consumer::Config
karafka_application Dionysus
karafka_application= Dionysus
#links Dionysus::Consumer::Deserializer::SerializedRecord
loader Dionysus
#local_changes Dionysus::Consumer::DionysusEvent
lock Dionysus::Utils::NullLockClient
#lock_client Dionysus::Producer::Config
#lock_expiry_time Dionysus::Producer::Config
logger Dionysus
#message Dionysus::Producer::Genesis::CannotExecuteGenesisForModelThatIsOnlyDependency
#message Dionysus::Monitor::UnknownEventError
#message_filter Dionysus::Consumer::Config
#message_filter= Dionysus::Consumer::Config
#message_filters Dionysus::Consumer::Config
#messages_buffer Dionysus::Producer::BaseResponder
#model Dionysus::Consumer::SynchronizableModel
#model Dionysus::Producer::Outbox::Publishable
#model_class Dionysus::Producer::Outbox::Publishable
#model_factory Dionysus::Consumer::Config
#model_klass Dionysus::Producer::Registry::Registration::Topic::ModelRegistration
#model_name Dionysus::Consumer::DionysusEvent
#model_name Dionysus::Producer::Outbox::Publishable
#model_name_for_relationship Dionysus::Consumer::Deserializer::SerializedRecord
#models Dionysus::Producer::Registry::Registration::Topic
monitor Dionysus
#name Dionysus::Producer::Registry::Registration::Topic
#name Dionysus::Consumer::Registry::Registration::Topic
#namespace Dionysus::Producer::Registry::Registration::Topic
#namespace Dionysus::Producer::Registry::Registration
#namespace Dionysus::Producer::Registry
#namespace Dionysus::Consumer::Registry::Registration
#namespace Dionysus::Consumer::Registry
#namespace Dionysus::Consumer::Registry::Registration::Topic
#notify_about_ignored_message Dionysus::Utils::DefaultMessageFilter
#number_of_batches Dionysus::Utils::SidekiqBatchedJobDistributor
#observables_config Dionysus::Producer::Registry::Registration::Topic::ModelRegistration
#observer? Dionysus::Producer::Outbox::Model
observer_topic Dionysus::Producer::Outbox::Model
#observers_inline_maximum_size Dionysus::Producer::Config
observers_with_responders_for Dionysus::Producer
#observes? Dionysus::Producer::Registry::Registration::Topic::ModelRegistration
on_error_occurred Dionysus::Utils::KarafkaDatadogListener
on_error_occurred Dionysus::Utils::KarafkaSentryListener
#options Dionysus::Producer::KarafkaResponderGenerator::NullRegistration
#options Dionysus::Producer::Registry::Registration::Topic::ModelRegistration
#options Dionysus::Producer::Registry::Registration::Topic
#options Dionysus::Consumer::Registry::Registration::Topic
outbox Dionysus::Producer
#outbox_model Dionysus::Producer::Config
outbox_publisher Dionysus::Producer
#outbox_publishing_batch_size Dionysus::Producer::Config
outbox_worker_health_check Dionysus
#outbox_worker_publishing_delay Dionysus::Producer::Config
#outbox_worker_sleep_seconds Dionysus::Producer::Config
#params_batch_transformation Dionysus::Consumer::Registry::Registration::Topic
#partition_key Dionysus::Producer::Registry::Registration::Topic
#perform Dionysus::Producer::Genesis::Streamer::BaseJob
#perform Dionysus::Producer::Genesis::StreamJob
#perform Dionysus::Consumer::SyncedData::AssignColumnsFromSyncedDataJob
#perform Dionysus::Producer::Outbox::DatadogLatencyReporterJob
#persist Dionysus::Consumer::Persistor
#persist_with_dionysus? Dionysus::Consumer::SynchronizableModel
#plain_attributes Dionysus::Consumer::Deserializer::SerializedRecord
#populate_attributes_with_relationship Dionysus::Consumer::Deserializer::DeserializedRecord
#previous_changed_still_visible? Dionysus::Producer::Outbox::Publishable
#previous_changes_canceled? Dionysus::Producer::Outbox::Publishable
#previous_changes_include_canceled? Dionysus::Producer::Outbox::Publishable
#previous_changes_still_canceled? Dionysus::Producer::Outbox::Publishable
#previous_changes_uncanceled? Dionysus::Producer::Outbox::Publishable
#previously_changed? Dionysus::Producer::Outbox::Publishable
#primary_key_attribute Dionysus::Producer::Outbox::Publishable
#process Dionysus::Consumer::ParamsBatchProcessor
#processing_mutex_method_name Dionysus::Consumer::Config
#processing_mutex_provider Dionysus::Consumer::Config
#producer Dionysus::Producer::Registry::Registration::Topic
#producers Dionysus::Producer::Registry::Registration
publish Dionysus::Utils::NullEventBus
#publish Dionysus::Producer::Registry::Registration::Topic
publish Dionysus::Utils::NullHermesEventProducer
#publish Dionysus::Producer::Outbox::Publisher
#publish Dionysus::Consumer::BatchEventsPublisher
#publish_after_commit Dionysus::Producer::Config
#publish_observers Dionysus::Producer::Outbox::Publisher
#publishable_id Dionysus::Producer::Outbox::Publishable
#published? Dionysus::Producer::Outbox::Model
#publisher_service_name Dionysus::Producer::Config
#publishes_model? Dionysus::Producer::Registry::Registration::Topic
#publishing_latency Dionysus::Producer::Outbox::Model
#register_heartbeat Dionysus::Checks::HealthCheck
#register_heartbeat Dionysus::Producer::Outbox::HealthCheck
#registrations Dionysus::Producer::Registry
#registrations Dionysus::Consumer::Registry
#registry Dionysus::Producer::Config
#registry Dionysus::Consumer::Config
registry Dionysus::Consumer
registry Dionysus::Producer
#remove_consecutive_duplicates_before_publishing Dionysus::Producer::Config
#remove_with_dionysus Dionysus::Consumer::SynchronizableModel
#report Dionysus::Producer::Outbox::DatadogLatencyReporter
reset! Dionysus::Producer
reset! Dionysus::Consumer
#resolve_synced_data_hash_proc Dionysus::Consumer::Config
#resource_created_at Dionysus::Producer::Outbox::Model
#resource_name Dionysus::Producer::Outbox::Publishable
responders_for Dionysus::Producer
responders_for_dependency_parent Dionysus::Producer
responders_for_dependency_parent_for_topic Dionysus::Producer
responders_for_model_for_topic Dionysus::Producer
#restorable? Dionysus::Consumer::SynchronizableModel
#restore_with_dionysus Dionysus::Consumer::SynchronizableModel
retry Dionysus::Utils::NullRetryProvider
#retry_provider Dionysus::Consumer::Config
serialize Dionysus::Producer::Serializer
#serialize Dionysus::Producer::Serializer
#serializer Dionysus::Producer::Registry::Registration
#serializer_klass Dionysus::Producer::Registry::Registration::Topic
#serializer_klass Dionysus::Producer::Registry::Registration
service_name Dionysus::Producer::Outbox::DatadogTracer
#sidekiq_backend? Dionysus::Consumer::Registry::Registration::Topic
#sidekiq_queue Dionysus::Producer::Config
#sidekiq_queue Dionysus::Consumer::Config
#sidekiq_worker Dionysus::Consumer::Registry::Registration::Topic
#soft_deletable? Dionysus::Producer::Outbox::Publishable
#soft_delete_column Dionysus::Producer::Config
#soft_delete_strategy Dionysus::Consumer::Config
#soft_deleted? Dionysus::Producer::Outbox::Publishable
#soft_deleted_at_timestamp_attribute Dionysus::Consumer::Config
#start Dionysus::Producer::Outbox::Runner
start_outbox_worker Dionysus::Producer
#stop Dionysus::Producer::Outbox::Runner
#stream Dionysus::Producer::Genesis::Streamer
#stream Dionysus::Producer::Genesis
#subscribe Dionysus::Monitor
suppress! Dionysus::Producer::Suppressor
suppressed? Dionysus::Producer::Suppressor
#synced_at Dionysus::Consumer::SynchronizableModel
#synced_canceled_at Dionysus::Consumer::Deserializer::DeserializedRecord
#synced_canceled_at= Dionysus::Consumer::Deserializer::DeserializedRecord
#synced_created_at Dionysus::Consumer::Deserializer::DeserializedRecord
#synced_created_at= Dionysus::Consumer::Deserializer::DeserializedRecord
#synced_created_at_timestamp_attribute Dionysus::Consumer::Config
#synced_data_attribute Dionysus::Consumer::Config
#synced_id Dionysus::Consumer::Deserializer::DeserializedRecord
#synced_id= Dionysus::Consumer::Deserializer::DeserializedRecord
#synced_id_attribute Dionysus::Consumer::Config
#synced_updated_at Dionysus::Consumer::Deserializer::DeserializedRecord
#synced_updated_at= Dionysus::Consumer::Deserializer::DeserializedRecord
#synced_updated_at_timestamp_attribute Dionysus::Consumer::Config
#time_per_batch Dionysus::Utils::SidekiqBatchedJobDistributor
#to_h Dionysus::Consumer::DionysusEvent
#to_key Dionysus::Producer::PartitionKey
#to_key Dionysus::Producer::Key
#to_s Dionysus::Producer::Registry::Registration::Topic
#to_s Dionysus::Consumer::Registry::Registration::Topic
#to_s Dionysus::TopicName
#tombstone Dionysus::Producer::Outbox::TombstonePublisher
topic Dionysus::Producer::BaseResponder
#topic Dionysus::Producer::Registry::Registration
#topic Dionysus::Consumer::Registry::Registration
#topics Dionysus::Producer::Outbox::Publishable
topics Dionysus::Producer::BaseResponder
#topics Dionysus::Producer::Registry::Registration
#topics Dionysus::Consumer::Registry::Registration
topics_models_mapping Dionysus::Producer
trace Dionysus::Utils::NullTracer
#trace Dionysus::Producer::Outbox::DatadogTracer
transaction Dionysus::Utils::NullTransactionProvider
#transaction_provider Dionysus::Producer::Config
#transaction_provider Dionysus::Consumer::Config
#transactional_outbox_enabled Dionysus::Producer::Config
#transformed_changeset Dionysus::Producer::Outbox::Model
#transformed_data Dionysus::Consumer::DionysusEvent
#transformed_payload Dionysus::Consumer::Deserializer::DeserializedRecord
unsuppress! Dionysus::Producer::Suppressor
#updated Dionysus::Producer::Outbox::EventName
#updated? Dionysus::Consumer::DionysusEvent
#updated_at Dionysus::Consumer::Deserializer::SerializedRecord
#updated_event? Dionysus::Producer::Outbox::Model
#validate_columns Dionysus::Producer::Registry::Validator
#visible? Dionysus::Producer::Outbox::Publishable
with_connection Dionysus::Utils::NullTransactionProvider
with_lock Dionysus::Utils::NullMutexProvider
#work Dionysus::Consumer::WorkersGroup
#worker_stopped Dionysus::Producer::Outbox::HealthCheck