Struct InMemoryConfig 

pub struct InMemoryConfig { /* private fields */ }

Implementations

impl InMemoryConfig

pub fn with_deduplication_window(self, window: Duration) -> Self

Sets the message-id deduplication window for this bus’s single stream. Use the production stream’s window to reproduce its retry behavior.

pub fn with_stream_ack_wait(self, ack_wait: Duration) -> Self

How long a stream delivery may stay unsettled before another cursor on the same durable receives it again; applies to every durable.

pub fn with_durable(self, owner: DurableOwner<'_>) -> Self

Creates the owner’s durable, as ck-bus would before any cursor binds.

Panics

When the owner’s id is not a valid agent or module id token: the fixture would otherwise hold a durable no cursor can bind.

pub fn deny_subject(self, subject: impl Into<String>) -> Self

pub fn with_work_queue(self, config: WorkQueueConfig) -> Self

Trait Implementations

impl Clone for InMemoryConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryConfig

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

Formats the value using the given formatter.

impl Default for InMemoryConfig

fn default() -> Self

Returns the “default value” for a type.