pub enum SwarmEvent {
Show 13 variants
Started {
task: String,
total_subtasks: usize,
},
Decomposed {
subtasks: Vec<SubTaskInfo>,
},
SubTaskUpdate {
id: String,
name: String,
status: SubTaskStatus,
agent_name: Option<String>,
},
AgentStarted {
subtask_id: String,
agent_name: String,
specialty: String,
},
AgentToolCall {
subtask_id: String,
tool_name: String,
},
AgentToolCallDetail {
subtask_id: String,
detail: AgentToolCallDetail,
},
AgentMessage {
subtask_id: String,
entry: AgentMessageEntry,
},
AgentComplete {
subtask_id: String,
success: bool,
steps: usize,
},
AgentOutput {
subtask_id: String,
output: String,
},
AgentError {
subtask_id: String,
error: String,
},
StageComplete {
stage: usize,
completed: usize,
failed: usize,
},
Complete {
success: bool,
stats: SwarmStats,
},
Error(String),
}Expand description
Events emitted by swarm execution for TUI updates
Variants§
Started
Swarm execution started
Decomposed
Task decomposition complete
Fields
§
subtasks: Vec<SubTaskInfo>SubTaskUpdate
SubTask status changed
AgentStarted
SubAgent started working
AgentToolCall
SubAgent made a tool call (basic)
AgentToolCallDetail
SubAgent made a tool call with detail
AgentMessage
SubAgent sent/received a message
AgentComplete
SubAgent completed
AgentOutput
SubAgent produced output text
AgentError
SubAgent encountered an error
StageComplete
Stage completed
Complete
Swarm execution complete
Error(String)
Error occurred
Trait Implementations§
Source§impl Clone for SwarmEvent
impl Clone for SwarmEvent
Source§fn clone(&self) -> SwarmEvent
fn clone(&self) -> SwarmEvent
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for SwarmEvent
impl RefUnwindSafe for SwarmEvent
impl Send for SwarmEvent
impl Sync for SwarmEvent
impl Unpin for SwarmEvent
impl UnwindSafe for SwarmEvent
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::RequestSource§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<T> ServiceExt for T
impl<T> ServiceExt for T
Source§fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where
Self: Sized,
fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where
Self: Sized,
Apply a transformation to the response body. Read more
Source§fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
High level tracing that classifies responses using HTTP status codes. Read more
Source§fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
High level tracing that classifies responses using gRPC headers. Read more