Struct MapConfig 

pub struct MapConfig {
    pub max_concurrency: Option<usize>,
    pub item_batcher: Option<ItemBatcher>,
    pub completion_config: CompletionConfig,
    pub serdes: Option<Arc<dyn SerDesAny>>,
}

Configuration for map operations.

Examples

Basic map configuration with concurrency limit:

use durable_execution_sdk::MapConfig;

let config = MapConfig {
    max_concurrency: Some(5),
    ..Default::default()
};

Map with failure tolerance:

use durable_execution_sdk::{MapConfig, CompletionConfig};

let config = MapConfig {
    max_concurrency: Some(10),
    completion_config: CompletionConfig::with_failure_tolerance(2),
    ..Default::default()
};

Fields

max_concurrency: Option<usize>

Maximum number of concurrent executions.

item_batcher: Option<ItemBatcher>

Optional item batcher for grouping items.

completion_config: CompletionConfig

Completion configuration defining success/failure criteria.

serdes: Option<Arc<dyn SerDesAny>>

Optional custom serializer/deserializer.

Trait Implementations

impl Clone for MapConfig

fn clone(&self) -> MapConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MapConfig

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

Formats the value using the given formatter.

impl Default for MapConfig

fn default() -> MapConfig

Returns the “default value” for a type.