Struct PostgresStateStore 

pub struct PostgresStateStore { /* private fields */ }

Implementations

impl PostgresStateStore

pub fn new(pool: Pool) -> Self

Trait Implementations

impl StateStore for PostgresStateStore

fn save<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, case_key: &'life1 str, step: &'life2 str, data: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Save or update state for a specific case + step pair.

fn get<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, case_key: &'life1 str, step: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<StateEntry>>> + Send + 'async_trait>>

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

Fetch state for a specific case + step. Returns None if not found.

fn get_all<'life0, 'life1, 'async_trait>( &'life0 self, case_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<StateEntry>>> + Send + 'async_trait>>

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

Fetch all state entries for a case (every step).

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

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

Delete all state entries for a case (cleanup when workflow finishes).

fn save_session<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, session_id: &'life1 str, step: &'life2 str, data: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Save session-scoped state for a specific session + step pair.

fn get_session<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, step: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<SessionStateEntry>>> + Send + 'async_trait>>

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

Fetch session-scoped state for a specific session + step.

fn get_all_session<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<SessionStateEntry>>> + Send + 'async_trait>>

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

Fetch all session-scoped state entries for a session.

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

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

Delete all session-scoped state entries for a session.

fn setup<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Optional: create tables / collections / indexes on first use.