Struct agilulf_driver::MultiAgilulfClient

pub struct MultiAgilulfClient { /* fields omitted */ }

A multi-thread client.

A multi-thread client will open several single-thread clients (called knight) and give them an ID. Any request will be hashed by key and send to corresponding client. As it is a KV server, just keeping operation order consistent of the same key is enough. Note: SCAN is different, this method will affect multiple keys. Guard (just like CPU's Memory Guard) is needed for this operation. Some strategy can be choosed:

1. Any request related before SCAN should have finished, then SCAN, then following requests.

2. Allocate all requests related with SCAN into the same knight, then the order is consistent natually

Methods

impl MultiAgilulfClient

pub async fn connect<'_>(
    address: &'_ str,
    knights_num: usize
) -> Result<MultiAgilulfClient, ClientError>

pub fn allocate_task(&self, command: &Command) -> usize

pub async fn put<'_>(
    &'_ self,
    key: Slice,
    value: Slice
) -> Result<Reply, ClientError>

pub async fn get<'_>(&'_ self, key: Slice) -> Result<Reply, ClientError>

pub async fn delete<'_>(&'_ self, key: Slice) -> Result<Reply, ClientError>

pub async fn scan<'_>(
    &'_ self,
    start: Slice,
    end: Slice
) -> Result<Reply, ClientError>

pub async fn send<'_>(&'_ self, command: Command) -> Result<Reply, ClientError>

pub async fn send_batch<'_>(
    &'_ self,
    commands: Vec<Command>
) -> Result<Vec<Reply>, ClientError>

Trait Implementations

impl Clone for MultiAgilulfClient

fn clone(&self) -> MultiAgilulfClient

Returns a copy of the value.

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

Performs copy-assignment from source.