Enum StepKind 

pub enum StepKind {
    ApiCall {
        method: String,
        url: String,
        body: Option<Value>,
        headers: Option<HashMap<String, String>>,
    },
    Script {
        command: String,
        args: Vec<String>,
        cwd: Option<String>,
        env: Option<HashMap<String, String>>,
        timeout_secs: Option<u64>,
        output_format: Option<ScriptOutputFormat>,
        shell: Option<ShellType>,
    },
    AgentRun {
        agent_id: String,
        prompt: String,
        tools: Vec<String>,
        skills: Vec<String>,
        model: Option<String>,
        max_iterations: Option<u32>,
    },
    ToolCall {
        tool_name: String,
        input: Value,
        agent_id: Option<String>,
    },
    Condition {
        expression: String,
        if_true: Box<StepKind>,
        if_false: Option<Box<StepKind>>,
    },
    Checkpoint {
        message: String,
    },
    WaitForInput {
        message: String,
        schema: Option<Value>,
    },
    Reply {
        text: String,
        buttons: Vec<Vec<ReplyButtonSpec>>,
        buttons_from: Option<String>,
        button_template: Option<ReplyButtonSpec>,
    },
}

Variants

ApiCall

HTTP API call

Fields

method: String

url: String

body: Option<Value>

headers: Option<HashMap<String, String>>

Script

Shell script / command

Fields

command: String

args: Vec<String>

cwd: Option<String>

env: Option<HashMap<String, String>>

timeout_secs: Option<u64>

output_format: Option<ScriptOutputFormat>

shell: Option<ShellType>

AgentRun

Delegate to a Distri agent (sub-agent run)

Fields

agent_id: String

prompt: String

tools: Vec<String>

skills: Vec<String>

Skills to load for this agent step

model: Option<String>

Override model for this step

max_iterations: Option<u32>

Limit agent loop iterations

ToolCall

Single tool invocation — not a full agent loop

Fields

tool_name: String

Tool name (must be registered)

input: Value

Tool input parameters

agent_id: Option<String>

Agent context to execute in (for tools needing agent-scoped permissions)

Condition

Conditional branch — evaluates expression against context

Fields

expression: String

if_true: Box<StepKind>

if_false: Option<Box<StepKind>>

Checkpoint

No-op / marker step (for documentation or manual checkpoints)

Fields

message: String

WaitForInput

Pause execution and wait for external/human input before continuing. The workflow saves state and stops. A resume call provides the input as the step result and continues from here.

Fields

message: String

Message to display to the human (what input is needed)

schema: Option<Value>

Optional JSON Schema describing the expected input shape

Reply

Emit a channel reply (text + optional buttons). Rendered by the gateway per channel. text / button fields support the standard {input.x} / {steps.id.x} interpolation; button_template fields additionally support {item.x} per buttons_from element.

Fields

text: String

buttons: Vec<Vec<ReplyButtonSpec>>

Static buttons (rows: outer = top-to-bottom).

buttons_from: Option<String>

Context path resolving to an array; one button per element.

button_template: Option<ReplyButtonSpec>

Template applied per buttons_from element.

Trait Implementations

impl Clone for StepKind

fn clone(&self) -> StepKind

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StepKind

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StepKind

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StepKind

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

where __S: Serializer,

Serialize this value into the given Serde serializer.