Struct logging::LogManager

pub struct LogManager {
    pub(crate) buffer: Vec<u8>,
    pub(crate) log_file: Box<File>,
    pub(crate) current_log_file_number: u32,
    pub(crate) current_log_sn: u128,
    pub(crate) log_queue_recv: Receiver<NandoActivation>,
    pub(crate) log_queue_snd: Sender<NandoActivation>,
}

Fields

buffer: Vec<u8>

log_file: Box<File>

current_log_file_number: u32

current_log_sn: u128

log_queue_recv: Receiver<NandoActivation>

log_queue_snd: Sender<NandoActivation>

Implementations

impl LogManager

pub fn new(config: Config) -> Self

pub fn get_txn_log_manager(maybe_config: Option<Config>) -> &'static LogManager

pub(crate) fn get_txn_log_manager_mut( maybe_config: Option<Config> ) -> &'static mut LogManager

pub fn init_persistence_loop( &self, scheduler_queue_send_handles: Vec<Producer<NandoActivation>> )

pub fn get_log_queue_sender(&self) -> Sender<NandoActivation>

pub fn append(&mut self, log_entry: &mut TransactionLogEntry)

pub fn shutdown(&self)

pub(crate) fn flush_buffer(&mut self)

pub(crate) fn serialize_log_entry( &mut self, log_entry: &mut TransactionLogEntry ) -> Vec<u8>

pub(crate) fn persist_loop( log_queue_recv: Receiver<NandoActivation>, scheduler_queue_send_handles: Vec<Producer<NandoActivation>> )