pub struct Module {
pub max_batch_size: Option<u32>,
/* private fields */
}
Fields§
§max_batch_size: Option<u32>
Implementations§
Source§impl Module
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, )
Source§impl Module
impl Module
pub fn prepare_queue(&mut self, veda_module: &mut dyn VedaQueueModule)
Trait Implementations§
Auto Trait Implementations§
impl Freeze for Module
impl RefUnwindSafe for Module
impl Send for Module
impl Sync for Module
impl Unpin for Module
impl UnwindSafe for Module
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more