Struct WorkerScheduler 

pub struct WorkerScheduler { /* private fields */ }

Scheduler backed by a canonical rskit-worker pool configuration.

The scheduler is deterministic and does not create background work by itself. Execution backpressure is enforced by the bounded Pool produced by WorkerScheduler::pool.

Implementations

impl WorkerScheduler

pub fn new(pool_name: impl Into<String>, config: SchedulerConfig) -> Self

Create a scheduler targeting a named worker pool.

pub fn pool<I, O, H>(&self, handler: Arc<H>) -> Pool<I, O>

where I: Send + 'static, O: Clone + Send + 'static, H: Handler<I, O> + 'static,

Create a typed worker pool for the supplied handler.

Trait Implementations

impl Clone for WorkerScheduler

fn clone(&self) -> WorkerScheduler

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WorkerScheduler

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Scheduler for WorkerScheduler

fn schedule<'life0, 'life1, 'async_trait>( &'life0 self, spec: &'life1 TaskSpec, ) -> Pin<Box<dyn Future<Output = AppResult<SchedulingDecision>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Decide where the task should execute.

fn plan_batch<'life0, 'async_trait>( &'life0 self, batch: TaskBatch, ) -> Pin<Box<dyn Future<Output = AppResult<ExecutionPlan>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Build an execution plan for a batch using a task stream.