Struct ServerKvClient 

pub struct ServerKvClient { /* private fields */ }

Server-backed key-value store using HTTP API.

This implementation communicates with a Hubert server via HTTP POST requests.

Example

use bc_components::ARID;
use bc_envelope::Envelope;
use hubert::{KvStore, server::ServerKvClient};

let store = ServerKvClient::new("http://127.0.0.1:45678");
let arid = ARID::new();
let envelope = Envelope::new("Hello, Server!");

// Put envelope (write-once)
store.put(&arid, &envelope, None, false).await.unwrap();

// Get envelope with verbose logging
if let Some(retrieved) = store.get(&arid, None, true).await.unwrap() {
    assert_eq!(retrieved, envelope);
}

Implementations

impl ServerKvClient

pub fn new(base_url: &str) -> Self

Create a new server KV store client.

pub async fn put_with_ttl( &self, arid: &ARID, envelope: &Envelope, ttl_seconds: u64, ) -> Result<String>

👎Deprecated since 0.2.0: Use KvStore::put() with ttl_seconds parameter instead

Put an envelope with a TTL (time-to-live).

Deprecated: Use KvStore::put(arid, envelope, Some(ttl_seconds)) instead.

Trait Implementations

impl KvStore for ServerKvClient

fn put<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, arid: &'life1 ARID, envelope: &'life2 Envelope, ttl_seconds: Option<u64>, verbose: bool, ) -> Pin<Box<dyn Future<Output = Result<String>> + 'async_trait>>

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

Store an envelope at the given ARID.

fn get<'life0, 'life1, 'async_trait>( &'life0 self, arid: &'life1 ARID, timeout_seconds: Option<u64>, verbose: bool, ) -> Pin<Box<dyn Future<Output = Result<Option<Envelope>>> + 'async_trait>>

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

Retrieve an envelope for the given ARID.

fn exists<'life0, 'life1, 'async_trait>( &'life0 self, arid: &'life1 ARID, ) -> Pin<Box<dyn Future<Output = Result<bool>> + 'async_trait>>

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

Check if an envelope exists at the given ARID.