Skip to main content

EventPayload

hivemind::core::events

Enum EventPayload 

Source 
pub enum EventPayload {

Show 71 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,
    },
    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,
    },
    TaskRuntimeCleared {
        task_id: Uuid,
    },
    TaskClosed {
        id: Uuid,
        reason: Option<String>,
    },
    RepositoryAttached {
        project_id: Uuid,
        path: String,
        name: String,
        access_mode: RepoAccessMode,
    },
    RepositoryDetached {
        project_id: Uuid,
        name: String,
    },
    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>,
    },
    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,
        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>,
    },
    RuntimeStarted {
        adapter_name: String,
        task_id: Uuid,
        attempt_id: Uuid,
    },
    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,
    },
    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: HivemindError
§

ProjectCreated

A new project was created.

Fields

§id: Uuid
§name: String
§description: Option<String>
§

ProjectUpdated

A project was updated.

Fields

§id: Uuid
§name: Option<String>
§description: Option<String>
§

ProjectRuntimeConfigured

Fields

§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
§

TaskCreated

A new task was created.

Fields

§id: Uuid
§project_id: Uuid
§title: String
§description: Option<String>
§scope: Option<Scope>
§

TaskUpdated

A task was updated.

Fields

§id: Uuid
§title: Option<String>
§description: Option<String>
§

TaskRuntimeConfigured

Fields

§task_id: Uuid
§adapter_name: String
§binary_path: String
§model: Option<String>
§args: Vec<String>
§env: HashMap<String, String>
§timeout_ms: u64
§

TaskRuntimeCleared

Fields

§task_id: Uuid
§

TaskClosed

A task was closed.

Fields

§id: Uuid
§reason: Option<String>
§

RepositoryAttached

A repository was attached to a project.

Fields

§project_id: Uuid
§path: String
§name: String
§access_mode: RepoAccessMode
§

RepositoryDetached

A repository was detached from a project.

Fields

§project_id: Uuid
§name: String
§

TaskGraphCreated

Fields

§graph_id: Uuid
§project_id: Uuid
§name: String
§description: Option<String>
§

TaskAddedToGraph

Fields

§graph_id: Uuid
§task: GraphTask
§

DependencyAdded

Fields

§graph_id: Uuid
§from_task: Uuid
§to_task: Uuid
§

GraphTaskCheckAdded

Fields

§graph_id: Uuid
§task_id: Uuid
§check: CheckConfig
§

ScopeAssigned

Fields

§graph_id: Uuid
§task_id: Uuid
§scope: Scope
§

TaskGraphValidated

Fields

§graph_id: Uuid
§project_id: Uuid
§valid: bool
§issues: Vec<String>
§

TaskGraphLocked

Fields

§graph_id: Uuid
§project_id: Uuid
§

TaskFlowCreated

Fields

§flow_id: Uuid
§graph_id: Uuid
§project_id: Uuid
§name: Option<String>
§task_ids: Vec<Uuid>
§

TaskFlowStarted

Fields

§flow_id: Uuid
§base_revision: Option<String>
§

TaskFlowPaused

Fields

§flow_id: Uuid
§running_tasks: Vec<Uuid>
§

TaskFlowResumed

Fields

§flow_id: Uuid
§

TaskFlowCompleted

Fields

§flow_id: Uuid
§

TaskFlowAborted

Fields

§flow_id: Uuid
§reason: Option<String>
§forced: bool
§

TaskReady

Fields

§flow_id: Uuid
§task_id: Uuid
§

TaskBlocked

Fields

§flow_id: Uuid
§task_id: Uuid
§reason: Option<String>
§

ScopeConflictDetected

Fields

§flow_id: Uuid
§task_id: Uuid
§conflicting_task_id: Uuid
§severity: String
§action: String
§reason: String
§

TaskSchedulingDeferred

Fields

§flow_id: Uuid
§task_id: Uuid
§reason: String
§

TaskExecutionStateChanged

Fields

§flow_id: Uuid
§task_id: Uuid
§from: TaskExecState
§to: TaskExecState
§

TaskExecutionStarted

Fields

§flow_id: Uuid
§task_id: Uuid
§attempt_id: Uuid
§attempt_number: u32
§

TaskExecutionSucceeded

Fields

§flow_id: Uuid
§task_id: Uuid
§attempt_id: Option<Uuid>
§

TaskExecutionFailed

Fields

§flow_id: Uuid
§task_id: Uuid
§attempt_id: Option<Uuid>
§reason: Option<String>
§

AttemptStarted

Fields

§flow_id: Uuid
§task_id: Uuid
§attempt_id: Uuid
§attempt_number: u32
§

BaselineCaptured

Fields

§flow_id: Uuid
§task_id: Uuid
§attempt_id: Uuid
§baseline_id: Uuid
§git_head: Option<String>
§file_count: usize
§

FileModified

Fields

§flow_id: Uuid
§task_id: Uuid
§attempt_id: Uuid
§path: String
§change_type: ChangeType
§old_hash: Option<String>
§new_hash: Option<String>
§

DiffComputed

Fields

§flow_id: Uuid
§task_id: Uuid
§attempt_id: Uuid
§diff_id: Uuid
§baseline_id: Uuid
§change_count: usize
§

CheckStarted

Fields

§flow_id: Uuid
§task_id: Uuid
§attempt_id: Uuid
§check_name: String
§required: bool
§

CheckCompleted

Fields

§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

Fields

