Struct caspaxos_kv::Client

pub struct Client {
    pub known_servers: Vec<SocketAddr>,
    pub net: Net,
    pub cache: HashMap<Vec<u8>, CacheEntry>,
    pub processor: Option<Task<Result<()>>>,
}

Fields

known_servers: Vec<SocketAddr>

net: Net

cache: HashMap<Vec<u8>, CacheEntry>

processor: Option<Task<Result<()>>>

Implementations

impl Client

pub async fn ping<'_>(&'_ mut self) -> usize

Send a Ping to the Server, which hopefully will respond with a Pong.

pub async fn get<K: AsRef<[u8]>, '_>(
    &'_ mut self,
    key: K
) -> Result<VersionedValue>

Get the value associated with a key, if any.

pub async fn set<K, V, '_>(
    &'_ mut self,
    key: K,
    value: V
) -> Result<Option<Vec<u8>>> where
    K: AsRef<[u8]>,
    V: AsRef<[u8]>, 

Set a key to a new value. Returns the previous set value.

pub async fn del<K: AsRef<[u8]>, '_>(
    &'_ mut self,
    key: K
) -> Result<Option<Vec<u8>>>

Delete a value associated with a key. Returns the previously set value, if any.

pub async fn cas<K: AsRef<[u8]>, '_>(
    &'_ mut self,
    key: K,
    old: VersionedValue,
    new: Option<Vec<u8>>
) -> Result<Result<VersionedValue, VersionedValue>>

Given a previous versioned value, either set (with Some) or delete (with None) a new value. Returns either Ok(new_version) or Err(current_versioned_value). Returns an error if the old value is not correctly guessed.

Trait Implementations

impl Debug for Client

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

Formats the value using the given formatter.