Struct StreamAuthorityStore 

pub struct StreamAuthorityStore<P> { /* private fields */ }

Filesystem authority over native hierarchical Streams.

Records, writer epochs, and lineage are child paths changed through one atomic Stream commit. Retry results come from the provider’s native idempotency authority; the adapter owns no side database or shadow operation streams.

Implementations

impl<P> StreamAuthorityStore<P>

pub fn new(provider: Arc<P>) -> Self

Binds one authenticated public Stream provider.

pub fn provider(&self) -> Arc<P>

Returns the exact public Stream provider that supplies this authority.

Higher-level protocol adapters use this only for filesystem-adjacent durable state machines, such as S3 multipart upload sessions. The filesystem authority itself remains represented by canonical Stream records and never by an adapter-local database.

impl<P: StreamProvider> StreamAuthorityStore<P>

pub async fn authorities( &self, maximum: u32, ) -> Result<Vec<AuthorityId>, AuthorityStoreError>

Lists a bounded snapshot of exact filesystem authority identities.

Authorities are native direct children in Stream; no filesystem record or object is read.

Trait Implementations

impl<P: StreamProvider> AsyncAuthorityStore for StreamAuthorityStore<P>

fn supports_generation_lineage_prefix(&self) -> bool

Whether this backend can retain an immutable published-generation lineage prefix when it creates a child authority.

async fn fork_generation_authority( &self, source: GenerationForkSource, destination_authority: AuthorityId, operation_id: OperationId, budget: WorkBudget, cancellation: &CancellationToken, ) -> AuthorityResult<CreateAuthorityOutcome>

Creates a destination authority whose canonical generation lineage is either an immutable native prefix of the source or an explicit independent lineage rooted at an unpublished authenticated generation.

async fn create_authority( &self, authority_id: AuthorityId, genesis_epoch: Epoch, budget: WorkBudget, cancellation: &CancellationToken, ) -> AuthorityResult<CreateAuthorityOutcome>

Asynchronously creates one authority.

async fn head( &self, authority_id: AuthorityId, budget: WorkBudget, cancellation: &CancellationToken, ) -> AuthorityResult<Head>

Asynchronously reads the linearizable head.

async fn compare_and_append( &self, authority_id: AuthorityId, epoch: Epoch, expected: Head, commit: ProposedCommit, budget: WorkBudget, cancellation: &CancellationToken, ) -> AuthorityResult<FsAppendOutcome>

Asynchronously compares and appends one durable operation.

async fn compare_and_append_guarded( &self, request: GuardedAppend, budget: WorkBudget, cancellation: &CancellationToken, ) -> AuthorityResult<FsAppendOutcome>

Asynchronously compares and appends under an optional operation-window permit. Backends that cannot atomically evaluate lease gates reject managed permits rather than using a read-then-write approximation.

async fn reserve_publication( &self, authority_id: AuthorityId, expected: Head, operation_id: OperationId, budget: WorkBudget, cancellation: &CancellationToken, ) -> AuthorityResult<ReservationOutcome>

Atomically acquires the exclusive publication gate at an exact head.

async fn release_publication( &self, reservation: PublicationReservation, budget: WorkBudget, cancellation: &CancellationToken, ) -> AuthorityResult<()>

Releases an exact publication reservation. Exact retries are idempotent.

async fn replay( &self, authority_id: AuthorityId, after: Sequence, limit: ReplayLimit, budget: WorkBudget, cancellation: &CancellationToken, ) -> AuthorityResult<Vec<DurableCommit>>

Asynchronously replays one bounded contiguous page.

async fn fence( &self, authority_id: AuthorityId, expected: Head, budget: WorkBudget, cancellation: &CancellationToken, ) -> AuthorityResult<FenceOutcome>

Asynchronously advances a writer fence.

async fn find_operation( &self, authority_id: AuthorityId, operation_id: OperationId, budget: WorkBudget, cancellation: &CancellationToken, ) -> AuthorityResult<Option<DurableCommit>>

Asynchronously resolves one idempotent operation identity.

impl<P: Clone> Clone for StreamAuthorityStore<P>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.