periplon 0.2.0

Rust SDK for building multi-agent AI workflows and automation
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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93

//! Domain-Specific Language (DSL) for creating agentic AI systems
//!
//! This module provides a YAML-based DSL for defining complex multi-agent workflows
//! with hierarchical task decomposition, tool usage, and inter-agent collaboration.
//!
//! # Core Components
//!
//! - **Schema**: DSL type definitions and structure
//! - **Parser**: YAML parsing and deserialization
//! - **Validator**: Semantic validation of DSL workflows
//! - **Executor**: DSL execution engine
//! - **Task Graph**: Hierarchical task management and dependency resolution
//! - **Communication**: Inter-agent messaging protocols
//!
//! # Example
//!
//! ```yaml
//! name: "Simple Workflow"
//! version: "1.0.0"
//!
//! agents:
//!   researcher:
//!     description: "Research and gather information"
//!     model: "claude-sonnet-4-5"
//!     tools:
//!       - Read
//!       - WebSearch
//!     permissions:
//!       mode: "default"
//!
//! tasks:
//!   gather_info:
//!     description: "Research the topic"
//!     agent: "researcher"
//! ```

pub mod context_injection;
pub mod executor;
pub mod fetcher;
pub mod hooks;
pub mod loop_context;
pub mod message_bus;
pub mod message_formatter;
pub mod nl_generator;
pub mod notifications;
pub mod parser;
pub mod predefined_tasks;
pub mod schema;
pub mod state;
pub mod task_graph;
pub mod template;
pub mod truncation;
pub mod validator;
pub mod variables;

pub use executor::DSLExecutor;
pub use fetcher::{fetch_subflow, SubflowCache};
pub use loop_context::{substitute_task_variables, LoopContext};
pub use message_bus::{AgentMessage, Channel, MessageBus};
pub use nl_generator::{generate_and_save, generate_from_nl};
pub use notifications::{
    ConsoleSender, DiscordSender, ElevenLabsSender, EmailSender, FileSender, NotificationContext,
    NotificationError, NotificationManager, NotificationResult, NotificationSender, NtfySender,
    SlackSender, SmsSender,
};
pub use parser::{
    merge_subflow_inline, parse_workflow, parse_workflow_file, parse_workflow_with_subflows,
    serialize_workflow, write_workflow_file,
};
pub use schema::{
    AgentSpec, CleanupStrategy, CollectionSource, CommandSpec, Condition, ConditionSpec,
    ContextConfig, ContextMode, CriterionResult, DSLWorkflow, DefinitionOfDone, DiscordEmbed,
    DiscordField, DoneCriterion, ExecutionMode, FileFormat, FileNotificationFormat, HttpAuth,
    HttpMethod, HttpSpec, InputSpec, LimitsConfig, LoopControl, LoopSpec, McpToolSpec,
    NotificationChannel, NotificationDefaults, NotificationPriority, NotificationSpec,
    OutputDataSource, OutputSource, OutputSpec, PagerDutyAction, PagerDutySeverity,
    PermissionsSpec, RetryConfig, ScriptLanguage, ScriptSpec, SecretSource, SecretSpec,
    SlackAttachment, SlackField, SlackMethod, SmtpConfig, StageSpec, SubflowSource, SubflowSpec,
    TaskSpec, TaskStatusCondition, TeamsFact, TelegramParseMode, ToolsConfig, TruncationStrategy,
    WorkflowSpec,
};
pub use state::{
    ContextMetrics, LoopState, OutputType, StatePersistence, TaskOutput, WorkflowState,
    WorkflowStatus,
};
pub use task_graph::{TaskGraph, TaskStatus};
pub use template::{generate_nl_to_dsl_prompt, generate_template, DSL_GRAMMAR_VERSION};
pub use validator::validate_workflow;
pub use variables::{extract_variable_references, Scope, VariableContext};

// Stdio and Context Management
pub use context_injection::{build_smart_context, calculate_relevance};
pub use truncation::{create_task_output, truncate_output};