Struct Module 

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

Fields

max_batch_size: Option<u32>

name: String

onto_types: Vec<String>

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 is_content_onto( &self, cmd: IndvOp, new_state: &mut Individual, prev_state: &mut Individual, ) -> bool

pub fn get_property<T: FromStr>(in_param: &str) -> Option<T>

pub fn connect_to_notify_channel(&mut self) -> Option<Socket>

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

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

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.