Skip to main content

kojin_core/
lib.rs

1//! Core traits, types, and worker runtime for the kojin task queue.
2//!
3//! This crate provides the foundational abstractions: [`Task`], [`Broker`],
4//! [`Middleware`], [`Worker`], and supporting types. Most users should depend
5//! on the [`kojin`](https://crates.io/crates/kojin) facade crate instead.
6
7pub mod backoff;
8pub mod broker;
9pub mod codec;
10pub mod context;
11pub mod error;
12pub mod memory_broker;
13pub mod message;
14pub mod middleware;
15pub mod queue_weight;
16pub mod registry;
17pub mod result_backend;
18pub mod shutdown;
19pub mod state;
20pub mod task;
21pub mod task_id;
22pub mod worker;
23
24// Re-export key types at crate root
25pub use backoff::BackoffStrategy;
26pub use broker::Broker;
27pub use codec::{Codec, JsonCodec};
28pub use context::TaskContext;
29pub use error::{KojinError, TaskResult};
30pub use memory_broker::MemoryBroker;
31pub use message::TaskMessage;
32pub use middleware::{MetricsMiddleware, Middleware, TracingMiddleware};
33pub use queue_weight::{QueueWeight, WeightedQueue};
34pub use registry::TaskRegistry;
35pub use result_backend::ResultBackend;
36pub use state::TaskState;
37pub use task::Task;
38pub use task_id::TaskId;
39pub use worker::{Worker, WorkerConfig};