Struct VersionedStateStore 

pub struct VersionedStateStore { /* private fields */ }

A StateStore that stores one key — the pipeline’s bookmark — in the versioned envelope and passes everything else through. Reads return the stored value; resolving it is the reader’s job (resolve_for_source).

Implementations

impl VersionedStateStore

pub fn new( inner: Arc<dyn StateStore>, key: impl Into<String>, codec: StateCodec, ) -> Self

Version writes of key into inner with codec.

Trait Implementations

impl StateStore for VersionedStateStore

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>, FaucetError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Return the value stored under key, or None if no entry exists.

fn put<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 str, value: &'life2 Value, ) -> Pin<Box<dyn Future<Output = Result<(), FaucetError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Store value under key, replacing any previous entry.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), FaucetError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Remove the entry for key. A missing key is not an error.

fn check<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 CheckContext, ) -> Pin<Box<dyn Future<Output = Result<CheckReport, FaucetError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Run a fast, non-mutating preflight probe (used by faucet doctor).

fn supports_list(&self) -> bool

Whether list can enumerate keys. Every built-in store can; the default is false so a third-party store keeps compiling.

fn list<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, FaucetError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Every stored key that starts with prefix, sorted ascending.

fn supports_atomic_batch(&self) -> bool

Whether put_batch commits all-or-nothing.

fn put_batch<'life0, 'life1, 'async_trait>( &'life0 self, entries: &'life1 [(String, Value)], ) -> Pin<Box<dyn Future<Output = Result<(), FaucetError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Store every entry. When supports_atomic_batch is true either all entries land or none do; the default writes them one by one, so an error can leave a prefix of entries written.