Trait Backend 

pub trait Backend<Args> {
    type IdType: Clone;
    type Context: Default;
    type Error;
    type Codec;
    type Stream: Stream<Item = Result<Option<Task<Args, Self::Context, Self::IdType>>, Self::Error>>;
    type Beat: Stream<Item = Result<(), Self::Error>>;
    type Layer;

    // Required methods
    fn heartbeat(&self, worker: &WorkerContext) -> Self::Beat;
    fn middleware(&self) -> Self::Layer;
    fn poll(self, worker: &WorkerContext) -> Self::Stream;
}

The Backend trait defines how workers get and manage tasks from a backend.

In other languages, this might be called a “Queue”, “Broker”, etc.

Required Associated Types

type IdType: Clone

The type used to uniquely identify tasks.

type Context: Default

Context associated with each task.

type Error

The error type returned by backend operations

type Codec

The codec used for serialization/deserialization of tasks.

type Stream: Stream<Item = Result<Option<Task<Args, Self::Context, Self::IdType>>, Self::Error>>

A stream of tasks provided by the backend.

type Beat: Stream<Item = Result<(), Self::Error>>

A stream representing heartbeat signals.

type Layer

The type representing backend middleware layer.

Required Methods

fn heartbeat(&self, worker: &WorkerContext) -> Self::Beat

Returns a heartbeat stream for the given worker.

fn middleware(&self) -> Self::Layer

Returns the backend’s middleware layer.

fn poll(self, worker: &WorkerContext) -> Self::Stream

Polls the backend for tasks for the given worker.

Implementors

impl<Args, Ctx, S, TSink, Err> Backend<Args> for Pipe<S, TSink, Args, Ctx>

where S: Stream<Item = Result<Args, Err>> + Send + 'static, TSink: Backend<Args, Context = Ctx> + Sink<Task<Args, Ctx, TSink::IdType>> + Clone + Unpin + Send + 'static, <TSink as Backend<Args>>::Error: Into<BoxDynError> + Send + Sync + 'static, TSink::Beat: Send + 'static, TSink::IdType: Send + Clone + 'static, TSink::Stream: Send + 'static, Args: Send + 'static, Ctx: Send + 'static + Default, Err: Into<BoxDynError> + Send + Sync + 'static, <TSink as Sink<Task<Args, Ctx, TSink::IdType>>>::Error: Into<BoxDynError> + Send + Sync + 'static,

type IdType = <TSink as Backend<Args>>::IdType

type Context = Ctx

type Stream = Pin<Box<dyn Stream<Item = Result<Option<Task<Args, Ctx, <Pipe<S, TSink, Args, Ctx> as Backend<Args>>::IdType>>, PipeError>> + Send>>

type Layer = <TSink as Backend<Args>>::Layer

type Beat = Pin<Box<dyn Stream<Item = Result<(), PipeError>> + Send>>

type Error = PipeError

type Codec = <TSink as Backend<Args>>::Codec

impl<Args, DB, Fetch, Sink, IdType: Clone, E, Ctx: Default, Encode, Config> Backend<Args> for CustomBackend<Args, DB, Fetch, Sink, IdType, Encode, Config>

where Fetch: Stream<Item = Result<Option<Task<Encode::Compact, Ctx, IdType>>, E>> + Send + 'static, Encode: Codec<Args> + Send + 'static, Encode::Error: Into<BoxDynError>, E: Into<BoxDynError>,

type IdType = IdType

type Context = Ctx

type Error = Box<dyn Error + Sync + Send>

type Stream = Pin<Box<dyn Stream<Item = Result<Option<Task<Args, Ctx, IdType>>, Box<dyn Error + Sync + Send>>> + Send>>

type Codec = Encode

type Beat = Pin<Box<dyn Stream<Item = Result<(), <CustomBackend<Args, DB, Fetch, Sink, IdType, Encode, Config> as Backend<Args>>::Error>> + Send>>

type Layer = Identity

impl<Args: 'static + Clone + Send, Ctx: 'static + Default> Backend<Args> for MemoryStorage<Args, Ctx>

type IdType = RandomId

type Context = Ctx

type Error = SendError

type Stream = Pin<Box<dyn Stream<Item = Result<Option<Task<Args, Ctx>>, SendError>> + Send>>

type Layer = Identity

type Beat = Pin<Box<dyn Stream<Item = Result<(), <MemoryStorage<Args, Ctx> as Backend<Args>>::Error>> + Send>>

type Codec = IdentityCodec

impl<Args: 'static + Send + DeserializeOwned + Unpin> Backend<Args> for JsonStorage<Args>

type IdType = RandomId

type Error = SendError

type Context = Map<String, Value>

type Stream = Pin<Box<dyn Stream<Item = Result<Option<Task<Args, Map<String, Value>>>, SendError>> + Send>>

type Layer = AcknowledgeLayer<JsonAck<Args>>

type Beat = Pin<Box<dyn Stream<Item = Result<(), <JsonStorage<Args> as Backend<Args>>::Error>> + Send>>

type Codec = JsonCodec<Value>