Skip to main content

Module store

Module store 

Source

Re-exports§

pub use materialization_models::activated_merge_membership_remote_objects;
pub use materialization_models::DeviceJoinBootstrapActivation;
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::VerifiedAcknowledgedStoreSnapshot;
pub use materialization_models::VerifiedMergeMaterialization;
pub use materialization_models::VerifiedMergeMembershipObjects;
pub use materialization_models::VerifiedReplayBaselineRetirementProof;
pub use materialization_models::VerifiedStoreSnapshotAuthority;
pub use publication_state::MergeCandidateAbandonmentPreparation;
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§

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
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.
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.
ReclaimCommitActivation
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.
StoreReclaimCandidateLoss
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§

AuthorExclusionLocatorTamper
BlobTransitionRoot
BlockedWriteDiscard
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
SnapshotBlobAudience
SnapshotImageError
SnapshotImageOperationError
StoreReclaimJournalError

Constants§

GENERATION_ZERO

Traits§

AudienceBlobMoveStaging
Staging audience-move blobs into the spool needs the connected staging 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 conflicts (premerge + row arbitration), 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).
select_author_exclusion_activation_locator

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.