Struct RunnableConfig 

pub struct RunnableConfig {
    pub recursion_limit: u32,
    pub max_concurrency: usize,
    pub tags: Vec<String>,
    pub metadata: Value,
    pub observers: Vec<Arc<dyn Observer>>,
    pub run_id: Uuid,
    pub cancel_token: Option<CancellationToken>,
    pub deadline: Option<Instant>,
    pub extras: Extensions,
    pub parent_run_id: Option<Uuid>,
}

Per-invocation configuration. Defaults are sensible; override only what you need.

Fields

recursion_limit: u32

Maximum number of graph supersteps / chain depth before erroring with CognisError::RecursionLimit.

max_concurrency: usize

Maximum concurrent in-flight tasks (used by batch and parallel nodes).

tags: Vec<String>

Free-form telemetry tags (e.g. [“production”, “feature/foo”]).

metadata: Value

User-supplied metadata, attached to every emitted Event.

observers: Vec<Arc<dyn Observer>>

Event subscribers. Multiple are allowed; each receives every event.

run_id: Uuid

Correlation ID. Defaults to a fresh UUID per Default::default().

cancel_token: Option<CancellationToken>

Cooperative cancellation token.

deadline: Option<Instant>

Hard deadline (if set, framework checks it at every superstep boundary).

extras: Extensions

Plugin-supplied typed payloads.

parent_run_id: Option<Uuid>

Parent observation id for trace nesting. Set by composition sites (Pipe, batch, graph engine) when invoking a sub-runnable. Defaults to None for top-level invocations.

Implementations

impl RunnableConfig

pub fn new() -> Self

Create with defaults. Equivalent to RunnableConfig::default().

pub fn with_recursion_limit(self, n: u32) -> Self

Set the recursion limit (builder-style).

pub fn with_max_concurrency(self, n: usize) -> Self

Set the max concurrency (builder-style).

pub fn with_observer(self, o: Arc<dyn Observer>) -> Self

Add a single observer (builder-style).

pub fn with_tag(self, tag: impl Into<String>) -> Self

Add a tag (builder-style).

pub fn with_cancel_token(self, t: CancellationToken) -> Self

Set the cancellation token (builder-style).

pub fn with_parent_run_id(self, id: Uuid) -> Self

Set the parent run id (builder-style). Used by composition sites to thread trace nesting down to children.

pub fn emit(&self, event: &Event)

Notify every registered observer of an event.

pub fn is_cancelled(&self) -> bool

True if the cancel token has been triggered.

impl RunnableConfig

pub fn clone_for_subcall(parent: &Arc<RunnableConfig>) -> RunnableConfig

Build a child config for a sub-call (batch / fan-out). Reuses tags, metadata, observers, cancel_token, deadline — everything except a fresh run_id and an empty extras.

Trait Implementations

impl Clone for RunnableConfig

fn clone(&self) -> RunnableConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for RunnableConfig

fn default() -> Self

Returns the “default value” for a type.