Struct RemoteMDBXClient

pub struct RemoteMDBXClient<Stub = Channel<RemoteMDBXRequest, RemoteMDBXResponse>>(/* private fields */);

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

Implementations

impl RemoteMDBXClient

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

where T: Transport<ClientMessage<RemoteMDBXRequest>, Response<RemoteMDBXResponse>>,

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

impl<Stub> RemoteMDBXClient<Stub>

where Stub: Stub<Req = RemoteMDBXRequest, Resp = RemoteMDBXResponse>,

pub fn open_env( &self, ctx: Context, path: PathBuf, builder: RemoteEnvironmentConfig, ) -> impl Future<Output = Result<Result<u64, ServerError>, RpcError>> + '_

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

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

pub fn env_sync( &self, ctx: Context, env: u64, force: bool, ) -> impl Future<Output = Result<Result<bool, ServerError>, RpcError>> + '_

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

pub fn env_stat( &self, ctx: Context, env: u64, ) -> impl Future<Output = Result<Result<Stat, ServerError>, RpcError>> + '_

pub fn env_info( &self, ctx: Context, env: u64, ) -> impl Future<Output = Result<Result<Info, ServerError>, RpcError>> + '_

pub fn tx_create_db( &self, ctx: Context, env: u64, tx: u64, db: Option<String>, flags: u32, ) -> impl Future<Output = Result<Result<u32, ServerError>, RpcError>> + '_

pub fn tx_get( &self, ctx: Context, env: u64, tx: u64, dbi: u32, key: Vec<u8>, ) -> impl Future<Output = Result<Result<Option<Vec<u8>>, ServerError>, RpcError>> + '_

pub fn tx_put( &self, ctx: Context, env: u64, tx: u64, dbi: u32, key: Vec<u8>, value: Vec<u8>, flags: u32, ) -> impl Future<Output = Result<Result<(), ServerError>, RpcError>> + '_

pub fn tx_del( &self, ctx: Context, env: u64, tx: u64, dbi: u32, key: Vec<u8>, value: Option<Vec<u8>>, ) -> impl Future<Output = Result<Result<bool, ServerError>, RpcError>> + '_

pub fn tx_ro_cursor( &self, ctx: Context, env: u64, tx: u64, dbi: u32, ) -> impl Future<Output = Result<Result<u64, ServerError>, RpcError>> + '_

pub fn tx_rw_cursor( &self, ctx: Context, env: u64, tx: u64, dbi: u32, ) -> impl Future<Output = Result<Result<u64, ServerError>, RpcError>> + '_

pub fn tx_commit( &self, ctx: Context, env: u64, tx: u64, ) -> impl Future<Output = Result<Result<(bool, CommitLatency), ServerError>, RpcError>> + '_

pub fn tx_abort( &self, ctx: Context, env: u64, tx: u64, ) -> impl Future<Output = Result<Result<(), ServerError>, RpcError>> + '_

pub fn tx_nested( &self, ctx: Context, env: u64, tx: u64, ) -> impl Future<Output = Result<Result<u64, ServerError>, RpcError>> + '_

pub fn tx_db_stat( &self, ctx: Context, env: u64, tx: u64, dbi: u32, ) -> impl Future<Output = Result<Result<Stat, ServerError>, RpcError>> + '_

pub fn clear_db( &self, ctx: Context, env: u64, tx: u64, dbi: u32, ) -> impl Future<Output = Result<Result<(), ServerError>, RpcError>> + '_

pub fn cur_get( &self, ctx: Context, env: u64, tx: u64, cur: u64, key: Option<Vec<u8>>, data: Option<Vec<u8>>, op: u32, ) -> impl Future<Output = Result<Result<(Option<Vec<u8>>, Vec<u8>, bool), ServerError>, RpcError>> + '_

pub fn cur_put( &self, ctx: Context, env: u64, tx: u64, cur: u64, key: Vec<u8>, value: Vec<u8>, flags: u32, ) -> impl Future<Output = Result<Result<(), ServerError>, RpcError>> + '_

pub fn cur_create( &self, ctx: Context, env: u64, tx: u64, cur: u64, ) -> impl Future<Output = Result<Result<u64, ServerError>, RpcError>> + '_

pub fn cur_del( &self, ctx: Context, env: u64, tx: u64, cur: u64, flags: u32, ) -> impl Future<Output = Result<Result<(), ServerError>, RpcError>> + '_

pub fn cur_close( &self, ctx: Context, env: u64, tx: u64, cur: u64, ) -> impl Future<Output = Result<Result<(), ServerError>, RpcError>> + '_

pub fn batch_cur_get_full( &self, ctx: Context, env: u64, tx: u64, cur: u64, cnt: u64, buffer: u64, op: u32, ) -> impl Future<Output = Result<Result<Vec<(Vec<u8>, Vec<u8>)>, ServerError>, RpcError>> + '_

Trait Implementations

impl<Stub: Clone> Clone for RemoteMDBXClient<Stub>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<Stub: Debug> Debug for RemoteMDBXClient<Stub>

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

Formats the value using the given formatter.

impl<Stub> From<Stub> for RemoteMDBXClient<Stub>

where Stub: Stub<Req = RemoteMDBXRequest, Resp = RemoteMDBXResponse>,

fn from(stub: Stub) -> Self

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