pub enum EventPayload {
Show 92 variants
ErrorOccurred {
error: HivemindError,
},
ProjectCreated {
id: Uuid,
name: String,
description: Option<String>,
},
ProjectUpdated {
id: Uuid,
name: Option<String>,
description: Option<String>,
},
ProjectRuntimeConfigured {
project_id: Uuid,
adapter_name: String,
binary_path: String,
model: Option<String>,
args: Vec<String>,
env: HashMap<String, String>,
timeout_ms: u64,
max_parallel_tasks: u16,
},
ProjectRuntimeRoleConfigured {
project_id: Uuid,
role: RuntimeRole,
adapter_name: String,
binary_path: String,
model: Option<String>,
args: Vec<String>,
env: HashMap<String, String>,
timeout_ms: u64,
max_parallel_tasks: u16,
},
GlobalRuntimeConfigured {
role: RuntimeRole,
adapter_name: String,
binary_path: String,
model: Option<String>,
args: Vec<String>,
env: HashMap<String, String>,
timeout_ms: u64,
max_parallel_tasks: u16,
},
TaskCreated {
id: Uuid,
project_id: Uuid,
title: String,
description: Option<String>,
scope: Option<Scope>,
},
TaskUpdated {
id: Uuid,
title: Option<String>,
description: Option<String>,
},
TaskRuntimeConfigured {
task_id: Uuid,
adapter_name: String,
binary_path: String,
model: Option<String>,
args: Vec<String>,
env: HashMap<String, String>,
timeout_ms: u64,
},
TaskRuntimeRoleConfigured {
task_id: Uuid,
role: RuntimeRole,
adapter_name: String,
binary_path: String,
model: Option<String>,
args: Vec<String>,
env: HashMap<String, String>,
timeout_ms: u64,
},
TaskRuntimeCleared {
task_id: Uuid,
},
TaskRuntimeRoleCleared {
task_id: Uuid,
role: RuntimeRole,
},
TaskRunModeSet {
task_id: Uuid,
mode: RunMode,
},
TaskClosed {
id: Uuid,
reason: Option<String>,
},
RepositoryAttached {
project_id: Uuid,
path: String,
name: String,
access_mode: RepoAccessMode,
},
RepositoryDetached {
project_id: Uuid,
name: String,
},
GovernanceProjectStorageInitialized {
project_id: Uuid,
schema_version: String,
projection_version: u32,
root_path: String,
},
GovernanceArtifactUpserted {
project_id: Option<Uuid>,
scope: String,
artifact_kind: String,
artifact_key: String,
path: String,
revision: u64,
schema_version: String,
projection_version: u32,
},
GovernanceArtifactDeleted {
project_id: Option<Uuid>,
scope: String,
artifact_kind: String,
artifact_key: String,
path: String,
schema_version: String,
projection_version: u32,
},
GovernanceAttachmentLifecycleUpdated {
project_id: Uuid,
task_id: Uuid,
artifact_kind: String,
artifact_key: String,
attached: bool,
schema_version: String,
projection_version: u32,
},
GovernanceStorageMigrated {
project_id: Option<Uuid>,
from_layout: String,
to_layout: String,
migrated_paths: Vec<String>,
rollback_hint: String,
schema_version: String,
projection_version: u32,
},
ConstitutionInitialized {
project_id: Uuid,
path: String,
schema_version: String,
constitution_version: u32,
digest: String,
revision: u64,
actor: String,
mutation_intent: String,
confirmed: bool,
},
ConstitutionUpdated {
project_id: Uuid,
path: String,
schema_version: String,
constitution_version: u32,
previous_digest: String,
digest: String,
revision: u64,
actor: String,
mutation_intent: String,
confirmed: bool,
},
ConstitutionValidated {
project_id: Uuid,
path: String,
schema_version: String,
constitution_version: u32,
digest: String,
valid: bool,
issues: Vec<String>,
validated_by: String,
},
TemplateInstantiated {
project_id: Uuid,
template_id: String,
system_prompt_id: String,
skill_ids: Vec<String>,
document_ids: Vec<String>,
schema_version: String,
projection_version: u32,
},
TaskGraphCreated {
graph_id: Uuid,
project_id: Uuid,
name: String,
description: Option<String>,
},
TaskAddedToGraph {
graph_id: Uuid,
task: GraphTask,
},
DependencyAdded {
graph_id: Uuid,
from_task: Uuid,
to_task: Uuid,
},
GraphTaskCheckAdded {
graph_id: Uuid,
task_id: Uuid,
check: CheckConfig,
},
ScopeAssigned {
graph_id: Uuid,
task_id: Uuid,
scope: Scope,
},
TaskGraphValidated {
graph_id: Uuid,
project_id: Uuid,
valid: bool,
issues: Vec<String>,
},
TaskGraphLocked {
graph_id: Uuid,
project_id: Uuid,
},
TaskFlowCreated {
flow_id: Uuid,
graph_id: Uuid,
project_id: Uuid,
name: Option<String>,
task_ids: Vec<Uuid>,
},
TaskFlowDependencyAdded {
flow_id: Uuid,
depends_on_flow_id: Uuid,
},
TaskFlowRunModeSet {
flow_id: Uuid,
mode: RunMode,
},
TaskFlowRuntimeConfigured {
flow_id: Uuid,
role: RuntimeRole,
adapter_name: String,
binary_path: String,
model: Option<String>,
args: Vec<String>,
env: HashMap<String, String>,
timeout_ms: u64,
max_parallel_tasks: u16,
},
TaskFlowRuntimeCleared {
flow_id: Uuid,
role: RuntimeRole,
},
TaskFlowStarted {
flow_id: Uuid,
base_revision: Option<String>,
},
TaskFlowPaused {
flow_id: Uuid,
running_tasks: Vec<Uuid>,
},
TaskFlowResumed {
flow_id: Uuid,
},
TaskFlowCompleted {
flow_id: Uuid,
},
TaskFlowAborted {
flow_id: Uuid,
reason: Option<String>,
forced: bool,
},
TaskReady {
flow_id: Uuid,
task_id: Uuid,
},
TaskBlocked {
flow_id: Uuid,
task_id: Uuid,
reason: Option<String>,
},
ScopeConflictDetected {
flow_id: Uuid,
task_id: Uuid,
conflicting_task_id: Uuid,
severity: String,
action: String,
reason: String,
},
TaskSchedulingDeferred {
flow_id: Uuid,
task_id: Uuid,
reason: String,
},
TaskExecutionStateChanged {
flow_id: Uuid,
task_id: Uuid,
attempt_id: Option<Uuid>,
from: TaskExecState,
to: TaskExecState,
},
TaskExecutionStarted {
flow_id: Uuid,
task_id: Uuid,
attempt_id: Uuid,
attempt_number: u32,
},
TaskExecutionSucceeded {
flow_id: Uuid,
task_id: Uuid,
attempt_id: Option<Uuid>,
},
TaskExecutionFailed {
flow_id: Uuid,
task_id: Uuid,
attempt_id: Option<Uuid>,
reason: Option<String>,
},
AttemptStarted {
flow_id: Uuid,
task_id: Uuid,
attempt_id: Uuid,
attempt_number: u32,
},
BaselineCaptured {
flow_id: Uuid,
task_id: Uuid,
attempt_id: Uuid,
baseline_id: Uuid,
git_head: Option<String>,
file_count: usize,
},
FileModified {
flow_id: Uuid,
task_id: Uuid,
attempt_id: Uuid,
path: String,
change_type: ChangeType,
old_hash: Option<String>,
new_hash: Option<String>,
},
DiffComputed {
flow_id: Uuid,
task_id: Uuid,
attempt_id: Uuid,
diff_id: Uuid,
baseline_id: Uuid,
change_count: usize,
},
CheckStarted {
flow_id: Uuid,
task_id: Uuid,
attempt_id: Uuid,
check_name: String,
required: bool,
},
CheckCompleted {
flow_id: Uuid,
task_id: Uuid,
attempt_id: Uuid,
check_name: String,
passed: bool,
exit_code: i32,
output: String,
duration_ms: u64,
required: bool,
},
MergeCheckStarted {
flow_id: Uuid,
task_id: Option<Uuid>,
check_name: String,
required: bool,
},
MergeCheckCompleted {
flow_id: Uuid,
task_id: Option<Uuid>,
check_name: String,
passed: bool,
exit_code: i32,
output: String,
duration_ms: u64,
required: bool,
},
TaskExecutionFrozen {
flow_id: Uuid,
task_id: Uuid,
commit_sha: Option<String>,
},
TaskIntegratedIntoFlow {
flow_id: Uuid,
task_id: Uuid,
commit_sha: Option<String>,
},
MergeConflictDetected {
flow_id: Uuid,
task_id: Option<Uuid>,
details: String,
},
FlowFrozenForMerge {
flow_id: Uuid,
},
FlowIntegrationLockAcquired {
flow_id: Uuid,
operation: String,
},
CheckpointDeclared {
flow_id: Uuid,
task_id: Uuid,
attempt_id: Uuid,
checkpoint_id: String,
order: u32,
total: u32,
},
CheckpointActivated {
flow_id: Uuid,
task_id: Uuid,
attempt_id: Uuid,
checkpoint_id: String,
order: u32,
},
CheckpointCompleted {
flow_id: Uuid,
task_id: Uuid,
attempt_id: Uuid,
checkpoint_id: String,
order: u32,
commit_hash: String,
timestamp: DateTime<Utc>,
summary: Option<String>,
},
AllCheckpointsCompleted {
flow_id: Uuid,
task_id: Uuid,
attempt_id: Uuid,
},
CheckpointCommitCreated {
flow_id: Uuid,
task_id: Uuid,
attempt_id: Uuid,
commit_sha: String,
},
ScopeValidated {
flow_id: Uuid,
task_id: Uuid,
attempt_id: Uuid,
verification_id: Uuid,
verified_at: DateTime<Utc>,
scope: Scope,
},
ScopeViolationDetected {
flow_id: Uuid,
task_id: Uuid,
attempt_id: Uuid,
verification_id: Uuid,
verified_at: DateTime<Utc>,
scope: Scope,
violations: Vec<ScopeViolation>,
},
RetryContextAssembled {
flow_id: Uuid,
task_id: Uuid,
attempt_id: Uuid,
attempt_number: u32,
max_attempts: u32,
prior_attempt_ids: Vec<Uuid>,
required_check_failures: Vec<String>,
optional_check_failures: Vec<String>,
runtime_exit_code: Option<i32>,
runtime_terminated_reason: Option<String>,
context: String,
},
TaskRetryRequested {
task_id: Uuid,
reset_count: bool,
retry_mode: RetryMode,
},
TaskAborted {
task_id: Uuid,
reason: Option<String>,
},
HumanOverride {
task_id: Uuid,
override_type: String,
decision: String,
reason: String,
user: Option<String>,
},
MergePrepared {
flow_id: Uuid,
target_branch: Option<String>,
conflicts: Vec<String>,
},
MergeApproved {
flow_id: Uuid,
user: Option<String>,
},
MergeCompleted {
flow_id: Uuid,
commits: Vec<String>,
},
WorktreeCleanupPerformed {
flow_id: Uuid,
cleaned_worktrees: usize,
forced: bool,
dry_run: bool,
},
RuntimeStarted {
adapter_name: String,
task_id: Uuid,
attempt_id: Uuid,
prompt: String,
flags: Vec<String>,
},
RuntimeOutputChunk {
attempt_id: Uuid,
stream: RuntimeOutputStream,
content: String,
},
RuntimeInputProvided {
attempt_id: Uuid,
content: String,
},
RuntimeInterrupted {
attempt_id: Uuid,
},
RuntimeExited {
attempt_id: Uuid,
exit_code: i32,
duration_ms: u64,
},
RuntimeTerminated {
attempt_id: Uuid,
reason: String,
},
RuntimeErrorClassified {
attempt_id: Uuid,
adapter_name: String,
code: String,
category: String,
message: String,
recoverable: bool,
retryable: bool,
rate_limited: bool,
},
RuntimeRecoveryScheduled {
attempt_id: Uuid,
from_adapter: String,
to_adapter: String,
strategy: String,
reason: String,
backoff_ms: u64,
},
RuntimeFilesystemObserved {
attempt_id: Uuid,
files_created: Vec<PathBuf>,
files_modified: Vec<PathBuf>,
files_deleted: Vec<PathBuf>,
},
RuntimeCommandObserved {
attempt_id: Uuid,
stream: RuntimeOutputStream,
command: String,
},
RuntimeToolCallObserved {
attempt_id: Uuid,
stream: RuntimeOutputStream,
tool_name: String,
details: String,
},
RuntimeTodoSnapshotUpdated {
attempt_id: Uuid,
stream: RuntimeOutputStream,
items: Vec<String>,
},
RuntimeNarrativeOutputObserved {
attempt_id: Uuid,
stream: RuntimeOutputStream,
content: String,
},
Unknown,
}Expand description
Payload types for different events.
Variants§
ErrorOccurred
A failure occurred and was recorded.
Fields
§
error: HivemindErrorProjectCreated
A new project was created.
ProjectUpdated
A project was updated.
ProjectRuntimeConfigured
Fields
ProjectRuntimeRoleConfigured
Fields
§
role: RuntimeRoleGlobalRuntimeConfigured
Fields
§
role: RuntimeRoleTaskCreated
A new task was created.
TaskUpdated
A task was updated.
TaskRuntimeConfigured
Fields
TaskRuntimeRoleConfigured
Fields
§
role: RuntimeRoleTaskRuntimeCleared
TaskRuntimeRoleCleared
TaskRunModeSet
TaskClosed
A task was closed.
RepositoryAttached
A repository was attached to a project.
RepositoryDetached
A repository was detached from a project.
GovernanceProjectStorageInitialized
GovernanceArtifactUpserted
Fields
GovernanceArtifactDeleted
Fields
GovernanceAttachmentLifecycleUpdated
Fields
GovernanceStorageMigrated
Fields
ConstitutionInitialized
Fields
ConstitutionUpdated
Fields
ConstitutionValidated
Fields
TemplateInstantiated
Fields
TaskGraphCreated
TaskAddedToGraph
DependencyAdded
GraphTaskCheckAdded
ScopeAssigned
TaskGraphValidated
TaskGraphLocked
TaskFlowCreated
TaskFlowDependencyAdded
TaskFlowRunModeSet
TaskFlowRuntimeConfigured
Fields
§
role: RuntimeRoleTaskFlowRuntimeCleared
TaskFlowStarted
TaskFlowPaused
TaskFlowResumed
TaskFlowCompleted
TaskFlowAborted
TaskReady
TaskBlocked
ScopeConflictDetected
Fields
TaskSchedulingDeferred
TaskExecutionStateChanged
TaskExecutionStarted
TaskExecutionSucceeded
TaskExecutionFailed
AttemptStarted
BaselineCaptured
Fields
FileModified
Fields
§
change_type: ChangeTypeDiffComputed
Fields
CheckStarted
CheckCompleted
Fields
MergeCheckStarted
MergeCheckCompleted
Fields
TaskExecutionFrozen
TaskIntegratedIntoFlow
MergeConflictDetected
FlowFrozenForMerge
FlowIntegrationLockAcquired
CheckpointDeclared
CheckpointActivated
CheckpointCompleted
Fields
AllCheckpointsCompleted
CheckpointCommitCreated
ScopeValidated
Fields
ScopeViolationDetected
Fields
§
violations: Vec<ScopeViolation>RetryContextAssembled
Fields
TaskRetryRequested
TaskAborted
HumanOverride
MergePrepared
MergeApproved
MergeCompleted
WorktreeCleanupPerformed
RuntimeStarted
RuntimeOutputChunk
RuntimeInputProvided
RuntimeInterrupted
RuntimeExited
RuntimeTerminated
RuntimeErrorClassified
Fields
RuntimeRecoveryScheduled
Fields
RuntimeFilesystemObserved
Fields
RuntimeCommandObserved
RuntimeToolCallObserved
RuntimeTodoSnapshotUpdated
RuntimeNarrativeOutputObserved
Unknown
Trait Implementations§
Source§impl Clone for EventPayload
impl Clone for EventPayload
Source§fn clone(&self) -> EventPayload
fn clone(&self) -> EventPayload
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 moreSource§impl Debug for EventPayload
impl Debug for EventPayload
Source§impl<'de> Deserialize<'de> for EventPayload
impl<'de> Deserialize<'de> for EventPayload
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl PartialEq for EventPayload
impl PartialEq for EventPayload
Source§impl Serialize for EventPayload
impl Serialize for EventPayload
impl Eq for EventPayload
impl StructuralPartialEq for EventPayload
Auto Trait Implementations§
impl Freeze for EventPayload
impl RefUnwindSafe for EventPayload
impl Send for EventPayload
impl Sync for EventPayload
impl Unpin for EventPayload
impl UnsafeUnpin for EventPayload
impl UnwindSafe for EventPayload
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> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
Source§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Convert
Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>. Box<dyn Any> can
then be further downcast into Box<ConcreteType> where ConcreteType implements Trait.Source§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Convert
Rc<Trait> (where Trait: Downcast) to Rc<Any>. Rc<Any> can then be
further downcast into Rc<ConcreteType> where ConcreteType implements Trait.Source§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
Convert
&Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &Any’s vtable from &Trait’s.Source§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
Convert
&mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &mut Any’s vtable from &mut Trait’s.Source§impl<T> DowncastSync for T
impl<T> DowncastSync for T
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.