Struct InMemoryDurabilityBackend 

pub struct InMemoryDurabilityBackend { /* private fields */ }

In-memory durability backend (default for DurabilityKind::Transient).

Implementations

impl InMemoryDurabilityBackend

pub fn new(qos: DurabilityServiceQosPolicy) -> Self

Constructor.

pub fn len(&self) -> usize

Number of stored samples (diagnostics / tests).

pub fn is_empty(&self) -> bool

True if no samples are stored.

Trait Implementations

impl DurabilityBackend for InMemoryDurabilityBackend

fn store(&self, sample: DurabilitySample) -> Result<()>

Persists a sample.

fn replay_for_topic(&self, topic: &str) -> Result<Vec<DurabilitySample>>

Returns all stored samples for a topic in order of their sequence number (sorted per instance).

fn unregister_instance( &self, topic: &str, instance_key: [u8; 16], now: SystemTime, ) -> Result<()>

Marks an instance as unregister so that its associated samples are removed after service_cleanup_delay. now is the current wall clock; the actual deletion happens later via Self::cleanup.

fn cleanup(&self, now: SystemTime) -> Result<usize>

Deletes all instances whose unregister timestamp + cleanup delay is before now. Returns the number of removed instances.