Struct openvet_common::storage::StorageClient

pub struct StorageClient<Stub = Channel<StorageRequest, StorageResponse>>(/* private fields */);

The client stub that makes RPC calls to the server. All request methods return Futures.

Implementations

impl StorageClient

pub fn new<T>( config: Config, transport: T, ) -> NewClient<Self, RequestDispatch<StorageRequest, StorageResponse, T>>

where T: Transport<ClientMessage<StorageRequest>, Response<StorageResponse>>,

Returns a new client stub that sends requests over the given transport.

impl<Stub> StorageClient<Stub>

where Stub: Stub<Req = StorageRequest, Resp = StorageResponse>,

pub fn ping( &self, ctx: Context, message: String, ) -> impl Future<Output = Result<String, RpcError>> + '_

Ping message, should respond with the same message.

pub fn version( &self, ctx: Context, ) -> impl Future<Output = Result<Version, RpcError>> + '_

Get version of storage server.

pub fn crate_write( &self, ctx: Context, name: CrateInfo, ) -> impl Future<Output = Result<(), RpcError>> + '_

Create a crate, if it does not exist.

pub fn crate_list( &self, ctx: Context, ) -> impl Future<Output = Result<BTreeSet<CrateName>, RpcError>> + '_

Get list of crates

pub fn crate_info( &self, ctx: Context, krate: CrateName, ) -> impl Future<Output = Result<Option<CrateInfo>, RpcError>> + '_

Get full crate info

pub fn object_get( &self, ctx: Context, hash: Checksum, ) -> impl Future<Output = Result<Option<Bytes>, RpcError>> + '_

Get an object

pub fn object_exists( &self, ctx: Context, hash: Checksum, ) -> impl Future<Output = Result<bool, RpcError>> + '_

Check if an object exists

pub fn object_write( &self, ctx: Context, bytes: Bytes, ) -> impl Future<Output = Result<Checksum, RpcError>> + '_

Write an object

pub fn object_gc( &self, ctx: Context, ) -> impl Future<Output = Result<(), RpcError>> + '_

Run garbage collection over objects

pub fn sources_missing( &self, ctx: Context, limit: usize, ) -> impl Future<Output = Result<BTreeSet<CrateVersion>, RpcError>> + '_

List all crate-versions which are missing sources

pub fn crate_tree_write( &self, ctx: Context, krate: CrateVersion, root: Node, ) -> impl Future<Output = Result<(), RpcError>> + '_

Trait Implementations

impl<Stub: Clone> Clone for StorageClient<Stub>

fn clone(&self) -> StorageClient<Stub>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<Stub: Debug> Debug for StorageClient<Stub>

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

Formats the value using the given formatter.

impl<Stub> From<Stub> for StorageClient<Stub>

where Stub: Stub<Req = StorageRequest, Resp = StorageResponse>,

fn from(stub: Stub) -> Self

Returns a new client stub that sends requests over the given transport.