Expand description
Core traits, types, and worker runtime for the kojin task queue.
This crate provides the foundational abstractions: Task, Broker,
Middleware, Worker, and supporting types. Most users should depend
on the kojin facade crate instead.
Re-exports§
pub use backoff::BackoffStrategy;pub use broker::Broker;pub use canvas::Canvas;pub use canvas::WorkflowHandle;pub use canvas::chord;pub use codec::Codec;pub use codec::JsonCodec;pub use context::TaskContext;pub use error::KojinError;pub use error::TaskResult;pub use memory_broker::MemoryBroker;pub use memory_result_backend::MemoryResultBackend;pub use message::TaskMessage;pub use middleware::MetricsMiddleware;pub use middleware::Middleware;pub use middleware::TracingMiddleware;pub use queue_weight::QueueWeight;pub use queue_weight::WeightedQueue;pub use registry::TaskRegistry;pub use result_backend::ResultBackend;pub use signature::Signature;pub use state::TaskState;pub use task::Task;pub use task_id::TaskId;pub use worker::Worker;pub use worker::WorkerConfig;
Modules§
- backoff
- broker
- canvas
- codec
- context
- error
- memory_
broker - memory_
result_ backend - message
- middleware
- queue_
weight - registry
- result_
backend - shutdown
- signature
- state
- task
- task_id
- worker