Struct InMemoryDurabilityBackend 

pub struct InMemoryDurabilityBackend { /* private fields */ }

In-Memory-Durability-Backend (Default fuer DurabilityKind::Transient).

Implementations

impl InMemoryDurabilityBackend

pub fn new(qos: DurabilityServiceQosPolicy) -> Self

Konstruktor.

pub fn len(&self) -> usize

Anzahl gespeicherter Samples (Diagnose / Tests).

pub fn is_empty(&self) -> bool

True wenn keine Samples gespeichert sind.

Trait Implementations

impl DurabilityBackend for InMemoryDurabilityBackend

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

Persistiert ein Sample.

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

Liefert alle gespeicherten Samples fuer ein Topic in der Reihenfolge ihrer Sequence-Number (sortiert pro Instance).

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

Markiert eine Instance als unregister, sodass nach service_cleanup_delay die zugehoerigen Samples entfernt werden. now ist die aktuelle Wall-Clock; das eigentliche Loeschen passiert spaeter via Self::cleanup.

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

Loescht alle Instanzen, deren unregister-Zeitpunkt + Cleanup- Delay vor now liegt. Liefert die Anzahl entfernter Instanzen.