Struct Builder 

pub struct Builder<S> { /* private fields */ }

Builds a queue over a Store.

Implementations

impl<S: Store> Builder<S>

pub fn new(store: S) -> Self

Start a builder over store (capacity 1024, Durability::Sync).

pub fn capacity(self, capacity: usize) -> Self

Set the maximum number of unacked items before push blocks. Must be > 0.

pub fn durability(self, durability: Durability) -> Self

Set the durability policy.

pub fn open(self) -> Result<Ends<S>, OpenError<S::Error>>

Open the queue, recovering any items already in the store.

impl<S: Store> Builder<S>

pub fn open_typed<T, C>( self, codec: C, ) -> Result<TypedEnds<S, T, C>, OpenError<S::Error>>

where C: Codec<T> + Clone,

Open a typed queue that encodes values with codec.

Returns a typed producer/consumer pair over the same backend as open; the configured capacity and durability apply unchanged.