Struct sim::models::batcher::Batcher

pub struct Batcher { /* fields omitted */ }

The batching process begins when the batcher receives a job. It will then accept additional jobs, adding them to a batch with the first job, until a max batching time or max batch size is reached - whichever comes first. If the simultaneous arrival of multiple jobs causes the max batch size to be exceeded, then the excess jobs will spillover into the next batching period. In this case of excess jobs, the next batching period begins immediately after the release of the preceding batch. If there are no excess jobs, the batcher will become passive, and wait for a job arrival to initiate the batching process.

Implementations

impl Batcher

pub fn from_value(value: Value) -> Option<Box<dyn ReportableModel>>

impl Batcher

pub fn new(
    job_in_port: String,
    job_out_port: String,
    max_batch_time: f64,
    max_batch_size: usize,
    store_records: bool
) -> Self

Trait Implementations

impl Clone for Batcher

fn clone(&self) -> Batcher

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Batcher

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Batcher

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl DevsModel for Batcher

fn events_ext(
    &mut self,
    incoming_message: &ModelMessage,
    services: &mut Services
) -> Result<(), SimulationError>

fn events_int(
    &mut self,
    services: &mut Services
) -> Result<Vec<ModelMessage>, SimulationError>

fn time_advance(&mut self, time_delta: f64)

fn until_next_event(&self) -> f64

impl Reportable for Batcher

fn status(&self) -> String

fn records(&self) -> &Vec<ModelRecord>

impl SerializableModel for Batcher

fn get_type(&self) -> &'static str

fn serialize(&self) -> Value

impl Serialize for Batcher

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.

impl ReportableModel for Batcher