Struct nebula_graph_fbthrift_storage_v2::mock::StorageAdminService

pub struct StorageAdminService<'mock> {
    pub transLeader: transLeader<'mock>,
    pub addPart: addPart<'mock>,
    pub addLearner: addLearner<'mock>,
    pub removePart: removePart<'mock>,
    pub memberChange: memberChange<'mock>,
    pub waitingForCatchUpData: waitingForCatchUpData<'mock>,
    pub createCheckpoint: createCheckpoint<'mock>,
    pub dropCheckpoint: dropCheckpoint<'mock>,
    pub blockingWrites: blockingWrites<'mock>,
    pub rebuildTagIndex: rebuildTagIndex<'mock>,
    pub rebuildEdgeIndex: rebuildEdgeIndex<'mock>,
    pub getLeaderParts: getLeaderParts<'mock>,
    pub checkPeers: checkPeers<'mock>,
    pub addAdminTask: addAdminTask<'mock>,
    pub stopAdminTask: stopAdminTask<'mock>,
    // some fields omitted
}

Fields

transLeader: transLeader<'mock>

addPart: addPart<'mock>

addLearner: addLearner<'mock>

removePart: removePart<'mock>

memberChange: memberChange<'mock>

waitingForCatchUpData: waitingForCatchUpData<'mock>

createCheckpoint: createCheckpoint<'mock>

dropCheckpoint: dropCheckpoint<'mock>

blockingWrites: blockingWrites<'mock>

rebuildTagIndex: rebuildTagIndex<'mock>

rebuildEdgeIndex: rebuildEdgeIndex<'mock>

getLeaderParts: getLeaderParts<'mock>

checkPeers: checkPeers<'mock>

addAdminTask: addAdminTask<'mock>

stopAdminTask: stopAdminTask<'mock>

Trait Implementations

impl<'mock> StorageAdminService for StorageAdminService<'mock>

fn transLeader(
    &self,
    arg_req: &TransLeaderReq
) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, TransLeaderError>> + Send + 'static>>

fn addPart(
    &self,
    arg_req: &AddPartReq
) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, AddPartError>> + Send + 'static>>

fn addLearner(
    &self,
    arg_req: &AddLearnerReq
) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, AddLearnerError>> + Send + 'static>>

fn removePart(
    &self,
    arg_req: &RemovePartReq
) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, RemovePartError>> + Send + 'static>>

fn memberChange(
    &self,
    arg_req: &MemberChangeReq
) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, MemberChangeError>> + Send + 'static>>

fn waitingForCatchUpData(
    &self,
    arg_req: &CatchUpDataReq
) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, WaitingForCatchUpDataError>> + Send + 'static>>

fn createCheckpoint(
    &self,
    arg_req: &CreateCPRequest
) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, CreateCheckpointError>> + Send + 'static>>

fn dropCheckpoint(
    &self,
    arg_req: &DropCPRequest
) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, DropCheckpointError>> + Send + 'static>>

fn blockingWrites(
    &self,
    arg_req: &BlockingSignRequest
) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, BlockingWritesError>> + Send + 'static>>

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

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

fn getLeaderParts(
    &self,
    arg_req: &GetLeaderReq
) -> Pin<Box<dyn Future<Output = Result<GetLeaderPartsResp, GetLeaderPartsError>> + Send + 'static>>

fn checkPeers(
    &self,
    arg_req: &CheckPeersReq
) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, CheckPeersError>> + Send + 'static>>

fn addAdminTask(
    &self,
    arg_req: &AddAdminTaskRequest
) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, AddAdminTaskError>> + Send + 'static>>

fn stopAdminTask(
    &self,
    arg_req: &StopAdminTaskRequest
) -> Pin<Box<dyn Future<Output = Result<AdminExecResp, StopAdminTaskError>> + Send + 'static>>