Struct RemoteMDBXServer 

pub struct RemoteMDBXServer { /* private fields */ }

Implementations

impl RemoteMDBXServer

pub fn new() -> Self

Trait Implementations

impl Clone for RemoteMDBXServer

fn clone(&self) -> RemoteMDBXServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RemoteMDBXServer

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

Formats the value using the given formatter.

impl RemoteMDBX for RemoteMDBXServer

async fn open_env( self, _context: Context, path: PathBuf, cfg: RemoteEnvironmentConfig, ) -> Result<u64, ServerError>

async fn env_close(self, _context: Context, env: u64) -> Result<(), ServerError>

async fn env_stat( self, _context: Context, env: u64, ) -> Result<Stat, ServerError>

async fn env_info( self, _context: Context, env: u64, ) -> Result<Info, ServerError>

async fn env_sync( self, _context: Context, env: u64, force: bool, ) -> Result<bool, ServerError>

async fn env_ro_tx( self, _context: Context, env: u64, ) -> Result<u64, ServerError>

async fn env_rw_tx( self, _context: Context, env: u64, ) -> Result<u64, ServerError>

async fn tx_create_db( self, _context: Context, env: u64, tx: u64, db: Option<String>, flags: u32, ) -> Result<u32, ServerError>

async fn tx_get( self, _context: Context, env: u64, tx: u64, dbi: u32, key: Vec<u8>, ) -> Result<Option<Vec<u8>>, ServerError>

async fn tx_put( self, _context: Context, env: u64, tx: u64, dbi: u32, key: Vec<u8>, value: Vec<u8>, flags: u32, ) -> Result<(), ServerError>

async fn tx_del( self, _context: Context, env: u64, tx: u64, dbi: u32, key: Vec<u8>, value: Option<Vec<u8>>, ) -> Result<bool, ServerError>

async fn tx_commit( self, _context: Context, env: u64, tx: u64, ) -> Result<(bool, CommitLatency), ServerError>

async fn tx_abort( self, _context: Context, env: u64, tx: u64, ) -> Result<(), ServerError>

async fn tx_nested( self, _context: Context, env: u64, tx: u64, ) -> Result<u64, ServerError>

async fn tx_db_stat( self, _context: Context, env: u64, tx: u64, dbi: u32, ) -> Result<Stat, ServerError>

async fn clear_db( self, _context: Context, env: u64, tx: u64, dbi: u32, ) -> Result<(), ServerError>

async fn tx_ro_cursor( self, _context: Context, env: u64, tx: u64, dbi: u32, ) -> Result<u64, ServerError>

async fn tx_rw_cursor( self, _context: Context, env: u64, tx: u64, dbi: u32, ) -> Result<u64, ServerError>

async fn cur_create( self, _context: Context, env: u64, tx: u64, cur: u64, ) -> Result<u64, ServerError>

async fn cur_get( self, _context: Context, env: u64, tx: u64, cur: u64, key: Option<Vec<u8>>, data: Option<Vec<u8>>, op: u32, ) -> Result<(Option<Vec<u8>>, Vec<u8>, bool), ServerError>

async fn cur_put( self, _context: Context, env: u64, tx: u64, cur: u64, key: Vec<u8>, value: Vec<u8>, flags: u32, ) -> Result<(), ServerError>

async fn cur_del( self, _context: Context, env: u64, tx: u64, cur: u64, flags: u32, ) -> Result<(), ServerError>

async fn cur_close( self, _context: Context, env: u64, tx: u64, cur: u64, ) -> Result<(), ServerError>

async fn batch_cur_get_full( self, _context: Context, env: u64, tx: u64, cur: u64, cnt: u64, buffer: u64, op: u32, ) -> Result<Vec<(Vec<u8>, Vec<u8>)>, ServerError>

fn serve(self) -> ServeRemoteMDBX<Self>

Returns a serving function to use with InFlightRequest::execute.