List of all items
Structs
- MessageProperties
- backends::dlq::DeadLetterQueueBackend
- backends::memory::MemoryAckHandle
- backends::memory::MemoryBackend
- backends::resilient::ResilientBackend
- backends::resilient::ResilientBackendBuilder
- batch::BatchConfig
- batch::BatchMetadata
- batch::MessageBatch
- batch::ReceivedBatchMessage
- batch_processor::BatchProcessor
- builder::WorkerPoolBuilder
- dlq::DeadLetterMessage
- dlq::PoisonPillConfig
- dlq::PoisonPillTracker
- health::WorkerHealth
- health::WorkerPoolHealth
- http::HealthEndpoint
- message::Message
- message::MessageMetadata
- message::ReceivedMessage
- metrics::NoOpMetrics
- middleware::MiddlewareChain
- middleware::ack_nack::AckNackMiddleware
- middleware::batch::BatchMiddleware
- middleware::circuit_breaker::CircuitBreakerMiddleware
- middleware::processing_timeout::ProcessingTimeoutMiddleware
- middleware::retry_handler::RetryHandler
- middleware::retry_handler::RetryHandlerConfig
- middleware::tracing::TracingMiddleware
- pool::WorkerPool
- prelude::MessageProperties
- strategies::LeastLoadedBalancer
- strategies::RandomBalancer
- strategies::RoundRobinBalancer
- stress::StressTestConfig
- stress::StressTestResults
Enums
- backends::contract::ReceiveResult
- backends::resilient::ReconnectStrategy
- batch::BatchStatus
- error::WorkerError
- health::HealthStatus
- middleware::MiddlewareResult
- middleware::circuit_breaker::CircuitState
- strategies::LoadBalancingStrategy
- worker::BackoffStrategy
Traits
- backends::contract::MessageBackend
- batch::BatchHandler
- health::HealthCheck
- message::AckHandle
- metrics::WorkerMetrics
- middleware::MessageHandler
- middleware::Middleware
- worker::Worker
Functions
- backends::dlq::create_dlq_message
- stress::run_stability_test
- stress::run_stress_test
- worker::box_worker