Struct BatchingPolicy 

#[non_exhaustive]
pub struct BatchingPolicy { /* private fields */ }

Batch formation policy: fixed-N and/or Δt micro-batching.

Implementations

impl BatchingPolicy

pub const fn none() -> Self

No batching (batch size 1).

pub const fn fixed(n: usize) -> Self

Fixed-N batching.

pub const fn delta_t(cap: Ticks) -> Self

Δt-bounded micro-batching (runtime may still emit batch < N if time cap hits).

pub const fn fixed_and_delta_t(n: usize, cap: Ticks) -> Self

Combined fixed-N and Δt caps.

pub const fn with_window( n: Option<usize>, cap: Option<Ticks>, window_kind: WindowKind, ) -> Self

Combined fixed-N and Δt caps with explicit window kind (e.g., sliding).

pub const fn fixed_with_window(n: usize, window_kind: WindowKind) -> Self

Convenience: fixed-N with explicit window kind.

pub const fn delta_t_with_window(cap: Ticks, window_kind: WindowKind) -> Self

Convenience: delta-t with explicit window kind.

pub const fn fixed_n(&self) -> &Option<usize>

Borrow the fixed-N batching value (if any).

pub const fn max_delta_t(&self) -> &Option<Ticks>

Borrow the delta-t cap (if any).

pub const fn window_kind(&self) -> WindowKind

Return the window kind.

Trait Implementations

impl Clone for BatchingPolicy

fn clone(&self) -> BatchingPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BatchingPolicy

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

Formats the value using the given formatter.

impl Default for BatchingPolicy

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for BatchingPolicy

fn eq(&self, other: &BatchingPolicy) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for BatchingPolicy

impl Eq for BatchingPolicy

impl StructuralPartialEq for BatchingPolicy