Trait MetaService 

pub trait MetaService: Send {
    // Required methods
    fn createSpace(
        &self,
        arg_req: &CreateSpaceReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, CreateSpaceError>> + Send + 'static>>;
    fn dropSpace(
        &self,
        arg_req: &DropSpaceReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, DropSpaceError>> + Send + 'static>>;
    fn getSpace(
        &self,
        arg_req: &GetSpaceReq,
    ) -> Pin<Box<dyn Future<Output = Result<GetSpaceResp, GetSpaceError>> + Send + 'static>>;
    fn listSpaces(
        &self,
        arg_req: &ListSpacesReq,
    ) -> Pin<Box<dyn Future<Output = Result<ListSpacesResp, ListSpacesError>> + Send + 'static>>;
    fn createTag(
        &self,
        arg_req: &CreateTagReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, CreateTagError>> + Send + 'static>>;
    fn alterTag(
        &self,
        arg_req: &AlterTagReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, AlterTagError>> + Send + 'static>>;
    fn dropTag(
        &self,
        arg_req: &DropTagReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, DropTagError>> + Send + 'static>>;
    fn getTag(
        &self,
        arg_req: &GetTagReq,
    ) -> Pin<Box<dyn Future<Output = Result<GetTagResp, GetTagError>> + Send + 'static>>;
    fn listTags(
        &self,
        arg_req: &ListTagsReq,
    ) -> Pin<Box<dyn Future<Output = Result<ListTagsResp, ListTagsError>> + Send + 'static>>;
    fn createEdge(
        &self,
        arg_req: &CreateEdgeReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, CreateEdgeError>> + Send + 'static>>;
    fn alterEdge(
        &self,
        arg_req: &AlterEdgeReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, AlterEdgeError>> + Send + 'static>>;
    fn dropEdge(
        &self,
        arg_req: &DropEdgeReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, DropEdgeError>> + Send + 'static>>;
    fn getEdge(
        &self,
        arg_req: &GetEdgeReq,
    ) -> Pin<Box<dyn Future<Output = Result<GetEdgeResp, GetEdgeError>> + Send + 'static>>;
    fn listEdges(
        &self,
        arg_req: &ListEdgesReq,
    ) -> Pin<Box<dyn Future<Output = Result<ListEdgesResp, ListEdgesError>> + Send + 'static>>;
    fn listHosts(
        &self,
        arg_req: &ListHostsReq,
    ) -> Pin<Box<dyn Future<Output = Result<ListHostsResp, ListHostsError>> + Send + 'static>>;
    fn getPartsAlloc(
        &self,
        arg_req: &GetPartsAllocReq,
    ) -> Pin<Box<dyn Future<Output = Result<GetPartsAllocResp, GetPartsAllocError>> + Send + 'static>>;
    fn listParts(
        &self,
        arg_req: &ListPartsReq,
    ) -> Pin<Box<dyn Future<Output = Result<ListPartsResp, ListPartsError>> + Send + 'static>>;
    fn multiPut(
        &self,
        arg_req: &MultiPutReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, MultiPutError>> + Send + 'static>>;
    fn get(
        &self,
        arg_req: &GetReq,
    ) -> Pin<Box<dyn Future<Output = Result<GetResp, GetError>> + Send + 'static>>;
    fn multiGet(
        &self,
        arg_req: &MultiGetReq,
    ) -> Pin<Box<dyn Future<Output = Result<MultiGetResp, MultiGetError>> + Send + 'static>>;
    fn remove(
        &self,
        arg_req: &RemoveReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, RemoveError>> + Send + 'static>>;
    fn removeRange(
        &self,
        arg_req: &RemoveRangeReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, RemoveRangeError>> + Send + 'static>>;
    fn scan(
        &self,
        arg_req: &ScanReq,
    ) -> Pin<Box<dyn Future<Output = Result<ScanResp, ScanError>> + Send + 'static>>;
    fn createTagIndex(
        &self,
        arg_req: &CreateTagIndexReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, CreateTagIndexError>> + Send + 'static>>;
    fn dropTagIndex(
        &self,
        arg_req: &DropTagIndexReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, DropTagIndexError>> + Send + 'static>>;
    fn getTagIndex(
        &self,
        arg_req: &GetTagIndexReq,
    ) -> Pin<Box<dyn Future<Output = Result<GetTagIndexResp, GetTagIndexError>> + Send + 'static>>;
    fn listTagIndexes(
        &self,
        arg_req: &ListTagIndexesReq,
    ) -> Pin<Box<dyn Future<Output = Result<ListTagIndexesResp, ListTagIndexesError>> + Send + 'static>>;
    fn rebuildTagIndex(
        &self,
        arg_req: &RebuildIndexReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, RebuildTagIndexError>> + Send + 'static>>;
    fn listTagIndexStatus(
        &self,
        arg_req: &ListIndexStatusReq,
    ) -> Pin<Box<dyn Future<Output = Result<ListIndexStatusResp, ListTagIndexStatusError>> + Send + 'static>>;
    fn createEdgeIndex(
        &self,
        arg_req: &CreateEdgeIndexReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, CreateEdgeIndexError>> + Send + 'static>>;
    fn dropEdgeIndex(
        &self,
        arg_req: &DropEdgeIndexReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, DropEdgeIndexError>> + Send + 'static>>;
    fn getEdgeIndex(
        &self,
        arg_req: &GetEdgeIndexReq,
    ) -> Pin<Box<dyn Future<Output = Result<GetEdgeIndexResp, GetEdgeIndexError>> + Send + 'static>>;
    fn listEdgeIndexes(
        &self,
        arg_req: &ListEdgeIndexesReq,
    ) -> Pin<Box<dyn Future<Output = Result<ListEdgeIndexesResp, ListEdgeIndexesError>> + Send + 'static>>;
    fn rebuildEdgeIndex(
        &self,
        arg_req: &RebuildIndexReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, RebuildEdgeIndexError>> + Send + 'static>>;
    fn listEdgeIndexStatus(
        &self,
        arg_req: &ListIndexStatusReq,
    ) -> Pin<Box<dyn Future<Output = Result<ListIndexStatusResp, ListEdgeIndexStatusError>> + Send + 'static>>;
    fn createUser(
        &self,
        arg_req: &CreateUserReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, CreateUserError>> + Send + 'static>>;
    fn dropUser(
        &self,
        arg_req: &DropUserReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, DropUserError>> + Send + 'static>>;
    fn alterUser(
        &self,
        arg_req: &AlterUserReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, AlterUserError>> + Send + 'static>>;
    fn grantRole(
        &self,
        arg_req: &GrantRoleReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, GrantRoleError>> + Send + 'static>>;
    fn revokeRole(
        &self,
        arg_req: &RevokeRoleReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, RevokeRoleError>> + Send + 'static>>;
    fn listUsers(
        &self,
        arg_req: &ListUsersReq,
    ) -> Pin<Box<dyn Future<Output = Result<ListUsersResp, ListUsersError>> + Send + 'static>>;
    fn listRoles(
        &self,
        arg_req: &ListRolesReq,
    ) -> Pin<Box<dyn Future<Output = Result<ListRolesResp, ListRolesError>> + Send + 'static>>;
    fn getUserRoles(
        &self,
        arg_req: &GetUserRolesReq,
    ) -> Pin<Box<dyn Future<Output = Result<ListRolesResp, GetUserRolesError>> + Send + 'static>>;
    fn changePassword(
        &self,
        arg_req: &ChangePasswordReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, ChangePasswordError>> + Send + 'static>>;
    fn heartBeat(
        &self,
        arg_req: &HBReq,
    ) -> Pin<Box<dyn Future<Output = Result<HBResp, HeartBeatError>> + Send + 'static>>;
    fn balance(
        &self,
        arg_req: &BalanceReq,
    ) -> Pin<Box<dyn Future<Output = Result<BalanceResp, BalanceError>> + Send + 'static>>;
    fn leaderBalance(
        &self,
        arg_req: &LeaderBalanceReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, LeaderBalanceError>> + Send + 'static>>;
    fn regConfig(
        &self,
        arg_req: &RegConfigReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, RegConfigError>> + Send + 'static>>;
    fn getConfig(
        &self,
        arg_req: &GetConfigReq,
    ) -> Pin<Box<dyn Future<Output = Result<GetConfigResp, GetConfigError>> + Send + 'static>>;
    fn setConfig(
        &self,
        arg_req: &SetConfigReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, SetConfigError>> + Send + 'static>>;
    fn listConfigs(
        &self,
        arg_req: &ListConfigsReq,
    ) -> Pin<Box<dyn Future<Output = Result<ListConfigsResp, ListConfigsError>> + Send + 'static>>;
    fn createSnapshot(
        &self,
        arg_req: &CreateSnapshotReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, CreateSnapshotError>> + Send + 'static>>;
    fn dropSnapshot(
        &self,
        arg_req: &DropSnapshotReq,
    ) -> Pin<Box<dyn Future<Output = Result<ExecResp, DropSnapshotError>> + Send + 'static>>;
    fn listSnapshots(
        &self,
        arg_req: &ListSnapshotsReq,
    ) -> Pin<Box<dyn Future<Output = Result<ListSnapshotsResp, ListSnapshotsError>> + Send + 'static>>;
    fn runAdminJob(
        &self,
        arg_req: &AdminJobReq,
    ) -> Pin<Box<dyn Future<Output = Result<AdminJobResp, RunAdminJobError>> + Send + 'static>>;
}

Required Methods

fn createSpace( &self, arg_req: &CreateSpaceReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, CreateSpaceError>> + Send + 'static>>

fn dropSpace( &self, arg_req: &DropSpaceReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, DropSpaceError>> + Send + 'static>>

fn getSpace( &self, arg_req: &GetSpaceReq, ) -> Pin<Box<dyn Future<Output = Result<GetSpaceResp, GetSpaceError>> + Send + 'static>>

fn listSpaces( &self, arg_req: &ListSpacesReq, ) -> Pin<Box<dyn Future<Output = Result<ListSpacesResp, ListSpacesError>> + Send + 'static>>

fn createTag( &self, arg_req: &CreateTagReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, CreateTagError>> + Send + 'static>>

fn alterTag( &self, arg_req: &AlterTagReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, AlterTagError>> + Send + 'static>>

fn dropTag( &self, arg_req: &DropTagReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, DropTagError>> + Send + 'static>>

fn getTag( &self, arg_req: &GetTagReq, ) -> Pin<Box<dyn Future<Output = Result<GetTagResp, GetTagError>> + Send + 'static>>

fn listTags( &self, arg_req: &ListTagsReq, ) -> Pin<Box<dyn Future<Output = Result<ListTagsResp, ListTagsError>> + Send + 'static>>

fn createEdge( &self, arg_req: &CreateEdgeReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, CreateEdgeError>> + Send + 'static>>

fn alterEdge( &self, arg_req: &AlterEdgeReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, AlterEdgeError>> + Send + 'static>>

fn dropEdge( &self, arg_req: &DropEdgeReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, DropEdgeError>> + Send + 'static>>

fn getEdge( &self, arg_req: &GetEdgeReq, ) -> Pin<Box<dyn Future<Output = Result<GetEdgeResp, GetEdgeError>> + Send + 'static>>

fn listEdges( &self, arg_req: &ListEdgesReq, ) -> Pin<Box<dyn Future<Output = Result<ListEdgesResp, ListEdgesError>> + Send + 'static>>

fn listHosts( &self, arg_req: &ListHostsReq, ) -> Pin<Box<dyn Future<Output = Result<ListHostsResp, ListHostsError>> + Send + 'static>>

fn getPartsAlloc( &self, arg_req: &GetPartsAllocReq, ) -> Pin<Box<dyn Future<Output = Result<GetPartsAllocResp, GetPartsAllocError>> + Send + 'static>>

fn listParts( &self, arg_req: &ListPartsReq, ) -> Pin<Box<dyn Future<Output = Result<ListPartsResp, ListPartsError>> + Send + 'static>>

fn multiPut( &self, arg_req: &MultiPutReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, MultiPutError>> + Send + 'static>>

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

fn multiGet( &self, arg_req: &MultiGetReq, ) -> Pin<Box<dyn Future<Output = Result<MultiGetResp, MultiGetError>> + Send + 'static>>

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

fn removeRange( &self, arg_req: &RemoveRangeReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, RemoveRangeError>> + Send + 'static>>

fn scan( &self, arg_req: &ScanReq, ) -> Pin<Box<dyn Future<Output = Result<ScanResp, ScanError>> + Send + 'static>>

fn createTagIndex( &self, arg_req: &CreateTagIndexReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, CreateTagIndexError>> + Send + 'static>>

fn dropTagIndex( &self, arg_req: &DropTagIndexReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, DropTagIndexError>> + Send + 'static>>

fn getTagIndex( &self, arg_req: &GetTagIndexReq, ) -> Pin<Box<dyn Future<Output = Result<GetTagIndexResp, GetTagIndexError>> + Send + 'static>>

fn listTagIndexes( &self, arg_req: &ListTagIndexesReq, ) -> Pin<Box<dyn Future<Output = Result<ListTagIndexesResp, ListTagIndexesError>> + Send + 'static>>

fn rebuildTagIndex( &self, arg_req: &RebuildIndexReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, RebuildTagIndexError>> + Send + 'static>>

fn listTagIndexStatus( &self, arg_req: &ListIndexStatusReq, ) -> Pin<Box<dyn Future<Output = Result<ListIndexStatusResp, ListTagIndexStatusError>> + Send + 'static>>

fn createEdgeIndex( &self, arg_req: &CreateEdgeIndexReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, CreateEdgeIndexError>> + Send + 'static>>

fn dropEdgeIndex( &self, arg_req: &DropEdgeIndexReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, DropEdgeIndexError>> + Send + 'static>>

fn getEdgeIndex( &self, arg_req: &GetEdgeIndexReq, ) -> Pin<Box<dyn Future<Output = Result<GetEdgeIndexResp, GetEdgeIndexError>> + Send + 'static>>

fn listEdgeIndexes( &self, arg_req: &ListEdgeIndexesReq, ) -> Pin<Box<dyn Future<Output = Result<ListEdgeIndexesResp, ListEdgeIndexesError>> + Send + 'static>>

fn rebuildEdgeIndex( &self, arg_req: &RebuildIndexReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, RebuildEdgeIndexError>> + Send + 'static>>

fn listEdgeIndexStatus( &self, arg_req: &ListIndexStatusReq, ) -> Pin<Box<dyn Future<Output = Result<ListIndexStatusResp, ListEdgeIndexStatusError>> + Send + 'static>>

fn createUser( &self, arg_req: &CreateUserReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, CreateUserError>> + Send + 'static>>

fn dropUser( &self, arg_req: &DropUserReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, DropUserError>> + Send + 'static>>

fn alterUser( &self, arg_req: &AlterUserReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, AlterUserError>> + Send + 'static>>

fn grantRole( &self, arg_req: &GrantRoleReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, GrantRoleError>> + Send + 'static>>

fn revokeRole( &self, arg_req: &RevokeRoleReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, RevokeRoleError>> + Send + 'static>>

fn listUsers( &self, arg_req: &ListUsersReq, ) -> Pin<Box<dyn Future<Output = Result<ListUsersResp, ListUsersError>> + Send + 'static>>

fn listRoles( &self, arg_req: &ListRolesReq, ) -> Pin<Box<dyn Future<Output = Result<ListRolesResp, ListRolesError>> + Send + 'static>>

fn getUserRoles( &self, arg_req: &GetUserRolesReq, ) -> Pin<Box<dyn Future<Output = Result<ListRolesResp, GetUserRolesError>> + Send + 'static>>

fn changePassword( &self, arg_req: &ChangePasswordReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, ChangePasswordError>> + Send + 'static>>

fn heartBeat( &self, arg_req: &HBReq, ) -> Pin<Box<dyn Future<Output = Result<HBResp, HeartBeatError>> + Send + 'static>>

fn balance( &self, arg_req: &BalanceReq, ) -> Pin<Box<dyn Future<Output = Result<BalanceResp, BalanceError>> + Send + 'static>>

fn leaderBalance( &self, arg_req: &LeaderBalanceReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, LeaderBalanceError>> + Send + 'static>>

fn regConfig( &self, arg_req: &RegConfigReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, RegConfigError>> + Send + 'static>>

fn getConfig( &self, arg_req: &GetConfigReq, ) -> Pin<Box<dyn Future<Output = Result<GetConfigResp, GetConfigError>> + Send + 'static>>

fn setConfig( &self, arg_req: &SetConfigReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, SetConfigError>> + Send + 'static>>

fn listConfigs( &self, arg_req: &ListConfigsReq, ) -> Pin<Box<dyn Future<Output = Result<ListConfigsResp, ListConfigsError>> + Send + 'static>>

fn createSnapshot( &self, arg_req: &CreateSnapshotReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, CreateSnapshotError>> + Send + 'static>>

fn dropSnapshot( &self, arg_req: &DropSnapshotReq, ) -> Pin<Box<dyn Future<Output = Result<ExecResp, DropSnapshotError>> + Send + 'static>>

fn listSnapshots( &self, arg_req: &ListSnapshotsReq, ) -> Pin<Box<dyn Future<Output = Result<ListSnapshotsResp, ListSnapshotsError>> + Send + 'static>>

fn runAdminJob( &self, arg_req: &AdminJobReq, ) -> Pin<Box<dyn Future<Output = Result<AdminJobResp, RunAdminJobError>> + Send + 'static>>

Implementations

impl dyn MetaService

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 MetaService + Send + 'static>

where P: Protocol<Frame = T>, T: Transport,

impl dyn MetaService

pub fn mock<'mock>() -> MetaService<'mock>

Implementors

impl<'a, T> MetaService for T

where T: AsRef<dyn MetaService + 'a> + Send,

impl<'mock> MetaService for MetaService<'mock>

impl<P, T> MetaService for MetaServiceImpl<P, T>

where P: Protocol, T: Transport, P::Frame: Framing<DecBuf = FramingDecoded<T>>, ProtocolEncoded<P>: BufMutExt<Final = FramingEncodedFinal<T>>,