§flow_id: Uuid
§task_id: Option<Uuid>
§check_name: String
§required: bool
§

MergeCheckCompleted

Fields

§flow_id: Uuid
§task_id: Option<Uuid>
§check_name: String
§passed: bool
§exit_code: i32
§output: String
§duration_ms: u64
§required: bool
§

TaskExecutionFrozen

Fields

§flow_id: Uuid
§task_id: Uuid
§commit_sha: Option<String>
§

TaskIntegratedIntoFlow

Fields

§flow_id: Uuid
§task_id: Uuid
§commit_sha: Option<String>
§

MergeConflictDetected

Fields

§flow_id: Uuid
§task_id: Option<Uuid>
§details: String
§

FlowFrozenForMerge

Fields

§flow_id: Uuid
§

FlowIntegrationLockAcquired

Fields

§flow_id: Uuid
§operation: String
§

CheckpointDeclared

Fields

§flow_id: Uuid
§task_id: Uuid
§attempt_id: Uuid
§checkpoint_id: String
§order: u32
§total: u32
§

CheckpointActivated

Fields

§flow_id: Uuid
§task_id: Uuid
§attempt_id: Uuid
§checkpoint_id: String
§order: u32
§

CheckpointCompleted

Fields

§flow_id: Uuid
§task_id: Uuid
§attempt_id: Uuid
§checkpoint_id: String
§order: u32
§commit_hash: String
§timestamp: DateTime<Utc>
§summary: Option<String>
§

AllCheckpointsCompleted

Fields

§flow_id: Uuid
§task_id: Uuid
§attempt_id: Uuid
§

CheckpointCommitCreated

Fields

§flow_id: Uuid
§task_id: Uuid
§attempt_id: Uuid
§commit_sha: String
§

ScopeValidated

Fields

§flow_id: Uuid
§task_id: Uuid
§attempt_id: Uuid
§verification_id: Uuid
§verified_at: DateTime<Utc>
§scope: Scope
§

ScopeViolationDetected

Fields

§flow_id: Uuid
§task_id: Uuid
§attempt_id: Uuid
§verification_id: Uuid
§verified_at: DateTime<Utc>
§scope: Scope
§violations: Vec<ScopeViolation>
§

RetryContextAssembled

Fields

§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

Fields

§task_id: Uuid
§reset_count: bool
§retry_mode: RetryMode
§

TaskAborted

Fields

§task_id: Uuid
§reason: Option<String>
§

HumanOverride

Fields

§task_id: Uuid
§override_type: String
§decision: String
§reason: String
§user: Option<String>
§

MergePrepared

Fields

§flow_id: Uuid
§target_branch: Option<String>
§conflicts: Vec<String>
§

MergeApproved

Fields

§flow_id: Uuid
§user: Option<String>
§

MergeCompleted

Fields

§flow_id: Uuid
§commits: Vec<String>
§

RuntimeStarted

Fields

§adapter_name: String
§task_id: Uuid
§attempt_id: Uuid
§

RuntimeOutputChunk

Fields

§attempt_id: Uuid
§stream: RuntimeOutputStream
§content: String
§

RuntimeInputProvided

Fields

§attempt_id: Uuid
§content: String
§

RuntimeInterrupted

Fields

§attempt_id: Uuid
§

RuntimeExited

Fields

§attempt_id: Uuid
§exit_code: i32
§duration_ms: u64
§

RuntimeTerminated

Fields

§attempt_id: Uuid
§reason: String
§

RuntimeFilesystemObserved

Fields

§attempt_id: Uuid
§files_created: Vec<PathBuf>
§files_modified: Vec<PathBuf>
§files_deleted: Vec<PathBuf>
§

RuntimeCommandObserved

Fields

§attempt_id: Uuid
§stream: RuntimeOutputStream
§command: String
§

RuntimeToolCallObserved

Fields

§attempt_id: Uuid
§stream: RuntimeOutputStream
§tool_name: String
§details: String
§

RuntimeTodoSnapshotUpdated

Fields

§attempt_id: Uuid
§stream: RuntimeOutputStream
§items: Vec<String>
§

RuntimeNarrativeOutputObserved

Fields

§attempt_id: Uuid
§stream: RuntimeOutputStream
§content: String
§

Unknown

Trait Implementations§

Source§

impl Clone for EventPayload

Source§

fn clone(&self) -> EventPayload

Returns a duplicate of the value. Read more
1.0.0 · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl Debug for EventPayload

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl<'de> Deserialize<'de> for EventPayload

Source§

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

Source§

fn eq(&self, other: &EventPayload) -> bool

Tests for self and other values to be equal, and is used by ==.
1.0.0 · Source§

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
Source§

impl Serialize for EventPayload

Source§

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>
where __S: Serializer,

Serialize this value into the given Serde serializer. Read more
Source§

impl Eq for EventPayload

Source§

impl StructuralPartialEq for EventPayload

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> Downcast for T
where T: Any,

Source§

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>

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)

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)

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
where T: Any + Send + Sync,

Source§

fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Send + Sync>

Convert Arc<Trait> (where Trait: Downcast) to Arc<Any>. Arc<Any> can then be further downcast into Arc<ConcreteType> where ConcreteType implements Trait.
Source§

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

Source§

fn equivalent(&self, key: &K) -> bool

Checks if this value is equivalent to the given key. Read more
Source§

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

Source§

fn equivalent(&self, key: &K) -> bool

Compare self to key and return true if they are equal.
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,