VedaQueueModule

Trait VedaQueueModule 

Source
pub trait VedaQueueModule {
    // Required methods
    fn before_batch(&mut self, size_batch: u32) -> Option<u32>;
    fn prepare(
        &mut self,
        queue_element: &mut Individual,
    ) -> Result<bool, PrepareError>;
    fn after_batch(
        &mut self,
        prepared_batch_size: u32,
    ) -> Result<bool, PrepareError>;
    fn heartbeat(&mut self) -> Result<(), PrepareError>;
    fn before_start(&mut self);
    fn before_exit(&mut self);
}

Required Methods§

Source

fn before_batch(&mut self, size_batch: u32) -> Option<u32>

Source

fn prepare( &mut self, queue_element: &mut Individual, ) -> Result<bool, PrepareError>

Source

fn after_batch( &mut self, prepared_batch_size: u32, ) -> Result<bool, PrepareError>

Source

fn heartbeat(&mut self) -> Result<(), PrepareError>

Source

fn before_start(&mut self)

Source

fn before_exit(&mut self)

Implementors§