Struct Client 

pub struct Client { /* private fields */ }

A remote client for the Celerix Store.

Client implements the CelerixStore trait and communicates with a celerix-stored daemon over TCP. It features automatic reconnection and exponential backoff retries.

Implementations

impl Client

pub async fn connect(addr: &str) -> Result<Self>

Connects to a remote Celerix Store daemon at the specified address.

pub async fn get_generic<T: DeserializeOwned>( &self, persona_id: &str, app_id: &str, key: &str, ) -> Result<T>

Retrieves a type-safe value using generics.

Automatically handles JSON deserialization into the target type.

pub async fn set_generic<T: Serialize>( &self, persona_id: &str, app_id: &str, key: &str, value: T, ) -> Result<()>

Stores a type-safe value using generics.

Automatically handles JSON serialization of the value.

Trait Implementations

impl AppEnumeration for Client

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

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

Lists all available persona IDs.

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

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

Lists all app IDs for a given persona.

impl BatchExporter for Client

fn get_app_store<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, persona_id: &'life1 str, app_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<HashMap<String, Value>>> + Send + 'async_trait>>

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

Returns all key-value pairs for a specific app within a persona.

fn dump_app<'life0, 'life1, 'async_trait>( &'life0 self, app_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<HashMap<String, HashMap<String, Value>>>> + Send + 'async_trait>>

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

Returns data for a specific app across all personas.

impl CelerixStore for Client

fn app(&self, persona_id: &str, app_id: &str) -> Box<dyn AppScope + '_>

Returns an AppScope that simplifies operations by pinning a persona and app.

impl GlobalSearcher for Client

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

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

Finds a key within an app by searching all personas. Returns the value and the persona ID where it was found.

impl KVReader for Client

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

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

Retrieves a value for a specific persona, app, and key.

impl KVWriter for Client

fn set<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, persona_id: &'life1 str, app_id: &'life2 str, key: &'life3 str, value: Value, ) -> 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,

Stores a value for a specific persona, app, and key.

fn delete<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, persona_id: &'life1 str, app_id: &'life2 str, key: &'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,

Deletes a key from a specific persona and app.

impl Orchestrator for Client

fn move_key<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, src_persona: &'life1 str, dst_persona: &'life2 str, app_id: &'life3 str, key: &'life4 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, 'life4: 'async_trait,

Moves a key from one persona to another within the same app.