Struct CoreProvider 

pub struct CoreProvider { /* private fields */ }

Shared provider implementation for live snapshots and recovery replay.

Live instances hold the exact ArcSwap used by crate::SharedGraph. Recovery instances accumulate snapshot sections and WAL changes until CoreProvider::finish_recovery materializes a SeleneGraph.

Implementations

impl CoreProvider

pub fn new_for_live(snapshot: Arc<ArcSwap<SeleneGraph>>) -> Arc<Self>

Construct a live provider bound to a shared graph snapshot pointer.

pub fn new_for_live_with_wal( snapshot: Arc<ArcSwap<SeleneGraph>>, durable: Option<DurableState>, ) -> Arc<Self>

Construct a live provider with optional commit-critical WAL state.

pub fn new_for_recovery() -> Arc<Self>

Construct a recovery-mode provider with an empty accumulator.

pub fn finish_recovery( self: Arc<Self>, expected_graph_id: GraphId, expected_bound_type: Option<Arc<GraphTypeDef>>, ) -> GraphResult<SeleneGraph>

Drain the recovery accumulator into a graph snapshot.

expected_graph_id is the caller-asserted graph identity. If a snapshot’s CORE/META was applied and disagrees with this id, recovery fails. If no CORE/META was applied (WAL-only or empty recovery), expected_graph_id is used directly with default scalar metadata fields.

Errors

Returns crate::GraphError::Provider if this provider was constructed for live mode, if META disagrees with expected_graph_id, or if the accumulated section/changelog state cannot be materialized into graph columns.

Trait Implementations

impl DurableProvider for CoreProvider

fn provider_tag(&self) -> ProviderTag

Stable 4-byte ASCII tag identifying this durable sink.

fn next_timestamp(&self) -> HlcTimestamp

Allocate the timestamp shared by every durable sink for one commit.

fn write_commit( &self, principal: Option<&Arc<[u8]>>, changes: &[Change], timestamp: HlcTimestamp, ) -> Result<u64, ProviderError>

Persist one committed change set before the graph snapshot is published.

fn flush(&self) -> Result<Option<u64>, ProviderError>

Force provider-owned durable state to stable storage.

impl IndexProvider for CoreProvider

fn provider_tag(&self) -> ProviderTag

Stable 4-byte ASCII tag uniquely identifying this provider.

fn read_section( &self, sub_tag: SubTag, bytes: &[u8], ) -> Result<(), ProviderError>

Snapshot bootstrap for one provider-owned section.

fn write_section(&self, sub_tag: SubTag) -> Result<Vec<u8>, ProviderError>

Snapshot publish for one provider-owned section.

fn on_change(&self, change: &Change) -> Result<(), ProviderError>

Observe one committed mutation.

fn declared_sub_tags(&self) -> &[SubTag]

Provider-owned snapshot subsection tags.

fn handles_change_batches(&self) -> bool

Return true when this provider wants one callback per committed change batch.

fn on_changes(&self, changes: &[Change]) -> Result<(), ProviderError>

Observe all changes from one committed mutation batch.

fn rebuild_from_graph(&self, _graph: &SeleneGraph) -> Result<(), ProviderError>

Rebuild provider-owned derived state from a recovered graph snapshot.

fn on_commit_applied(&self, _generation: u64) -> Result<(), ProviderError>

Observe that every change for a committed graph generation was applied.

fn vector_candidate_set( &self, _name: &DbString, _generation: u64, ) -> Result<Option<VectorCandidateSet>, ProviderError>

Return a provider-owned vector candidate set for name at generation.

fn vector_candidate_state_infos( &self, _generation: u64, ) -> Result<Vec<VectorCandidateStateInfo>, ProviderError>

Return provider-owned vector candidate-state descriptors at generation.

impl RecoveryProvider for CoreProvider

fn provider_tag(&self) -> [u8; 4]

Stable four-byte tag identifying this provider in snapshot section tables.

fn read_section(&self, sub: [u8; 4], bytes: &[u8]) -> RecoveryResult<()>

Deliver the already-decompressed bytes of one snapshot section.

fn on_changes(&self, changes: &[Change]) -> RecoveryResult<()>

Deliver one committed WAL entry as a batch. This is the sole entry point WAL replay invokes, and the only required method of the trait.

fn on_change(&self, change: &Change) -> Result<(), Box<dyn Error + Sync + Send>>

Deliver one committed mutation from WAL replay.