Struct libfrugalos::client::mds::Client

pub struct Client { /* fields omitted */ }

RPCクライアント。

Methods

impl Client

pub fn new(node: RemoteNodeId, rpc_service: RpcServiceHandle) -> Self

新しいClientインスタンスを生成する。

pub fn recommend_to_leader(&self)

RecommendToLeaderRpcを実行する。

pub fn list_objects(
    &self
) -> impl Future<Item = (Option<RemoteNodeId>, Vec<ObjectSummary>), Error = Error>

ListObjectsRpcを実行する。

pub fn latest_version(
    &self
) -> impl Future<Item = (Option<RemoteNodeId>, Option<ObjectSummary>), Error = Error>

GetLatestVersionRpcを実行する。

pub fn object_count(
    &self
) -> impl Future<Item = (Option<RemoteNodeId>, u64), Error = Error>

セグメントが保持しているオブジェクトの数を返す.

pub fn get_object(
    &self,
    id: ObjectId,
    expect: Expect
) -> impl Future<Item = (Option<RemoteNodeId>, Option<Metadata>), Error = Error>

GetObjectRpcを実行する。

pub fn head_object(
    &self,
    id: ObjectId,
    expect: Expect
) -> impl Future<Item = (Option<RemoteNodeId>, Option<ObjectVersion>), Error = Error>

HeadObjectRpcを実行する。

pub fn put_object(
    &self,
    id: ObjectId,
    metadata: Vec<u8>,
    expect: Expect,
    put_content_timeout: Duration
) -> impl Future<Item = (Option<RemoteNodeId>, (ObjectVersion, Option<ObjectVersion>)), Error = Error>

PutObjectRpcを実行する。

pub fn delete_object(
    &self,
    id: ObjectId,
    expect: Expect
) -> impl Future<Item = (Option<RemoteNodeId>, Option<ObjectVersion>), Error = Error>

DeleteObjectRpcを実行する。

pub fn delete_object_by_version(
    &self,
    version: ObjectVersion
) -> impl Future<Item = (Option<RemoteNodeId>, Option<ObjectVersion>), Error = Error>

DeleteObjectByVersionRpcを実行する。

pub fn delete_by_range(
    &self,
    targets: Range<ObjectVersion>
) -> impl Future<Item = (Option<RemoteNodeId>, Vec<ObjectSummary>), Error = Error>

DeleteObjectsByRangeRpcを実行する。

pub fn delete_by_prefix(
    &self,
    prefix: ObjectPrefix
) -> impl Future<Item = (Option<RemoteNodeId>, DeleteObjectsByPrefixSummary), Error = Error>

DeleteObjectsByPrefixRpcを実行する。

Trait Implementations

impl Debug for Client

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

Formats the value using the given formatter.