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§
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)
Dyn Compatibility§
This trait is dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety".