Struct StateStore 

pub struct StateStore { /* private fields */ }

Cloneable opaque state-store handle.

Clones share the same store. Bring StateStoreBackend into scope for reads, listing, and transaction creation; transaction behavior is provided by StateTransactionBackend. This handle contains built-ins only.

Examples

use storage_kit::{StateStore, StateStoreBackend, StateTransactionBackend};
use storage_kit::state::config::{StateStoreConfig, LanceStateStoreConfig};
use storage_kit::state::record::{StateKey, StateRecord};
let store = StateStore::connect(StateStoreConfig::lance(LanceStateStoreConfig::memory())).await?;
let shared = store.clone();
let key = StateKey::new("workflow", "run/1")?;
let mut transaction = shared.begin_transaction().await?;
transaction.put(StateRecord::new(key.clone(), serde_json::json!(42))).await?;
transaction.commit().await?;
assert!(store.load(key).await?.is_some());

Implementations

impl StateStore

pub async fn connect(config: StateStoreConfig) -> Result<Self, StateStoreError>

Opens a built-in state store.

Configuration is validated before opening the selected backend. Lance is always available. Redb, PostgreSQL, and SQLite/Turso require redb, postgres, and sqlite, respectively. A disabled implementation returns StateStoreError::InvalidConfig before opening native resources.

Errors

Returns StateStoreError::InvalidConfig for invalid configuration, or the owning I/O, connection, setup, or timeout error when opening fails.

Examples

use storage_kit::{StateStore, StateStoreBackend, StateTransactionBackend};
use storage_kit::state::config::{StateStoreConfig, LanceStateStoreConfig};
use storage_kit::state::record::StateKey;
let store = StateStore::connect(StateStoreConfig::lance(LanceStateStoreConfig::memory())).await?;
assert!(store.load(StateKey::new("workflow", "run/1")?).await?.is_none());

Trait Implementations

impl Clone for StateStore

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StateStore

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

Formats the value using the given formatter.

impl StateStoreBackend for StateStore

type Transaction = StateTransaction

Unique owned transaction returned by this store.

async fn load( &self, key: StateKey, ) -> Result<Option<StateRecordSnapshot>, StateStoreError>

Loads the current non-deleted value for a key.

async fn list( &self, request: StateListRequest, ) -> Result<StateListResponse, StateStoreError>

Lists present records in canonical ascending UTF-8 key order.

async fn begin_transaction(&self) -> Result<Self::Transaction, StateStoreError>

Opens an owned transaction whose successful outcomes are serializable.