distri 0.3.7

Rust client for the Distri A2A agent platform
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

mod client;
mod client_app;
mod client_stream;
pub mod config;
mod local_tools;
mod printer;
mod renderers;

/// Workflow engine — define, execute, and track multi-step workflows.
pub mod workflow {
    pub use distri_workflow::*;
}

mod workflow_executor;
pub use workflow_executor::{ChannelEventSink, DistriStepExecutor, WorkflowSession};

use thiserror::Error;

pub use crate::external_tools_runtime::ExternalToolRegistry;
pub use crate::hooks_runtime::HookRegistry;
pub use client::{
    AgentListItem, AgentRegistrationResponse, ApiKeyResponse, ArtifactEntry, ArtifactListResponse,
    ArtifactNamespace, ArtifactNamespaceList, ArtifactReadResponse, ArtifactSaveResponse,
    ConnectResponse, ConnectionSummary, ConnectionToken, CreatePluginRequest, CreateSkillRequest,
    CreateSkillScriptRequest, Distri, InvokeOptions, LlmExecuteOptions, LlmExecuteResponse,
    LoginUrlResponse, NewPromptTemplateRequest, NewSecretRequest, PluginResponse,
    PluginsListResponse, PromptTemplateResponse, ProviderInfo, SecretEntry, SkillListItemResponse,
    SkillResponse, SyncPromptTemplatesResponse, TaskNamespaceResponse, ThreadSummary,
    UpdatePluginRequest, UpdateSkillRequest, ValidatePluginResponse, WorkspaceResponse,
};
pub use client_app::{AppError, DistriClientApp, ToolListItem};
pub use client_stream::{AgentStreamClient, StreamError, StreamItem};
pub use config::{BuildHttpClient, DistriConfig};
pub use hooks_runtime::*;

pub use distri_types::{
    HookContext, HookKind, HookMutation, InlineHookRequest, InlineHookResponse, TokenResponse,
};
pub use local_tools::register_local_filesystem_tools;
pub use printer::{EventPrinter, print_stream, print_stream_verbose};

#[cfg(test)]
mod tests;

#[derive(Debug, Error)]
pub enum ClientError {
    #[error("http request failed: {0}")]
    Http(#[from] reqwest::Error),
    #[error("stdout transport failed: {0}")]
    Stdout(String),
    #[error("invalid response: {0}")]
    InvalidResponse(String),
    #[error("serialization error: {0}")]
    Serialization(#[from] serde_json::Error),
    #[error("io error: {0}")]
    Io(#[from] std::io::Error),
}

mod external_tools_runtime;
mod hooks_runtime;
pub mod platform_tools;

pub use distri_a2a as a2a;
pub use distri_types as types;