Struct SplitOpening 

#[non_exhaustive]
pub struct SplitOpening<'a> {
    pub split: &'a SplitSpec,
    pub resume: Option<&'a SplitProgress>,
    pub lane: LaneId,
    pub partition: PartitionId,
    pub epoch: LeaseEpoch,
    pub waker: &'a ControlWaker,
}

Everything the driver hands a source when a split’s lane is materialized — exactly once per tenancy, when the gain is staged into a SourceEvent::LanesAdded.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

split: &'a SplitSpec

The split to read.

resume: Option<&'a SplitProgress>

Authoritative progress to resume from (already validated via SplitSource::validate_resume); None for a fresh split.

lane: LaneId

Lane id minted for this tenancy’s lifetime; never reused by this source.

partition: PartitionId

Stable partition id for this tenancy — the key under which this split’s watermarks come back to CoordinationDriver::commit.

epoch: LeaseEpoch

Fencing token of the current tenancy.

waker: &'a ControlWaker

Wakes the control-plane wait. Clone it into the lane and signal it the moment the lane decides end-of-input or reports poison — otherwise the driver only notices between waits and the split’s completion waits out an idle timeout.

Trait Implementations

impl<'a> Debug for SplitOpening<'a>

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

Formats the value using the given formatter.