Trait v_common::module::veda_module::VedaQueueModule
source · pub trait VedaQueueModule {
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);
}