Struct Module

pub struct Module {
    pub max_batch_size: Option<u32>,
    /* private fields */
}

Fields

max_batch_size: Option<u32>

Implementations

impl Module

pub fn new_with_name(name: &str) -> Self

pub fn create(module_id: Option<i64>, module_name: &str) -> Self

pub fn new() -> Self

pub fn get_property(param: &str) -> Option<String>

pub fn is_content_onto( &self, cmd: IndvOp, new_state: &mut Individual, prev_state: &mut Individual, ) -> bool

pub fn get_sys_ticket_id_from_db(storage: &mut VStorage) -> Result<String, i32>

pub fn listen_queue_raw<T>( &mut self, queue_consumer: &mut Consumer, module_context: &mut T, before_batch: &mut fn(_: &mut Backend, _: &mut T, batch_size: u32) -> Option<u32>, prepare: &mut fn(&mut Backend, &mut T, &RawObj, &Consumer) -> Result<bool, PrepareError>, after_batch: &mut fn(_: &mut Backend, _: &mut T, prepared_batch_size: u32) -> Result<bool, PrepareError>, heartbeat: &mut fn(&mut Backend, &mut T) -> Result<(), PrepareError>, backend: &mut Backend, )

pub fn listen_queue<T>( &mut self, queue_consumer: &mut Consumer, module_context: &mut T, before_batch: &mut fn(_: &mut Backend, _: &mut T, batch_size: u32) -> Option<u32>, prepare: &mut fn(&mut Backend, &mut T, &mut Individual, &Consumer) -> Result<bool, PrepareError>, after_batch: &mut fn(_: &mut Backend, _: &mut T, prepared_batch_size: u32) -> Result<bool, PrepareError>, heartbeat: &mut fn(&mut Backend, &mut T) -> Result<(), PrepareError>, backend: &mut Backend, )

impl Module

pub fn prepare_queue(&mut self, veda_module: &mut dyn VedaQueueModule)

Trait Implementations

impl Default for Module

fn default() -> Self

Returns the “default value” for a type.