Struct EventQueue 

pub struct EventQueue {
    pub batch_size: usize,
    pub max_pending_batches: usize,
    /* private fields */
}

Fields

batch_size: usize

max_pending_batches: usize

Implementations

impl EventQueue

pub fn new(batch_size: u32, max_queue_size: u32) -> Self

pub fn approximate_pending_events_count(&self) -> usize

pub fn add(&self, pending_event: QueuedEvent) -> QueueAddResult

pub fn requeue_batch(&self, batch: EventBatch) -> QueueReconcileResult

pub fn contains_at_least_one_full_batch(&self) -> bool

pub fn take_all_batches(&self) -> VecDeque<EventBatch>

pub fn take_next_batch(&self) -> Option<EventBatch>

pub fn reconcile_batching(&self) -> QueueReconcileResult