Crate rskit_worker 

Bounded async worker pool with streaming events and cooperative cancellation.

Re-exports

pub use bridge::as_provider;

pub use bridge::from_provider;

pub use dispatch::DispatchStrategy;

pub use dispatch::RoundRobinDispatcher;

pub use event::Event;

pub use event::EventKind;

pub use event::Progress;

pub use handler::Handler;

pub use pool::OverflowPolicy;

pub use pool::Pool;

pub use pool::PoolConfig;

pub use pool::PoolStats;

pub use scheduler::ExecutionPlan;

pub use scheduler::ResourceRequirements;

pub use scheduler::Scheduler;

pub use scheduler::SchedulerConfig;

pub use scheduler::SchedulingDecision;

pub use scheduler::TaskBatch;

pub use scheduler::TaskSpec;

pub use scheduler::WorkerScheduler;

pub use task::TaskHandle;

Modules

bridge

Provider/handler bridge adapters for interoperability with rskit-provider. Bridges between Handler and rskit_provider traits.

dispatch

Task dispatch strategies (e.g. round-robin).

event

Event types emitted by tasks during execution.

handler

Handler trait implemented by task executors.

pool

Pool and PoolConfig for managing concurrent task execution. Bounded async worker pool with streaming events and cooperative cancellation.

scheduler

Task specs and scheduling helpers built on the worker pool. Task specs and scheduling helpers built on the worker pool.

task

TaskHandle returned to callers after task submission.