Struct raft_engine::LogBatch

pub struct LogBatch<E, W> where
    E: Message,
    W: EntryExt<E>,  {
    pub items: Vec<LogItem<E>>,
    // some fields omitted
}

Fields

items: Vec<LogItem<E>>

Implementations

impl<E, W> LogBatch<E, W> where
    E: Message,
    W: EntryExt<E>, 

pub fn with_capacity(cap: usize) -> Self

pub fn add_entries(&mut self, region_id: u64, entries: Vec<E>)

pub fn clean_region(&mut self, region_id: u64)

pub fn add_command(&mut self, region_id: u64, cmd: Command)

pub fn delete(&mut self, region_id: u64, key: Vec<u8>)

pub fn put(&mut self, region_id: u64, key: Vec<u8>, value: Vec<u8>)

pub fn put_msg<M: Message>(
    &mut self,
    region_id: u64,
    key: Vec<u8>,
    m: &M
) -> Result<()>

pub fn is_empty(&self) -> bool

pub fn from_bytes(
    buf: &mut &'_ [u8],
    file_num: u64,
    base_offset: u64
) -> Result<Option<LogBatch<E, W>>>

pub fn encode_to_bytes(
    &mut self,
    compression_threshold: usize
) -> Option<Vec<u8>>

pub fn entries_size(&self) -> usize

Trait Implementations

impl<E: Debug, W: Debug> Debug for LogBatch<E, W> where
    E: Message,
    W: EntryExt<E>, 

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<E, W> Default for LogBatch<E, W> where
    E: Message,
    W: EntryExt<E>, 

fn default() -> Self

Returns the “default value” for a type.

impl<E: PartialEq, W: PartialEq> PartialEq<LogBatch<E, W>> for LogBatch<E, W> where
    E: Message,
    W: EntryExt<E>, 

fn eq(&self, other: &LogBatch<E, W>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &LogBatch<E, W>) -> bool

This method tests for !=.

impl<E, W> StructuralPartialEq for LogBatch<E, W> where
    E: Message,
    W: EntryExt<E>,