Struct ReplicationService 

pub struct ReplicationService<'a> { /* private fields */ }

Backend-neutral replication operations over a Thingd store.

Implementations

impl<'a> ReplicationService<'a>

pub fn new(engine: &'a mut dyn ThingStore, config: ReplicationConfig) -> Self

Create a service over an existing in-memory or persistent engine.

pub const fn config(&self) -> &ReplicationConfig

Return the service configuration.

pub fn record_object_upsert( &mut self, object: &MemoryObject, ) -> ThingdResult<()>

Record an object upsert in the durable source feed.

Errors

Returns an error if the service is not configured as a source or the durable replication event cannot be appended.

pub fn record_object_delete( &mut self, collection: &str, id: &str, ) -> ThingdResult<()>

Record an object deletion in the durable source feed.

Errors

Returns an error if the service is not configured as a source or the durable replication event cannot be appended.

pub fn record_event_append(&mut self, event: &MemoryEvent) -> ThingdResult<()>

Record an application event in the durable source feed.

Errors

Returns an error if the service is not configured as a source or the durable replication event cannot be appended.

pub fn record_change(&mut self, change: &Value) -> ThingdResult<()>

Record a provider-neutral change payload in the source feed.

This is the escape hatch for transports that already construct the public operation envelope. Prefer the typed record_* methods for native callers.

Errors

Returns an error if the service is not configured as a source or the durable replication event cannot be appended.

pub fn events( &mut self, after: u64, limit: u64, ) -> ThingdResult<ReplicationPage>

Read a source page after a cursor.

Errors

Returns an error when the cursor has fallen outside the retained replication event window or the event store cannot be read.

pub fn snapshot(&mut self) -> ThingdResult<ReplicationSnapshot>

Create a source snapshot containing only replicable data.

Errors

Returns an error when the object or event stores cannot be read.

pub fn apply( &mut self, changes: &[ReplicationChange], ) -> ThingdResult<ReplicationApplyResult>

Apply a source batch to a replica store.

Errors

Returns an error for source-role stores, malformed changes, conflicts, or durable storage failures.

pub fn apply_snapshot( &mut self, snapshot: &ReplicationSnapshot, replace: bool, ) -> ThingdResult<ReplicationApplyResult>

Apply a bootstrap snapshot to a replica.

Errors

Returns an error for source-role stores, conflicts, or durable storage failures.

pub fn status(&mut self) -> ThingdResult<ReplicationStatus>

Return status for the configured source/replica.

Errors

Returns an error when replication state cannot be read.

pub fn conflicts(&mut self) -> ThingdResult<Vec<MemoryObject>>

List durable quarantined conflicts.

Errors

Returns an error when the conflict collection cannot be read.