Struct NamespacedState 

pub struct NamespacedState { /* private fields */ }

A namespaced view over a shared state backend. Use one namespace per workflow instance so identical branch/key names cannot collide.

Implementations

impl NamespacedState

pub fn new(inner: Arc<dyn State>, namespace: impl Display) -> Self

View of inner with every key prefixed by namespace.

pub fn prefix(&self) -> &str

Key prefix.

Trait Implementations

impl State for NamespacedState

fn append<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, item: Value, max_len: Option<usize>, ttl: Option<Duration>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Append item to the list at key, keeping at most max_len entries (oldest dropped first). Creates the list if absent. ttl bounds the key’s lifetime.

fn set<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, value: Value, ttl: Option<Duration>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Set key to value (overwrite), with optional ttl.

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

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

Read key, or None if absent/expired.