List of all items
Structs
- Message
- MessageHeaders
- MessageProperties
- TaskArgs
- auth::MessageSigner
- batch::BatchProcessor
- batch::BatchStats
- batch::MessageBatch
- builder::MessageBuilder
- compression::Compressor
- crypto::MessageEncryptor
- dedup::DedupCache
- dedup::SimpleDedupSet
- embed::CallbackSignature
- embed::EmbedOptions
- embed::EmbeddedBody
- event::EventMessage
- event::TaskEvent
- event::WorkerEvent
- extension_api::ExtendedMessage
- extension_api::ExtensionRegistry
- extension_api::MetricsExtension
- extension_api::RoutingExtension
- extension_api::TelemetryExtension
- extensions::SecureMessageBuilder
- lazy::LazyBody
- lazy::LazyMessage
- lazy::LazyTaskArgs
- middleware::ContentTypeMiddleware
- middleware::MessagePipeline
- middleware::PriorityMiddleware
- middleware::RetryLimitMiddleware
- middleware::SizeLimitMiddleware
- middleware::TaskNameFilterMiddleware
- middleware::ValidationMiddleware
- migration::CompatibilityInfo
- migration::MigrationStep
- migration::ProtocolMigrator
- negotiation::ProtocolCapabilities
- negotiation::ProtocolDetection
- negotiation::ProtocolNegotiator
- pool::MessagePool
- pool::PooledMessage
- pool::PooledTaskArgs
- pool::TaskArgsPool
- priority_queue::MessagePriorityQueue
- priority_queue::MultiLevelQueue
- priority_queue::MultiLevelQueueIter
- priority_queue::PriorityQueueIter
- result::ExceptionInfo
- result::ResultMessage
- retry::RetryPolicy
- retry::RetryStats
- routing::MessageRouter
- routing::PriorityRouter
- routing::RoundRobinRouter
- routing::RoutingRule
- security::ContentTypeWhitelist
- security::SecurityPolicy
- serializer::JsonSerializer
- serializer::SerializerRegistry
- workflow::ChainBuilder
- workflow::Group
- workflow::Workflow
- workflow::WorkflowTask
- zerocopy::MessageHeadersRef
- zerocopy::MessagePropertiesRef
- zerocopy::MessageRef
- zerocopy::TaskArgsRef
Enums
- ContentEncoding
- ContentType
- ProtocolVersion
- ValidationError
- auth::SignatureError
- builder::BuilderError
- compression::CompressionError
- compression::CompressionType
- crypto::EncryptionError
- dedup::DedupKey
- event::EventType
- extension_api::ExtensionValue
- extensions::ExtensionError
- lazy::LazyError
- middleware::MiddlewareError
- migration::MigrationError
- migration::MigrationStrategy
- negotiation::DetectionMethod
- negotiation::NegotiationError
- result::TaskStatus
- retry::RetryStrategy
- security::SecurityError
- serializer::SerializerError
- serializer::SerializerType
Traits
Functions
- batch::group_by
- batch::partition
- builder::delayed_task
- builder::scheduled_task
- builder::task
- builder::task_with_args
- compat::create_python_celery_message
- compat::parse_python_message
- compat::verify_message_format
- compression::auto_decompress
- compression::detect_compression
- dedup::filter_duplicates
- dedup::filter_duplicates_by_content
- embed::format_args
- extension_api::create_default_registry
- migration::create_migration_plan
- negotiation::detect_protocol
- negotiation::detect_protocol_from_bytes
- negotiation::negotiate_protocol
- security::is_unsafe_content_type
- serializer::get_serializer
- utils::can_retry
- utils::clone_with_new_id
- utils::create_retry_message
- utils::exponential_backoff
- utils::filter_by_task
- utils::group_by_task
- utils::is_message_expired
- utils::is_ready_to_execute
- utils::message_age
- utils::sort_by_eta
- utils::sort_by_priority
- utils::time_until_eta
- utils::time_until_expiration
- utils::validate_batch