Struct ErrorContext 

pub struct ErrorContext { /* private fields */ }

Where the engine mirrors failure records in the context, and how many it keeps.

After every recorded call that is not a Skip, each error record the call added (the handler’s own and the engine’s) is appended at the path as {"workflow_id", "task_id", "code", "status"}, status being the call’s (500 for an Err), and the array is trimmed to the newest limit. A call that adds no record writes nothing, so a message whose calls all succeed has no key at the path, not []. As in v3, every segment below the root names an object key: a non-array at the path, or anything but an object above it, is replaced.

At run start the engine removes the path’s key: a message never brings records in.

use dataflow_rs::run::{EngineConfig, ErrorContext};
use dataflow_rs::ErrorKind;

let ec = ErrorContext::new("metadata.errors".parse()?, ErrorContext::DEFAULT_LIMIT)?;
assert_eq!(ec.limit(), 32);
let config = EngineConfig::default().error_context(ec);
assert!(config.error_context.is_some());

// The engine owns `metadata.progress`, and every slot below it.
let refused = ErrorContext::new("metadata.progress.errors".parse()?, 32).unwrap_err();
assert_eq!(*refused.kind(), ErrorKind::Config);

Implementations

impl ErrorContext

pub const DEFAULT_LIMIT: usize = 32

The records kept when a host names no limit: v3’s default.

pub fn new(path: Path, limit: usize) -> Result<Self>

The error context at path, keeping the newest limit records.

Errors

ErrorKind::Config for a root (data, metadata or temp_data itself); for a path at or below a metadata slot the engine owns metadata.progress, which it writes after every call for cross-workflow chaining, and the run’s stamps metadata.processed_at, metadata.engine_version and metadata.channel; and for a limit of 0.

pub fn path(&self) -> &Path

Where the records are mirrored.

pub fn limit(&self) -> usize

How many records are kept: the newest.

Trait Implementations

impl Clone for ErrorContext

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ErrorContext

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

Formats the value using the given formatter.

impl Eq for ErrorContext

impl PartialEq for ErrorContext

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ErrorContext