Struct OnDiskDurabilityBackend 

pub struct OnDiskDurabilityBackend { /* private fields */ }

On-Disk-Durability-Backend (DurabilityKind::Persistent).

Layout: <root>/<topic>/<hex(instance_key)>/<sequence>.bin enthaelt den Encoded-Payload; <root>/<topic>/<hex(instance_key)>/.unregistered markiert den Instance-Cleanup-Zeitpunkt (Unix-Nanos als ASCII).

Implementations

impl OnDiskDurabilityBackend

pub fn new<P: Into<PathBuf>>( root: P, qos: DurabilityServiceQosPolicy, ) -> Result<Self>

Konstruktor — erzeugt den Root-Pfad falls nicht vorhanden.

Errors

Filesystem-Fehler beim Anlegen des Roots.

Trait Implementations

impl DurabilityBackend for OnDiskDurabilityBackend

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.