Struct ExitReport 

#[non_exhaustive]
pub struct ExitReport {
    pub state: ExitState,
    pub sink_drain: Option<DrainReport>,
    pub final_watermarks: Vec<(PartitionId, i64)>,
}

Outcome of PipelineRuntime::run.

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.

state: ExitState

How the run ended.

sink_drain: Option<DrainReport>

The sink’s drain report (absent when the sink drain hook could not run, e.g. the I/O runtime was already gone).

final_watermarks: Vec<(PartitionId, i64)>

The last committed watermark per partition, as reported by the final commit.

Implementations

impl ExitReport

pub fn log(&self)

Log the outcome — state, sink drain, final watermarks — at the level matching it (info for a clean exit, error for a failure).

pub fn exit_code(&self) -> i32

The process exit code this outcome maps to: 0 for a clean exit, 1 for a failure.

pub fn ok(self) -> Result<ExitReport, FatalErrorReport>

The report as a Result, so a main can ? a failed run: a clean exit passes the report through, a failure returns the FatalErrorReport as the error.

Trait Implementations

impl Debug for ExitReport

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

Formats the value using the given formatter.