Enum BulkOutputCommand 

pub enum BulkOutputCommand {
    Park {
        completion: Sender<u64>,
    },
    Resume {
        completion: Sender<()>,
    },
    Restore {
        generation: u64,
        completion: Sender<()>,
    },
    DropFlow {
        incarnation: ClientIncarnation,
        id: u32,
        completion: Sender<()>,
    },
    DropIncarnation {
        incarnation: ClientIncarnation,
        completion: Sender<()>,
    },
}

Lifecycle commands processed ahead of queued dedicated-lane output.

Variants

Park

Park after the currently written complete record, retaining all queued source output.

Fields

completion: Sender<u64>

Cumulative complete dedicated-lane wire bytes at the cut.

Resume

Release the parked source or restored output generation after its thaw reply.

Fields

completion: Sender<()>

Resolves once ordinary output is eligible again.

Restore

Discard inherited transfer output before acknowledging restore activation.

Fields

generation: u64

New attachment generation; late output from previous generations is discarded.

completion: Sender<()>

Resolves after the scheduler has crossed the cut.

DropFlow

Release queued records for one cancelled operation.

Fields

incarnation: ClientIncarnation

Range owner that opened the operation.

id: u32

Correlation being cancelled.

completion: Sender<()>

Resolves after matching queued records and their permits are dropped.

DropIncarnation

Release every queued record owned by one disconnected SDK client.

Fields

incarnation: ClientIncarnation

Range ownership period being removed.

completion: Sender<()>

Resolves after matching queued records and their permits are dropped.