Struct ChildConfig 

pub struct ChildConfig {
    pub serdes: Option<Arc<dyn SerDesAny>>,
    pub replay_children: bool,
    pub error_mapper: Option<Arc<dyn Fn(DurableError) -> DurableError + Send + Sync>>,
    pub summary_generator: Option<Arc<dyn Fn(&str) -> String + Send + Sync>>,
}

Configuration for child context operations.

This configuration controls how child contexts behave, including whether to replay children when loading state for large parallel operations.

Fields

serdes: Option<Arc<dyn SerDesAny>>

Optional custom serializer/deserializer.

replay_children: bool

Whether to replay children when loading state.

When set to true, the child context will request child operations to be included in state loads during replay. This is useful for large parallel operations where the combined output needs to be reconstructed by replaying each branch.

Default is false for better performance in most cases.

error_mapper: Option<Arc<dyn Fn(DurableError) -> DurableError + Send + Sync>>

Optional function to map child context errors before propagation.

When set, this function is applied to errors from child context execution before they are checkpointed and propagated. Suspend errors are never mapped.

Default is None, which preserves current behavior (errors propagate unchanged).

summary_generator: Option<Arc<dyn Fn(&str) -> String + Send + Sync>>

Optional function to generate a summary when the serialized child result exceeds 256KB.

When set, this function is invoked with the serialized result string if its size exceeds 256KB (262144 bytes). The returned summary string is stored instead of the full result, enabling replay-based reconstruction for large payloads.

When the serialized result is 256KB or less, the full result is stored even if a summary generator is configured.

Default is None, which preserves current behavior (full result stored regardless of size).

Implementations

impl ChildConfig

pub fn new() -> Self

Creates a new ChildConfig with default values.

pub fn with_replay_children() -> Self

Creates a ChildConfig with replay_children enabled.

Use this when you need to reconstruct the combined output of a large parallel operation by replaying each branch.

Example

use durable_execution_sdk::ChildConfig;

let config = ChildConfig::with_replay_children();
assert!(config.replay_children);

pub fn set_replay_children(self, replay_children: bool) -> Self

Sets the replay_children option.

Arguments

• replay_children - Whether to replay children when loading state

pub fn set_serdes(self, serdes: Arc<dyn SerDesAny>) -> Self

Sets the custom serializer/deserializer.

pub fn set_error_mapper( self, mapper: Arc<dyn Fn(DurableError) -> DurableError + Send + Sync>, ) -> Self

Sets the error mapper function.

The error mapper is applied to child context errors before they are checkpointed and propagated. Suspend errors are never mapped.

pub fn set_summary_generator( self, generator: Arc<dyn Fn(&str) -> String + Send + Sync>, ) -> Self

Sets the summary generator function.

The summary generator is invoked when the serialized child result exceeds 256KB (262144 bytes). It receives the serialized result string and should return a compact summary string to store instead.

Trait Implementations

impl Clone for ChildConfig

fn clone(&self) -> ChildConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChildConfig

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

Formats the value using the given formatter.

impl Default for ChildConfig

fn default() -> ChildConfig

Returns the “default value” for a type.