Struct FailurePolicies 

pub struct FailurePolicies { /* private fields */ }

How the engine resolves the FailurePolicy for a rejected document: a global default plus per-index overrides, keyed by logical index name.

The engine governs only item-level rejections (a sink accepted the batch but refused specific documents). Transport failures, a source decode error, or a flush returning Err always stop the run regardless of this.

Implementations

impl FailurePolicies

pub fn new(default: FailurePolicy) -> Self

A policy set with default applied to every index and no overrides.

pub fn with_override( self, index: impl Into<String>, policy: FailurePolicy, ) -> Self

Override the policy for one logical index, leaving others on the default.

pub fn resolve(&self, index: &str) -> FailurePolicy

The effective policy for index (its override, else the default).

Trait Implementations

impl Clone for FailurePolicies

fn clone(&self) -> FailurePolicies

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FailurePolicies

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

Formats the value using the given formatter.

impl Default for FailurePolicies

fn default() -> FailurePolicies

Returns the “default value” for a type.