List of all items

Structs

• backends::kafka::CustomContext
• backends::kafka::KafkaConsumer
• backends::kafka::config::KafkaConfig
• backends::kafka::config::OffsetResetConfig
• backends::kafka::producer::AsyncKafkaProducer
• backends::kafka::producer::KafkaProducer
• backends::kafka::producer::ProducerContext
• backends::kafka::types::Headers
• backends::kafka::types::KafkaPayload
• backends::local::LocalConsumer
• backends::local::LocalProducer
• backends::local::RebalanceNotSupported
• backends::local::broker::LocalBroker
• backends::storages::OffsetOutOfRange
• backends::storages::PartitionDoesNotExist
• backends::storages::TopicDoesNotExist
• backends::storages::TopicExists
• backends::storages::memory::MemoryMessageStorage
• metrics::Metric
• metrics::StatsdRecorder
• processing::Callbacks
• processing::ConsumerState
• processing::InvalidState
• processing::PauseError
• processing::PollError
• processing::ProcessorHandle
• processing::StreamProcessor
• processing::dlq::BufferedMessages
• processing::dlq::DlqLimit
• processing::dlq::DlqLimitState
• processing::dlq::DlqPolicy
• processing::dlq::InvalidMessageStats
• processing::dlq::KafkaDlqProducer
• processing::dlq::NoopDlqProducer
• processing::strategies::CommitRequest
• processing::strategies::InvalidMessage
• processing::strategies::MessageRejected
• processing::strategies::commit_offsets::CommitOffsets
• processing::strategies::healthcheck::HealthCheck
• processing::strategies::noop::Noop
• processing::strategies::produce::Produce
• processing::strategies::reduce::Reduce
• processing::strategies::run_task::RunTask
• processing::strategies::run_task_in_threads::ConcurrencyConfig
• processing::strategies::run_task_in_threads::RunTaskInThreads
• testutils::ProcessingTestStrategy
• testutils::TestFactory
• testutils::TestStrategy
• testutils::TestTopic
• types::AnyMessage
• types::BrokerMessage
• types::Committable
• types::Message
• types::Partition
• types::Topic
• utils::clock::SystemClock
• utils::clock::TestingClock
• utils::timing::Deadline

Enums

• backends::ConsumerError
• backends::ProducerError
• backends::kafka::InitialOffset
• backends::local::broker::BrokerError
• backends::storages::ConsumeError
• metrics::MetricType
• metrics::MetricValue
• processing::RunError
• processing::strategies::StrategyError
• processing::strategies::SubmitError
• processing::strategies::run_task_in_threads::RunTaskError
• types::InnerMessage
• types::TopicOrPartition

Traits

• backends::AssignmentCallbacks
• backends::AsyncProducer
• backends::CommitOffsets
• backends::Consumer
• backends::Producer
• backends::storages::MessageStorage
• metrics::MetricSink
• metrics::Recorder
• processing::dlq::DlqProducer
• processing::strategies::ProcessingStrategy
• processing::strategies::ProcessingStrategyFactory
• processing::strategies::run_task_in_threads::TaskRunner
• utils::clock::Clock

Macros

• counter
• gauge
• metric
• timer

Functions

• metrics::init
• metrics::record_metric
• processing::strategies::merge_commit_request
• testutils::get_default_broker

Type Aliases

• metrics::MetricTags
• processing::strategies::run_task_in_threads::RunTaskFunc