Struct MetaPeerClient

pub struct MetaPeerClient {
    election: Option<ElectionRef>,
    in_memory: ResettableKvBackendRef,
    channel_manager: ChannelManager,
    max_retry_count: usize,
    retry_interval_ms: u64,
}

Fields

election: Option<ElectionRef>

in_memory: ResettableKvBackendRef

channel_manager: ChannelManager

max_retry_count: usize

retry_interval_ms: u64

Implementations

impl MetaPeerClient

async fn get_dn_key_value(&self, keys_only: bool) -> Result<Vec<KeyValue>>

pub async fn get_all_dn_stat_kvs( &self, ) -> Result<HashMap<DatanodeStatKey, DatanodeStatValue>>

pub async fn get_node_cnt(&self) -> Result<i32>

pub async fn get_dn_stat_kvs( &self, keys: Vec<DatanodeStatKey>, ) -> Result<HashMap<DatanodeStatKey, DatanodeStatValue>>

async fn remote_range( &self, key: Vec<u8>, range_end: Vec<u8>, keys_only: bool, ) -> Result<RangeResponse>

async fn remote_batch_get(&self, keys: Vec<Vec<u8>>) -> Result<BatchGetResponse>

pub(crate) fn is_leader(&self) -> bool

Trait Implementations

impl KvBackend for MetaPeerClient

fn name(&self) -> &str

fn as_any(&self) -> &dyn Any

fn range<'life0, 'async_trait>( &'life0 self, req: RangeRequest, ) -> Pin<Box<dyn Future<Output = Result<RangeResponse>> + Send + 'async_trait>>

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

fn put<'life0, 'async_trait>( &'life0 self, _req: PutRequest, ) -> Pin<Box<dyn Future<Output = Result<PutResponse>> + Send + 'async_trait>>

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

fn batch_put<'life0, 'async_trait>( &'life0 self, _req: BatchPutRequest, ) -> Pin<Box<dyn Future<Output = Result<BatchPutResponse>> + Send + 'async_trait>>

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

fn batch_get<'life0, 'async_trait>( &'life0 self, req: BatchGetRequest, ) -> Pin<Box<dyn Future<Output = Result<BatchGetResponse>> + Send + 'async_trait>>

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

fn delete_range<'life0, 'async_trait>( &'life0 self, _req: DeleteRangeRequest, ) -> Pin<Box<dyn Future<Output = Result<DeleteRangeResponse>> + Send + 'async_trait>>

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

fn batch_delete<'life0, 'async_trait>( &'life0 self, _req: BatchDeleteRequest, ) -> Pin<Box<dyn Future<Output = Result<BatchDeleteResponse>> + Send + 'async_trait>>

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

fn compare_and_put<'life0, 'async_trait>( &'life0 self, _req: CompareAndPutRequest, ) -> Pin<Box<dyn Future<Output = Result<CompareAndPutResponse>> + Send + 'async_trait>>

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

CAS: Compares the value at the key with the given value, and if they are equal, puts the new value at the key.

fn put_conditionally<'life0, 'async_trait>( &'life0 self, _key: Vec<u8>, _value: Vec<u8>, _if_not_exists: bool, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Puts a value at a key. If if_not_exists is true, the operation ensures the key does not exist before applying the PUT operation. Otherwise, it simply applies the PUT operation without checking for the key’s existence.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, _key: &'life1 [u8], _prev_kv: bool, ) -> Pin<Box<dyn Future<Output = Result<Option<KeyValue>>> + Send + 'async_trait>>

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

Returns previous key-value pair if prev_kv is true.

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<Option<KeyValue>, Self::Error>> + Send + 'async_trait>>

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

fn exists<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<bool, Self::Error>> + Send + 'async_trait>>

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

Check if the key exists, not returning the value. If the value is large, this method is more efficient than get.

impl TxnService for MetaPeerClient

type Error = Error

fn txn<'life0, 'async_trait>( &'life0 self, _txn: Txn, ) -> Pin<Box<dyn Future<Output = Result<TxnResponse, Self::Error>> + Send + 'async_trait>>

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

fn max_txn_ops(&self) -> usize

Maximum number of operations permitted in a transaction.