Enum SourceEvent 

#[non_exhaustive]
pub enum SourceEvent<L> {
    LanesAssigned(Vec<L>),
    LanesRevoked {
        lanes: Vec<LaneId>,
        barrier: DrainBarrier,
    },
    Idle,
}

Control-plane event returned by Source::poll_events.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

LanesAssigned(Vec<L>)

New lanes were assigned; the runtime distributes them across pipeline threads. The source bumps its assignment epoch first.

LanesRevoked

Lanes are being revoked. The runtime trips the DrainBarrier for the owning threads, which stop the lanes, flush in-flight records, and arrive; the source completes the revocation (final synchronous commit included) only after DrainBarrier::wait returns.

Fields

lanes: Vec<LaneId>

Which lanes to stop.

barrier: DrainBarrier

Barrier the owning pipeline threads arrive at once drained.

Idle

Nothing happened within the timeout.

Trait Implementations

impl<L> Debug for SourceEvent<L>

where L: Debug,

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

Formats the value using the given formatter.