Struct BidirectionalSync 

pub struct BidirectionalSync { /* private fields */ }

Periodic bidirectional sync orchestrator.

Implementations

impl BidirectionalSync

pub fn new(config: BidirectionalSyncConfig) -> Self

Build a new orchestrator from config.

pub fn with_defaults() -> Self

Convenience constructor with default configuration.

pub fn writer(&self) -> &StateToRdfWriter

Read-only access to the embedded writer (e.g. for inspecting the configured prefix in tests).

pub fn ready(&self) -> bool

Returns true when the configured interval has elapsed since the last sync.

pub fn touch(&mut self)

Manually mark the orchestrator as just-synced (mainly for tests).

pub fn push_state( &mut self, state: &PhysicsState, ) -> PhysicsResult<BidirectionalSyncReport>

Push the supplied state to RDF, returning the SPARQL query the caller should execute. The very first call returns a full snapshot (when initial_full_snapshot is true), subsequent calls return only diffs.

Returns SyncDirection::Skipped when the configured interval has not yet elapsed.

Errors

Returns PhysicsError::Internal when the supplied state is malformed (empty entity IRI).

pub fn pull_state<F>( &mut self, entity_iri: &str, step: u64, fetch_rows: F, ) -> PhysicsResult<BidirectionalSyncReport>

where F: FnOnce(&str, u64) -> PhysicsResult<Vec<RdfPropertyRow>>,

Pull the most recent property rows for entity_iri at step from the supplied closure and re-extract a PhysicsState.

Errors

Bubbles up any error returned by fetch_rows and any failure from the inner extractor.

pub fn reset(&mut self)

Reset internal state so the next push emits a full snapshot again.