Struct v_common_module::module::Module

pub struct Module {
    pub storage: VStorage,
    pub fts: FTClient,
    pub api: APIClient,
    pub max_batch_size: Option<u32>,
    // some fields omitted
}

Fields

storage: VStorage

fts: FTClient

api: APIClient

max_batch_size: Option<u32>

Implementations

impl Module

pub fn new_with_module_id(
    storage_mode: StorageMode,
    use_remote_storage: bool,
    module_id: Option<i64>
) -> Self

pub fn new(storage_mode: StorageMode, use_remote_storage: bool) -> Self

impl Module

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

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

pub fn get_sys_ticket_id(&mut self) -> Result<String, i32>

pub fn get_literal_of_link(
    &mut self,
    indv: &mut Individual,
    link: &str,
    field: &str,
    to: &mut Individual
) -> Option<String>

pub fn get_literals_of_link(
    &mut self,
    indv: &mut Individual,
    link: &str,
    field: &str
) -> Vec<String>

pub fn get_datetime_of_link(
    &mut self,
    indv: &mut Individual,
    link: &str,
    field: &str,
    to: &mut Individual
) -> Option<i64>

pub fn get_individual_h(&mut self, uri: &str) -> Option<Box<Individual>>

pub fn get_individual<'a>(
    &mut self,
    uri: &str,
    iraw: &'a mut Individual
) -> Option<&'a mut Individual>

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

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

pub fn get_ticket_from_db(&mut self, id: &str) -> Ticket

Trait Implementations

impl Default for Module

fn default() -> Self

Returns the “default value” for a type.