Struct NamespaceCommitEngine 

pub struct NamespaceCommitEngine { /* private fields */ }

Implementations

impl NamespaceCommitEngine

pub fn new(namespace_id: NamespaceId) -> Self

pub fn writer_session(self, session: SharedWriterSessionState) -> Self

Attaches the runtime’s session state for this namespace, so the acquired epoch and fencing outlive this engine instance.

pub fn table_cache(self, table_cache: Arc<MetadataTableCache>) -> Self

pub fn invalidate(&mut self)

pub fn retained_tail_weight(&self) -> Option<PublishTailWeight>

What the tail projection this engine retains weighs, or None when it retains none.

A runtime holding one engine per namespace bounds its total retention with this; the per-projection ceiling in PublishTailOptions only bounds one.

pub async fn delete_namespace<S: ObjectStore + ?Sized>( &mut self, store: &S, options: DeleteNamespaceOptions, context: &MutationContext, ) -> Result<DeleteNamespaceResponse, Error>

Deletes the namespace through this session (format spec, “Tombstones and deletion”).

Deletion is a head-advancing write, so it takes the same session gate as Self::publish_batch: a fenced session is refused terminally without touching the store, and the epoch acquired for publishing is the epoch the tombstone swap is fenced by. A takeover observed by the swap fences this session for good.

pub async fn publish_batch<S: ObjectStore + ?Sized>( &mut self, store: &S, candidates: Vec<CommitCandidate>, context: &MutationContext, tail_options: &PublishTailOptions, ) -> NamespaceCommitEnginePublishResult

Trait Implementations

impl Clone for NamespaceCommitEngine

fn clone(&self) -> NamespaceCommitEngine

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for NamespaceCommitEngine

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.