Struct tikv::server::raft_client::RaftCall

struct RaftCall<R, M, B, E> {
    sender: ClientCStreamSender<M>,
    receiver: ClientCStreamReceiver<Done>,
    queue: Arc<Queue>,
    buffer: B,
    router: R,
    snap_scheduler: Scheduler<SnapTask>,
    lifetime: Option<Sender<()>>,
    store_id: u64,
    addr: String,
    engine: PhantomData<E>,
}

Struct tracks the lifetime of a raft or batch_raft RPC.

Fields

sender: ClientCStreamSender<M>

receiver: ClientCStreamReceiver<Done>

queue: Arc<Queue>

buffer: B

router: R

snap_scheduler: Scheduler<SnapTask>

lifetime: Option<Sender<()>>

store_id: u64

addr: String

engine: PhantomData<E>

Implementations

impl<R, M, B, E> RaftCall<R, M, B, E> where
    R: RaftStoreRouter<E> + 'static,
    B: Buffer<OutputMessage = M>,
    E: KvEngine, 

fn new_snapshot_reporter(&self, msg: &RaftMessage) -> SnapshotReporter<R, E>

fn send_snapshot_sock(&self, msg: RaftMessage)

fn fill_msg(&mut self, ctx: &Context<'_>)

fn clean_up(&mut self, sink_err: &Option<Error>, recv_err: &Option<Error>)

Trait Implementations

impl<R, M, B, E> Future for RaftCall<R, M, B, E> where
    R: RaftStoreRouter<E> + Unpin + 'static,
    B: Buffer<OutputMessage = M> + Unpin,
    E: KvEngine, 

type Output = ()

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, ctx: &mut Context<'_>) -> Poll<()>

Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.