Struct RawDataBackend 

pub struct RawDataBackend<B> { /* private fields */ }

Wrapper that skips decoding and works directly with compact representation.

This is useful for backends that natively handle compact types and do not know the types at compile time. Examples include backends that work with raw bytes or JSON values like workflows that manipulate dynamic data.

Implementations

impl<B> RawDataBackend<B>

pub fn new(backend: B) -> Self

Create a new RawDataBackend wrapping the given backend.

Trait Implementations

impl<B> Backend for RawDataBackend<B>

where B: BackendExt,

type Args = <B as BackendExt>::Compact

The type of arguments the backend handles.

type IdType = <B as Backend>::IdType

The type used to uniquely identify tasks.

type Context = <B as Backend>::Context

Context associated with each task.

type Error = <B as Backend>::Error

The error type returned by backend operations

type Stream = <B as BackendExt>::CompactStream

A stream of tasks provided by the backend.

type Beat = <B as Backend>::Beat

A stream representing heartbeat signals.

type Layer = <B as Backend>::Layer

The type representing backend middleware layer.

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.

impl<B: Clone> Clone for RawDataBackend<B>

fn clone(&self) -> RawDataBackend<B>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<B: Debug> Debug for RawDataBackend<B>

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

Formats the value using the given formatter.