Module store 

Re-exports

pub use materialization_models::activated_merge_membership_remote_objects;

pub use materialization_models::DeviceJoinBootstrapCommit;

pub use materialization_models::DeviceJoinBootstrapPlan;

pub use materialization_models::DeviceJoinBootstrapRowData;

pub use materialization_models::InstalledReplayBaseline;

pub use materialization_models::MembershipAuthorityBytes;

pub use materialization_models::OwnedVerifiedMergeMaterialization;

pub use materialization_models::PreparedMergeMaterialization;

pub use materialization_models::PreparedMergeMaterializationPackage;

pub use materialization_models::ResolvedDeviceJoinBootstrap;

pub use materialization_models::RetainedAudiencePackage;

pub use materialization_models::RetainedMergeHistoryCheckpoint;

pub use materialization_models::RetainedMergeMaterializationKey;

pub use materialization_models::RetainedPackageApplication;

pub use materialization_models::VerifiedMergeMaterialization;

pub use materialization_models::VerifiedMergeMembershipObjects;

pub use materialization_models::VerifiedStoreSnapshotAuthority;

pub use publication_state::StorePublicationPreparation;

pub use publication_state::StoreWritePreparation;

Modules

candidate_records

device_join_journal

The adjacency rules the device-join journal’s compare-and-swap update enforces between recorded steps, and the failures a journal write reports.

local_blob_cleanup_intents

Durable deletion of obsolete logical-source and exact-locator copies.

materialization_models

publication_state

reclaim

Structs

AcceptedStoreCommitEvidence

AcceptedStoreCommitPublication

AcceptedStorePublicationInterval

AdvancedReplayBaseline

What one advancement retired, for the reclaim report that follows it.

ApplyResult

Result of applying a changeset.

BlobFileFailure

A local blob file that failed to unwind after a host write failed. Names the blob so a host learns which files are left behind, not just that some were.

BlobFileFailures

Every blob that failed to unwind, in the order they were attempted.

BlobUploadDrainPermit

This drain’s exclusive turn over the blob upload queue, held from reading the pending entries through the last attempt admitted from that read.

CandidateCleanupObject

CircleAckPublicationInput

Everything one active Circle contributes to staging its device’s next Circle acknowledgement: the exact control and epoch the live projection derives from, the access authority that seals the acknowledgement, and the retained bootstrap coverage the projection was seeded from (None for a founder/source device).

CloudOutboxSnapshot

CoveredStoreWrite

A reserved logical write included in the installed snapshot, without an assertion about which of its exact candidates was accepted.

CoveredStoreWriteCompletion

Cleanup still belongs to the reserved write until its exact remote objects and local spools have been retired and the receipt commits atomically.

CreatedSnapshot

DeviceExclusionPermit

DeviceJoinJournalStore

The joining device’s own journal of in-flight join attempts, kept in its own SQLite file under the stores root because the Store database it is joining does not exist yet while the attempt runs.

HostWriteBlobTransaction

HostWriteOperation

LocalBlobCleanup

LocalBlobCleanupPermit

MakeRemoteAdmission

MaterializedLocalBlob

MembershipLoadPermit

MembershipMutationPermit

ObservedStorePublication

OutboxEntry

OutboxFailure

OwnStreamAuthorship

This device’s exclusive turn to author its own next Store commit, held from reading the position through publishing the head that takes it.

PreparedStoreSnapshot

A closed, migrated snapshot image and the directory owning its payloads. Installation opens the image only within the receiving database operation.

QueuedDelete

One cloud object the durable queue is holding a tombstone for.

QueuedMakeRemote

QueuedUpload

One upload the durable cloud queue is holding, as a host renders it.

RetainedReplayBaseline

The database image a replay starts from, and the authority that says which history it covers.

RetainedReplayGenesisAuthority

SnapshotBlobFact

SnapshotDatabaseImage

One uncommitted SQLite image and its sidecar files.

SnapshotPublicationPermit

SqlContext

Host SQL inside one journaled write transaction.

SqlReadContext

Host SQL against Coven’s retained database connection.

StoreCreationPermit

StoreDatabase

Store operations backed by one owned database.

StoreReads

Application reads over owned read-only connections, with a separate bounded executor for processing owned results after their transaction ends.

StoreRowWrites

StuckReclaimOperation

A journalled reclaim operation whose last run failed with an error that running it again cannot change.

TableSchema

Schema info for all synced tables: maps table name to column indices. Built once before an apply and moved (owned) into the conflict closure, which must be 'static.

ValidatedChangeset

Changeset bytes paired with the exact synced schema that validated their row identities. Construction is the one identity-validation boundary; apply only accepts this type, so callers cannot parse once for classification and then parse the same bytes again during mutation.

WinningRow

WriteBatch

Enums

BlobTransitionRoot

BlockedWriteDiscard

CirclePackageAccess

Package keys resolved against the installed state and verified prepared controls. Successor keys still require the historical roster to authorize the package author.

DurableStoreReclaimObject

DurableStoreReclaimOperation

HostWriteError

IncomingTimestampPolicy

MakeRemoteProgress

How far a gated root’s make-remote transition has got, as its durable intent records it. The write id a publication carries is bookkeeping the transition owns, so it is not part of this.

OutboxFailureKind

OutboxOperation

OutboxUploadState

PayloadStoreError

PostUpload

QueuedUploadPhase

ReclaimedStorePackage

RetainedReplayAuthority

SnapshotImageError

SnapshotImageOperationError

StoreCommitPublicationOutcome

Whether this publisher advanced the provider or found its commit already installed.

StorePublicationBoundary

An installed accepted prefix may be handed to a joining device without a provider observation. Only an observed boundary can start a conditional write.

StoreReclaimJournalError

Traits

AudienceBlobMoveStaging

Capturing immutable blob sources or materializing a Local destination needs the connected owner replication composes. The capture transaction names only this port; the returned rollback closure is consumed on failure.

Functions

audience_moves_by_row

projection_table_names

resolve_and_apply_changeset

Apply bytes to conn, resolving column and row conflicts, building the TableSchema from tables once. A convenience wrapper over resolve_and_apply_changeset_with_schema for callers that apply a single changeset and don’t already hold a schema (tests, snapshot round-trips).

Type Aliases

PreparedCircleObjects

The stored bytes of one operation’s objects, supplied alongside the operation that names them so the database can install the bytes and their owner claims at the same durable boundary.

StagedAudienceBlobRollback

Rolls back the staged audience blob files after a failed capture, folding any cleanup failure into the operation error it returns.