[][src]Trait nebula_graph_fbthrift_storage_v2::client::GeneralStorageService

pub trait GeneralStorageService: Send {
    fn get(
        &self,
        arg_req: &KVGetRequest
    ) -> Pin<Box<dyn Future<Output = Result<KVGetResponse, GetError>> + Send + 'static>>;
fn put(
        &self,
        arg_req: &KVPutRequest
    ) -> Pin<Box<dyn Future<Output = Result<ExecResponse, PutError>> + Send + 'static>>;
fn remove(
        &self,
        arg_req: &KVRemoveRequest
    ) -> Pin<Box<dyn Future<Output = Result<ExecResponse, RemoveError>> + Send + 'static>>; }

Required methods

fn get(
    &self,
    arg_req: &KVGetRequest
) -> Pin<Box<dyn Future<Output = Result<KVGetResponse, GetError>> + Send + 'static>>

fn put(
    &self,
    arg_req: &KVPutRequest
) -> Pin<Box<dyn Future<Output = Result<ExecResponse, PutError>> + Send + 'static>>

fn remove(
    &self,
    arg_req: &KVRemoveRequest
) -> Pin<Box<dyn Future<Output = Result<ExecResponse, RemoveError>> + Send + 'static>>

Loading content...

Implementations

impl dyn GeneralStorageService[src]

To be called by user directly setting up a client. Avoids needing ClientFactory trait in scope, avoids unidiomatic make_Trait name.

use bgs::client::BuckGraphService;

let protocol = BinaryProtocol::new();
let transport = HttpClient::new();
let client = BuckGraphService::new(protocol, transport);

pub fn new<P, T>(
    protocol: P,
    transport: T
) -> Arc<impl GeneralStorageService + Send + 'static> where
    P: Protocol<Frame = T>,
    T: Transport
[src]

impl dyn GeneralStorageService[src]

pub fn mock<'mock>() -> GeneralStorageService<'mock>[src]

Implementors

impl<'a, T> GeneralStorageService for T where
    T: AsRef<dyn GeneralStorageService + 'a>,
    T: Send
[src]

impl<'mock> GeneralStorageService for GeneralStorageService<'mock>[src]

impl<P, T> GeneralStorageService for GeneralStorageServiceImpl<P, T> where
    P: Protocol,
    T: Transport,
    P::Frame: Framing<DecBuf = FramingDecoded<T>>,
    ProtocolEncoded<P>: BufMutExt<Final = FramingEncodedFinal<T>>, 
[src]

Loading content...