Skip to main content

Crate distri

Crate distri 

Source

Re-exports§

pub use config::BuildHttpClient;
pub use distri_a2a as a2a;
pub use distri_types as types;

Modules§

config
Configuration for the Distri client.
platform_tools
Builds the distri_request dynamic tool factory from client config.
workflow
Workflow engine — define, execute, and track multi-step workflows.

Structs§

AgentListItem
AgentRegistrationResponse
Minimal response from agent registration - ignores extra fields like cloud-only id
AgentStreamClient
ApiKeyResponse
Response from API key creation
ArtifactEntry
An artifact entry in a listing.
ArtifactListResponse
Response from listing artifacts in a namespace.
ArtifactNamespace
An artifact namespace (e.g., a task’s artifact space).
ArtifactNamespaceList
Response listing all artifact namespaces.
ArtifactReadResponse
Response from reading an artifact.
ArtifactSaveResponse
Response from saving an artifact.
ChannelEventSink
Sends WorkflowEvents to an mpsc channel. Client apps receive from the other end and can forward as SSE.
ConnectResponse
ConnectionSummary
ConnectionToken
ContextHealth
Shared context health state — updated by the event printer, read by the CLI status line.
CreatePluginRequest
Request to create a new plugin.
CreateSkillRequest
Request to create a new skill.
Distri
Simple HTTP/SSE client for invoking agents with Distri messages.
DistriClientApp
DistriConfig
Configuration for the Distri client.
DistriStepExecutor
Executes workflow steps using the Distri HTTP client. Handles ApiCall (HTTP), ToolCall (client.call_tool), Checkpoint (pass-through).
EventPrinter
ExternalToolRegistry
Per-context registry for handling external tools locally instead of waiting for remote completion.
HookContext
HookMutation
HookRegistry
A per-execution hook registry that lives alongside an ExecutorContext. Hooks are fire-and-forget - they execute but don’t return values.
InlineHookRequest
InlineHookResponse
InvokeOptions
Options for customizing agent invocations with dynamic template data.
LlmExecuteOptions
Options for LLM execution
LlmExecuteResponse
LoginUrlResponse
Response from get_login_url - returns the web app login URL
Model
A model with its capability, pricing, and metadata.
ModelProviderDefinition
A provider definition with its keys and available models.
NewPromptTemplateRequest
Request to create/update a prompt template.
NewSecretRequest
PluginResponse
Full plugin information including code - returned from get/create/update.
PluginsListResponse
Wrapped response for plugin lists.
PromptTemplateResponse
Response from prompt template API.
ProviderInfo
ProviderKeyDefinition
Secret key definition for a provider.
SecretEntry
SkillResponse
Full skill information including content.
StreamItem
SyncPromptTemplatesResponse
Response from syncing prompt templates.
TaskNamespaceResponse
Response from getting a task’s namespace.
ThreadSummary
TokenResponse
Response for issuing access + refresh tokens.
ToolListItem
TraceSummary
TtsModelsResponse
Response from the TTS models list endpoint.
TtsSpeechRequest
Request to generate speech from text.
TtsSpeechResponse
Response from TTS speech generation.
TtsVoiceInfo
Information about a TTS voice.
UpdatePluginRequest
Request to update an existing plugin.
UpdateSkillRequest
Request to update an existing skill.
ValidatePluginResponse
Response from plugin validation.
WorkflowSession
A workflow execution session with event streaming.
WorkspaceResponse
Workspace information

Enums§

AppError
ClientError
HookKind
ProviderType
Known provider types. Used for identity and dispatch.
StreamError

Functions§

parse_sse_data
Parse a raw SSE data string (JSON-RPC response) into a StreamItem.
print_stream
Convenience helper that streams an agent and prints events to stdout.
print_stream_verbose
Convenience helper that streams an agent and prints events to stdout, with optional verbose tool output.
print_stream_with_health
Stream agent events, print to terminal, and update shared context health state.

Type Aliases§

Handler
HandlerFuture