Struct SyncRemoteClient 

pub struct SyncRemoteClient { /* private fields */ }

Implementations

impl SyncRemoteClient

pub fn new( schema: ClientSchema, client_id: impl Into<String>, ) -> Result<Self, RemoteClientError>

pub fn for_operations( client_id: impl Into<String>, ) -> Result<Self, RemoteClientError>

pub fn with_encryption(self, encryption: EncryptionConfig) -> Self

pub fn with_log_epoch( self, log_epoch: impl Into<String>, ) -> Result<Self, RemoteClientError>

Bind prepared commit bytes to one acquired partition log epoch (§2.1).

pub fn prepare_commit( &self, input: RemoteCommitInput, ) -> Result<PreparedRemoteCommit, RemoteClientError>

pub fn send_commit<T: Transport>( &self, transport: &mut T, prepared: &PreparedRemoteCommit, ) -> Result<RemoteCommitResult, RemoteClientError>

pub fn commit<T: Transport>( &self, transport: &mut T, input: RemoteCommitInput, ) -> Result<RemoteCommitResult, RemoteClientError>

pub fn query<T, Params, Row>( &self, transport: &mut T, operation_id: &str, params: &Params, ) -> Result<RemoteQueryResult<Row>, RemoteClientError>

where T: Transport, Params: Serialize, Row: DeserializeOwned,

pub fn command<T, Input>( &self, transport: &mut T, operation_id: &str, request_id: &str, input: &Input, ) -> Result<RemoteCommandResult, RemoteClientError>

where T: Transport, Input: Serialize,