List of all items

Structs

• backend::RedisBroker
• backend::RedisInspector
• backend::option::RateLimit
• backend::option::TaskOptions
• backend::pagination::Pagination
• client::Client
• components::aggregator::Aggregator
• components::aggregator::AggregatorConfig
• components::aggregator::GroupAggregatorFunc
• components::forwarder::Forwarder
• components::forwarder::ForwarderConfig
• components::healthcheck::Healthcheck
• components::healthcheck::HealthcheckConfig
• components::heartbeat::Heartbeat
• components::heartbeat::HeartbeatMeta
• components::heartbeat::WorkerEventSender
• components::heartbeat::WorkerInfoEntry
• components::janitor::Janitor
• components::janitor::JanitorConfig
• components::periodic_task_manager::PeriodicTaskConfig
• components::periodic_task_manager::PeriodicTaskManager
• components::periodic_task_manager::PeriodicTaskManagerConfig
• components::processor::CancellationMap
• components::processor::Processor
• components::processor::ProcessorParams
• components::recoverer::Recoverer
• components::recoverer::RecovererConfig
• components::subscriber::Subscriber
• components::subscriber::SubscriberConfig
• config::ClientConfig
• config::ServerConfig
• error::RevokeTaskError
• error::SkipRetryError
• proto::SchedulerEnqueueEvent
• proto::SchedulerEntry
• proto::ServerInfo
• proto::TaskMessage
• proto::WorkerInfo
• scheduler::PeriodicTask
• scheduler::Scheduler
• serve_mux::ServeMux
• server::AsyncHandlerFunc
• server::HandlerFunc
• server::Server
• server::ServerBuilder
• task::DailyStats
• task::QueueInfo
• task::QueueStats
• task::ResultWriter
• task::Task
• task::TaskInfo

Enums

• backend::RedisConnectionType
• backend::option::OptionType
• backend::option::OptionTypeParseError
• backend::option::RateLimitType
• backend::option::RetryPolicy
• base::ServerState
• base::keys::TaskState
• components::heartbeat::WorkerEvent
• components::subscriber::SubscriptionEvent
• error::Error

Traits

• base::Broker
• base::SchedulerBroker
• components::ComponentLifecycle
• components::aggregator::GroupAggregator
• components::periodic_task_manager::PeriodicTaskConfigProvider
• inspector::InspectorTrait
• server::Handler
• task::IntoHeaders
• task::PayloadCodec
• task::ToHashMap

Functions

• base::keys::active_key
• base::keys::aggregating_key
• base::keys::aggregation_set_key
• base::keys::all_aggregation_sets
• base::keys::all_groups
• base::keys::archived_key
• base::keys::completed_key
• base::keys::failed_key
• base::keys::failed_total_key
• base::keys::group_key
• base::keys::group_key_prefix
• base::keys::groups_key
• base::keys::lease_key
• base::keys::paused_key
• base::keys::pending_key
• base::keys::processed_key
• base::keys::processed_total_key
• base::keys::queue_key_prefix
• base::keys::retry_key
• base::keys::scheduled_key
• base::keys::scheduler_entries_key
• base::keys::scheduler_entries_key_with_tenant
• base::keys::scheduler_history_key
• base::keys::server_and_workers_keys
• base::keys::server_info_key
• base::keys::server_info_key_full
• base::keys::server_info_key_full_with_tenant
• base::keys::server_info_key_legacy
• base::keys::server_info_key_with_tenant
• base::keys::task_key
• base::keys::task_key_prefix
• base::keys::unique_key
• base::keys::workers_key
• base::keys::workers_key_full
• base::keys::workers_key_full_with_tenant
• base::keys::workers_key_with_tenant
• config::default_retry_delay
• task::generate_task_id
• task::generate_unique_key

Type Aliases

• backend::Broker
• backend::Inspector
• components::healthcheck::HealthcheckFunc
• config::ErrorHandlerFunc
• config::HealthCheckFunc
• config::RetryDelayFunc
• error::Result
• task::HeaderMap

Constants

• base::constants::DEFAULT_ARCHIVED_EXPIRATION_IN_DAYS
• base::constants::DEFAULT_MAX_ARCHIVE_SIZE
• base::constants::DEFAULT_MAX_RETRY
• base::constants::DEFAULT_QUEUE_NAME
• base::constants::DEFAULT_TIMEOUT
• base::constants::TIME_LAYOUT_YMD
• base::constants::VERSION
• base::keys::AGGREGATING_PREFIX
• base::keys::ALL_QUEUES
• base::keys::ALL_SCHEDULERS
• base::keys::ALL_SERVERS
• base::keys::ALL_WORKERS
• base::keys::CANCEL_CHANNEL
• base::keys::QUEUE_END
• base::keys::QUEUE_PREFIX
• base::keys::QUEUE_START
• base::keys::SCHEDULED_PREFIX
• base::keys::SCHEDULER_EVENTS
• base::keys::SERVERS_PREFIX
• base::keys::TASK_RESULT_PREFIX
• base::keys::WORKERS_PREFIX