ironflow-core 2.12.0

Rust workflow engine with Claude Code native agent support
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

# ironflow-core

Core building blocks for the **ironflow** workflow engine. Provides composable, async operations that can be chained via plain Rust variables to build headless CI/CD, DevOps, and AI-powered workflows.

## Operations

| Operation | Description |
|-----------|-------------|
| `Shell` | Execute a shell command with timeout, env control, and `kill_on_drop` |
| `Agent` | Invoke an AI agent (Claude Code by default) with structured output support |
| `Http` | Perform HTTP requests via `reqwest` with builder-pattern ergonomics |

## Provider trait

The `AgentProvider` trait abstracts how agent commands are executed. Built-in providers:

| Provider | Feature flag | Description |
|----------|-------------|-------------|
| `ClaudeCodeProvider` | - | Local Claude Code CLI |
| `SshProvider` | `transport-ssh` | Remote execution via SSH |
| `DockerProvider` | `transport-docker` | Run inside a Docker container |
| `K8sEphemeralProvider` | `transport-k8s` | Ephemeral Kubernetes pods |
| `RecordReplayProvider` | - | Deterministic test fixtures without tokens |

## Features

| Feature | Description |
|---------|-------------|
| `prometheus` | Expose Shell, HTTP, and Agent metrics via `metrics` |
| `transport-ssh` | SSH-based remote agent execution |
| `transport-docker` | Docker-based remote agent execution |
| `transport-k8s` | Kubernetes-based ephemeral agent execution |

## Quick start

```rust,no_run
use ironflow_core::prelude::*;
use ironflow_core::operations::shell::Shell;
use ironflow_core::operations::agent::Agent;

async fn example() -> Result<(), OperationError> {
    // Shell command
    let output = Shell::new("echo hello").await?;
    println!("{}", output.stdout);

    // Agent with structured output
    let provider = ClaudeCodeProvider::default();
    let result = Agent::new("Summarize this text", provider).await?;
    println!("{}", result.text());
    Ok(())
}
```

## License

MIT License - see [LICENSE](../LICENSE) for details.