Struct v_common_module::module::Module

pub struct Module {
    pub max_batch_size: Option<u32>,
    // some fields omitted
}

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 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.