Trait tikv::server::raft_client::Buffer

trait Buffer {
    type OutputMessage;
    fn full(&self) -> bool;
    fn push(&mut self, msg: RaftMessage);
    fn empty(&self) -> bool;
    fn flush(
        &mut self, 
        sender: &mut ClientCStreamSender<Self::OutputMessage>
    ) -> Result<()>;
}

Associated Types

type OutputMessage

Loading content...

Required methods

fn full(&self) -> bool

Tests if it is full.

A full buffer should be flushed successfully before calling push.

fn push(&mut self, msg: RaftMessage)

Pushes the message into buffer.

fn empty(&self) -> bool

Checks if the batch is empty.

fn flush(
    &mut self,
    sender: &mut ClientCStreamSender<Self::OutputMessage>
) -> Result<()>

Flushes the message to grpc.

sender should be able to accept messages.

Loading content...

Implementors

impl Buffer for BatchMessageBuffer

type OutputMessage = BatchRaftMessage

fn full(&self) -> bool

fn push(&mut self, msg: RaftMessage)

fn empty(&self) -> bool

fn flush(
    &mut self,
    sender: &mut ClientCStreamSender<BatchRaftMessage>
) -> Result<()>

impl Buffer for MessageBuffer

type OutputMessage = RaftMessage

fn full(&self) -> bool

fn push(&mut self, msg: RaftMessage)

fn empty(&self) -> bool

fn flush(&mut self, sender: &mut ClientCStreamSender<RaftMessage>) -> Result<()>

Loading content...