HewStandard Library

Module std::pipeline

Temporary S1 admission-proof shim for a concrete two-stage i64 pipeline.

WHY: actor monomorphisation and closure-valued actor state are S2 work. WHEN: S2 lands, retire these concrete actors and records. WHAT: the generic Pipeline<T> combinator is the planned S3 surface.

Contents

Functions

Function from

pub fn from(sink_permits: i64) -> PipelineI64TwoStage

Configure a concrete two-stage pipeline.

Function run

pub fn run(pipeline: PipelineI64TwoStage) -> SourceI64

Spawn and wire the source, fixed transform stage, sink, and control actor.

Types

Struct PipelineItemI64

Owning payload carried across the source, stage, and sink mailboxes.

Fields

value: i64
label: string
crash_stage: bool

Struct PipelineI64TwoStage

Concrete S1 builder. The permit count controls sink processing so callers can deterministically prove capacity-one admission.

Fields

sink_permits: i64

Actors

Actor AdmissionControlI64

Fields

permits: i64
stage_attempts: i64
stage_post_sends: i64

Handlers

receive fn take_permit() -> bool
receive fn release()
receive fn mark_stage_attempt() -> i64
receive fn mark_stage_post_send() -> i64
receive fn attempts() -> i64
receive fn post_sends() -> i64

Actor SinkI64

Fields

count: i64
sum: i64
first: i64
second: i64
third: i64
last_value: i64
last_label: string
control: AdmissionControlI64

Handlers

receive fn push(item: PipelineItemI64)
receive fn count() -> i64
receive fn sum() -> i64
receive fn last_value() -> i64
receive fn item(index: i64) -> i64
receive fn last_label() -> string

Actor StageI64

Fields

next: SinkI64
control: AdmissionControlI64

Handlers

receive fn push(item: PipelineItemI64) -> bool

Actor SourceI64

Fields

next: StageI64
sink: SinkI64
control: AdmissionControlI64

Handlers

receive fn push(item: PipelineItemI64) -> bool
receive fn count() -> i64
receive fn sum() -> i64
receive fn last_value() -> i64
receive fn item(index: i64) -> i64
receive fn last_label() -> string
receive fn release_sink()
receive fn control_handle() -> AdmissionControlI64
receive fn stage_attempts() -> i64
receive fn stage_post_sends() -> i64
receive fn shutdown(expected_count: i64) -> bool