Trait nebula_fbthrift_storage::client::StorageService

source · 
pub trait StorageService: Send {

Show 31 methods    fn getBound(
        &self,
        arg_req: &GetNeighborsRequest
    ) -> Pin<Box<dyn Future<Output = Result<QueryResponse, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn boundStats(
        &self,
        arg_req: &GetNeighborsRequest
    ) -> Pin<Box<dyn Future<Output = Result<QueryStatsResponse, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn getProps(
        &self,
        arg_req: &VertexPropRequest
    ) -> Pin<Box<dyn Future<Output = Result<QueryResponse, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn getEdgeProps(
        &self,
        arg_req: &EdgePropRequest
    ) -> Pin<Box<dyn Future<Output = Result<EdgePropResponse, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn addVertices(
        &self,
        arg_req: &AddVerticesRequest
    ) -> Pin<Box<dyn Future<Output = Result<ExecResponse, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn addEdges(
        &self,
        arg_req: &AddEdgesRequest
    ) -> Pin<Box<dyn Future<Output = Result<ExecResponse, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn deleteEdges(
        &self,
        arg_req: &DeleteEdgesRequest
    ) -> Pin<Box<dyn Future<Output = Result<ExecResponse, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn deleteVertices(
        &self,
        arg_req: &DeleteVerticesRequest
    ) -> Pin<Box<dyn Future<Output = Result<ExecResponse, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn updateVertex(
        &self,
        arg_req: &UpdateVertexRequest
    ) -> Pin<Box<dyn Future<Output = Result<UpdateResponse, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn updateEdge(
        &self,
        arg_req: &UpdateEdgeRequest
    ) -> Pin<Box<dyn Future<Output = Result<UpdateResponse, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn scanEdge(
        &self,
        arg_req: &ScanEdgeRequest
    ) -> Pin<Box<dyn Future<Output = Result<ScanEdgeResponse, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn scanVertex(
        &self,
        arg_req: &ScanVertexRequest
    ) -> Pin<Box<dyn Future<Output = Result<ScanVertexResponse, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn transLeader(
        &self,
        arg_req: &TransLeaderReq
    ) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn addPart(
        &self,
        arg_req: &AddPartReq
    ) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn addLearner(
        &self,
        arg_req: &AddLearnerReq
    ) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn waitingForCatchUpData(
        &self,
        arg_req: &CatchUpDataReq
    ) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn removePart(
        &self,
        arg_req: &RemovePartReq
    ) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn memberChange(
        &self,
        arg_req: &MemberChangeReq
    ) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn checkPeers(
        &self,
        arg_req: &CheckPeersReq
    ) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn getLeaderPart(
        &self,
        arg_req: &GetLeaderReq
    ) -> Pin<Box<dyn Future<Output = Result<GetLeaderResp, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn createCheckpoint(
        &self,
        arg_req: &CreateCPRequest
    ) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn dropCheckpoint(
        &self,
        arg_req: &DropCPRequest
    ) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn blockingWrites(
        &self,
        arg_req: &BlockingSignRequest
    ) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn rebuildTagIndex(
        &self,
        arg_req: &RebuildIndexRequest
    ) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn rebuildEdgeIndex(
        &self,
        arg_req: &RebuildIndexRequest
    ) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn put(
        &self,
        arg_req: &PutRequest
    ) -> Pin<Box<dyn Future<Output = Result<ExecResponse, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn get(
        &self,
        arg_req: &GetRequest
    ) -> Pin<Box<dyn Future<Output = Result<GeneralResponse, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn remove(
        &self,
        arg_req: &RemoveRequest
    ) -> Pin<Box<dyn Future<Output = Result<ExecResponse, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn removeRange(
        &self,
        arg_req: &RemoveRangeRequest
    ) -> Pin<Box<dyn Future<Output = Result<ExecResponse, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn getUUID(
        &self,
        arg_req: &GetUUIDReq
    ) -> Pin<Box<dyn Future<Output = Result<GetUUIDResp, NonthrowingFunctionError>> + Send + 'static, Global>>;
    fn lookUpIndex(
        &self,
        arg_req: &LookUpIndexRequest
    ) -> Pin<Box<dyn Future<Output = Result<LookUpIndexResp, NonthrowingFunctionError>> + Send + 'static, Global>>;

}

Required Methods§

Implementations§

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 = <dyn BuckGraphService>::new(protocol, transport);

Implementors§