Enum ShutdownStrategy

pub enum ShutdownStrategy {
    Immediate,
    ProcessPending,
}

Defines the shutdown behavior for the pipeline.

ShutdownStrategy determines how the pipeline will behave when it receives a shutdown signal. It supports two modes:

• Immediate: Stops the entire pipeline, including all tasks, instantly.
• ProcessPending: Terminates the data sources, then completes processing of any updates currently pending in the pipeline. This is the default behavior.

Variants

• Immediate: Immediately stops all pipeline activity without processing any remaining updates.
• ProcessPending: Gracefully terminates the data sources and allows the pipeline to finish processing updates that are still in progress or queued.

Notes

• ProcessPending is the default variant, enabling the pipeline to ensure that no updates are lost during shutdown.

Variants

Immediate

Stop the whole pipeline immediately.

ProcessPending

Terminate the datasource(s) and finish processing all pending updates.

Trait Implementations

impl Debug for ShutdownStrategy

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

Formats the value using the given formatter.

impl Default for ShutdownStrategy

fn default() -> ShutdownStrategy

Returns the “default value” for a type.

impl PartialEq for ShutdownStrategy

fn eq(&self, other: &ShutdownStrategy) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ShutdownStrategy