List of all items

Structs

• client::FlashQ
• connection::Connection
• pool::ConnectionPool
• queue::Queue
• types::BatchPushResult
• types::BulkJob
• types::ClientOptions
• types::CronJob
• types::CronOptions
• types::FlowChild
• types::FlowResult
• types::Job
• types::JobCounts
• types::JobPayload
• types::JobWithState
• types::JobsResult
• types::LogEntry
• types::Metrics
• types::ProgressInfo
• types::PushOptions
• types::QueueInfo
• types::QueueMetrics
• types::Stats
• types::WorkerOptions
• worker::Worker

Enums

• errors::FlashQError
• types::JobState
• types::WorkerEvent
• worker::WorkerEventData

Functions

• errors::check_response
• errors::parse_server_error
• validation::validate_batch_size
• validation::validate_queue_name

Type Aliases

• errors::Result
• worker::ProcessorFn

Constants

• constants::CLIENT_TIMEOUT_BUFFER_MS
• constants::DEFAULT_HOST
• constants::DEFAULT_HTTP_PORT
• constants::DEFAULT_MAX_RECONNECT_ATTEMPTS
• constants::DEFAULT_MAX_RECONNECT_DELAY
• constants::DEFAULT_POOL_SIZE
• constants::DEFAULT_PORT
• constants::DEFAULT_PULL_TIMEOUT_MS
• constants::DEFAULT_RECONNECT_DELAY
• constants::DEFAULT_TIMEOUT
• constants::DEFAULT_WORKER_BATCH_SIZE
• constants::DEFAULT_WORKER_CLOSE_TIMEOUT
• constants::DEFAULT_WORKER_CONCURRENCY
• constants::MAX_BATCH_SIZE
• constants::MAX_JOB_DATA_SIZE
• constants::MAX_QUEUE_NAME_LENGTH
• constants::QUEUE_NAME_PATTERN