Struct Config 

pub struct Config {
    pub max_concurrency: usize,
    pub storage_dir: PathBuf,
    pub persist_state: bool,
    pub cache_capacity: usize,
    pub task_timeout: Option<Duration>,
    pub max_attempts: u32,
    pub metrics_enabled: bool,
    pub log_level: String,
}

Top-level executor configuration.

All fields have sensible defaults (see Config::default) so the executor can run with zero configuration. Values can also be loaded from a JSON file or overridden from the environment.

Fields

max_concurrency: usize

Maximum number of tasks executing concurrently.

storage_dir: PathBuf

Directory used by file-based storage.

persist_state: bool

Whether to persist task state to disk during execution.

cache_capacity: usize

LRU cache capacity (entries) sitting in front of storage.

task_timeout: Option<Duration>

Default per-task timeout. None disables the timeout.

max_attempts: u32

Default maximum execution attempts per task (1 = no retries).

metrics_enabled: bool

Whether the metrics endpoint/registry is enabled.

log_level: String

Log level filter (e.g. “info”, “debug”, “dag_executor=trace”).

Implementations

impl Config

pub fn from_file(path: impl Into<PathBuf>) -> Result<Self>

Load configuration from a JSON file, falling back to defaults for any missing fields.

pub fn with_env_overrides(self) -> Self

Apply overrides from environment variables.

Recognized: DAG_MAX_CONCURRENCY, DAG_STORAGE_DIR, DAG_MAX_ATTEMPTS, DAG_LOG_LEVEL, DAG_PERSIST_STATE.

Trait Implementations

impl Clone for Config

fn clone(&self) -> Config

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Config

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

Formats the value using the given formatter.

impl Default for Config

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Config

where Config: Default,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Config

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.