Table of Contents - phobos-2.1.0 Documentation
Classes and Modules
- Logging
- Logging::Logger
- Phobos
- Phobos::AbortError
- Phobos::Actions
- Phobos::Actions::ProcessBatch
- Phobos::Actions::ProcessBatchInline
- Phobos::Actions::ProcessMessage
- Phobos::BatchHandler
- Phobos::BatchHandler::ClassMethods
- Phobos::BatchMessage
- Phobos::CLI
- Phobos::CLI::Commands
- Phobos::CLI::Runner
- Phobos::CLI::Start
- Phobos::Constants
- Phobos::DeepStruct
- Phobos::EchoHandler
- Phobos::Error
- Phobos::Executor
- Phobos::Handler
- Phobos::Handler::ClassMethods
- Phobos::Instrumentation
- Phobos::Listener
- Phobos::Log
- Phobos::LoggerHelper
- Phobos::Processor
- Phobos::Producer
- Phobos::Producer::ClassMethods
- Phobos::Producer::ClassMethods::PublicAPI
- Phobos::Producer::PublicAPI
- Phobos::Test
- Phobos::Test::Helper
Methods
- ::add_listeners — Phobos
- ::configure — Phobos
- ::create_exponential_backoff — Phobos
- ::create_kafka_client — Phobos
- ::deprecate — Phobos
- ::included — Phobos::BatchHandler
- ::included — Phobos::Handler
- ::included — Phobos::Producer
- ::log — Phobos::LoggerHelper
- ::logger — Phobos::CLI
- ::new — Phobos::Actions::ProcessBatch
- ::new — Phobos::Actions::ProcessBatchInline
- ::new — Phobos::Actions::ProcessMessage
- ::new — Phobos::BatchMessage
- ::new — Phobos::CLI::Runner
- ::new — Phobos::CLI::Start
- ::new — Phobos::DeepStruct
- ::new — Phobos::Executor
- ::new — Phobos::Listener
- ::new — Phobos::Producer::PublicAPI
- ::source_root — Phobos::CLI::Commands
- ::subscribe — Phobos::Instrumentation
- ::unsubscribe — Phobos::Instrumentation
- #== — Phobos::BatchMessage
- #around_consume — Phobos::Handler
- #around_consume_batch — Phobos::BatchHandler
- #async_automatic_delivery? — Phobos::Producer::ClassMethods::PublicAPI
- #async_configs — Phobos::Producer::ClassMethods::PublicAPI
- #async_producer — Phobos::Producer::ClassMethods::PublicAPI
- #async_producer_shutdown — Phobos::Producer::ClassMethods::PublicAPI
- #async_publish — Phobos::Producer::PublicAPI
- #async_publish — Phobos::Producer::ClassMethods::PublicAPI
- #async_publish_list — Phobos::Producer::PublicAPI
- #async_publish_list — Phobos::Producer::ClassMethods::PublicAPI
- #backoff — Phobos::Processor
- #backoff_interval — Phobos::Processor
- #class_producer — Phobos::Producer::PublicAPI
- #compact — Phobos::Listener
- #configure_kafka_client — Phobos::Producer::ClassMethods::PublicAPI
- #consume — Phobos::EchoHandler
- #consume — Phobos::Handler
- #consume_batch — Phobos::BatchHandler
- #consume_each_batch — Phobos::Listener
- #consume_each_batch_inline — Phobos::Listener
- #consume_each_message — Phobos::Listener
- #create_async_producer — Phobos::Producer::ClassMethods::PublicAPI
- #create_exponential_backoff — Phobos::Listener
- #create_kafka_consumer — Phobos::Listener
- #create_sync_producer — Phobos::Producer::ClassMethods::PublicAPI
- #error_exit — Phobos::CLI::Start
- #error_metadata — Phobos::Executor
- #execute — Phobos::Actions::ProcessBatch
- #execute — Phobos::Actions::ProcessBatchInline
- #execute — Phobos::Actions::ProcessMessage
- #execute — Phobos::CLI::Start
- #force_encoding — Phobos::Processor
- #handle_crashed_listener — Phobos::Executor
- #handle_error — Phobos::Processor
- #increment_retry_count — Phobos::Processor
- #init — Phobos::CLI::Commands
- #instantiate_batch_message — Phobos::Actions::ProcessBatchInline
- #instrument — Phobos::Instrumentation
- #kafka_client — Phobos::Producer::ClassMethods::PublicAPI
- #listener_metadata — Phobos::Listener
- #load_boot_file — Phobos::CLI::Start
- #log_debug — Phobos::Log
- #log_error — Phobos::Log
- #log_info — Phobos::Log
- #process_batch — Phobos::Actions::ProcessBatchInline
- #process_message — Phobos::Actions::ProcessMessage
- #process_message — Phobos::Test::Helper
- #produce_messages — Phobos::Producer::ClassMethods::PublicAPI
- #producer — Phobos::Producer
- #producer — Phobos::Producer::ClassMethods
- #producer_store — Phobos::Producer::ClassMethods::PublicAPI
- #publish — Phobos::Producer::PublicAPI
- #publish — Phobos::Producer::ClassMethods::PublicAPI
- #publish_list — Phobos::Producer::PublicAPI
- #publish_list — Phobos::Producer::ClassMethods::PublicAPI
- #regular_configs — Phobos::Producer::ClassMethods::PublicAPI
- #retry_count — Phobos::Processor
- #run! — Phobos::CLI::Runner
- #run_listener — Phobos::Executor
- #send_heartbeat_if_necessary — Phobos::Listener
- #setup_signals — Phobos::CLI::Runner
- #should_stop? — Phobos::Listener
- #snooze — Phobos::Processor
- #start — Phobos::CLI::Commands
- #start — Phobos::Executor
- #start — Phobos::Listener
- #start — Phobos::BatchHandler::ClassMethods
- #start — Phobos::Handler::ClassMethods
- #start_consumer_loop — Phobos::Listener
- #start_listener — Phobos::Listener
- #stop — Phobos::Executor
- #stop — Phobos::Listener
- #stop — Phobos::BatchHandler::ClassMethods
- #stop — Phobos::Handler::ClassMethods
- #stop_listener — Phobos::Listener
- #sync_producer — Phobos::Producer::ClassMethods::PublicAPI
- #sync_producer_shutdown — Phobos::Producer::ClassMethods::PublicAPI
- #to_deep_struct — Phobos::DeepStruct
- #to_h — Phobos::DeepStruct
- #to_hash — Phobos::DeepStruct
- #unblock — Phobos::CLI::Runner
- #validate_config_file! — Phobos::CLI::Start
- #validate_listeners! — Phobos::CLI::Start
- #version — Phobos::CLI::Commands