Struct v_common_module::module::Module [−][src]
Fields
max_batch_size: Option<u32>
Implementations
impl Module
[src]
impl Module
[src]pub fn new_with_name(name: &str) -> Self
[src]
pub fn create(module_id: Option<i64>, module_name: &str) -> Self
[src]
pub fn new() -> Self
[src]
pub fn get_property(param: &str) -> Option<String>
[src]
pub fn get_sys_ticket_id_from_db(storage: &mut VStorage) -> Result<String, i32>
[src]
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
)
[src]
&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
)
[src]
&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
[src]
impl Module
[src]pub fn prepare_queue(&mut self, veda_module: &mut dyn VedaQueueModule)
[src]
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for Module
impl RefUnwindSafe for Module
impl UnwindSafe for Module
impl UnwindSafe for Module