Trait channel_loader::task::TaskHandler

pub trait TaskHandler: Default + Send + Sync {
    type Key: Key;
    type Value: Send + Clone + 'static;
    type Error: Send + Clone + 'static;

    const MAX_BATCH_SIZE: i32;

    #[must_use]
    fn handle_task<'async_trait>(
        task: Task<PendingAssignment<Self>>
    ) -> Pin<Box<dyn Future<Output = Task<CompletionReceipt<Self>>> + Send + 'async_trait>>
    where
        Self: 'async_trait;
}

A type-state control flow for driving tasks from pre-assigning to conditional completion. As task-assignment can be deferred until connection acquisition and likewise load tasks can be batched by key, this enables opportunistic batching when connection acquisition becomes a bottleneck and also enables connection yielding as a consequence of work consolidation

Associated Types

type Key: Key

type Value: Send + Clone + 'static

type Error: Send + Clone + 'static

Associated Constants

const MAX_BATCH_SIZE: i32

Required methods

#[must_use]

fn handle_task<'async_trait>(
    task: Task<PendingAssignment<Self>>
) -> Pin<Box<dyn Future<Output = Task<CompletionReceipt<Self>>> + Send + 'async_trait>> where
    Self: 'async_trait, 

Implementors

impl<T> TaskHandler for DieselLoader<T> where
    T: DieselWorker + 'static, 

type Key = T::Key

type Value = T::Value

type Error = SimpleDieselError

const MAX_BATCH_SIZE: i32

fn handle_task<'async_trait>(
    task: Task<PendingAssignment<Self>>
) -> Pin<Box<dyn Future<Output = Task<CompletionReceipt<Self>>> + Send + 'async_trait>> where
    Self: 'async_trait, 

impl<T> TaskHandler for SimpleLoader<T> where
    T: SimpleWorker, 

type Key = T::Key

type Value = T::Value

type Error = T::Error

const MAX_BATCH_SIZE: i32

fn handle_task<'async_trait>(
    task: Task<PendingAssignment<Self>>
) -> Pin<Box<dyn Future<Output = Task<CompletionReceipt<Self>>> + Send + 'async_trait>> where
    Self: 'async_trait,