Struct ActorStore 

pub struct ActorStore { /* private fields */ }

Actor isolated storage handle

Each Actor has an independent SQLite database file, with the path determined by Hyper’s namespace resolver. All read/write operations are confined to this namespace; an Actor cannot access another Actor’s data.

The rusqlite connection is not Send; wrapped in Arc<Mutex<Connection>> for cross-thread sharing. All blocking I/O is offloaded to the blocking thread pool via tokio::task::spawn_blocking.

Implementations

impl ActorStore

pub async fn open(db_path: &Path) -> Result<Self, HyperError>

Open or create an Actor’s SQLite database

Automatically creates the table on first call. Parent directory is created automatically if missing.

pub async fn kv_set(&self, key: &str, value: &[u8]) -> Result<(), HyperError>

Generic KV storage: write or update a key-value pair

pub async fn kv_get(&self, key: &str) -> Result<Option<Vec<u8>>, HyperError>

Generic KV storage: read a key’s value, returns None if the key does not exist

pub async fn kv_delete(&self, key: &str) -> Result<bool, HyperError>

Generic KV storage: delete a key, returns whether a record was actually deleted

pub async fn kv_list_keys( &self, prefix: Option<&str>, ) -> Result<Vec<String>, HyperError>

List all keys, optionally filtered by prefix

pub async fn kv_batch(&self, ops: Vec<KvOp>) -> Result<(), HyperError>

Batch operations (atomic transaction)

All operations execute in a single transaction; if any step fails, all are rolled back.

Trait Implementations

impl Clone for ActorStore

fn clone(&self) -> ActorStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl KvStore for ActorStore

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

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

Read a key’s value, returns None if the key does not exist

fn set<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 str, value: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), PlatformError>> + Send + 'async_trait>>

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

Write or update a key-value pair

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

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

Delete a key, returns whether a record was actually deleted

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

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

List all keys, optionally filtered by prefix

fn batch<'life0, 'async_trait>( &'life0 self, ops: Vec<KvOp>, ) -> Pin<Box<dyn Future<Output = Result<(), PlatformError>> + Send + 'async_trait>>

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

Batch operations (atomic transaction)