Struct NodeService 

pub struct NodeService { /* private fields */ }

Implementations

impl NodeService

pub fn new( runtime: Arc<NodeRuntime>, coordinator: Option<Arc<CheckpointCoordinator>>, ) -> Self

pub async fn put( &self, request_id: &str, key: &str, value: &str, ) -> Result<WriteResponse, NodeError>

pub async fn write( &self, request: WriteRequest, ) -> Result<WriteResponse, NodeError>

pub async fn execute_sql( &self, command: SqlCommand, ) -> Result<SqlExecuteResponse, NodeError>

pub async fn read( &self, key: &str, consistency: ReadConsistency, ) -> Result<ReadResponse, NodeError>

pub async fn query( &self, statement: SqlStatement, consistency: ReadConsistency, max_rows: u32, ) -> Result<SqlQueryResponse, NodeError>

Trait Implementations

impl Clone for NodeService

fn clone(&self) -> NodeService

Returns a duplicate of the value.

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

Performs copy-assignment from source.