weavegraph 0.3.0

Graph-driven, concurrent agent workflow framework with versioned state, deterministic barrier merges, and rich diagnostics.
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

use std::fmt;
use thiserror::Error;

use super::event::Event;

/// Trait representing an abstract event emitter that workflow nodes can clone.
pub trait EventEmitter: Send + Sync + fmt::Debug {
    /// Emit an event in a synchronous, non-blocking manner.
    fn emit(&self, event: Event) -> Result<(), EmitterError>;
}

/// Errors that can occur when emitting an event.
#[derive(Debug, Error)]
#[cfg_attr(feature = "diagnostics", derive(miette::Diagnostic))]
pub enum EmitterError {
    #[error("event hub closed")]
    #[cfg_attr(
        feature = "diagnostics",
        diagnostic(
            code(weavegraph::emitter::emitter_fail),
            help("Check event emitter configuration and downstream handler.")
        )
    )]
    Closed,
    #[error("event emission failed: {0}")]
    #[cfg_attr(
        feature = "diagnostics",
        diagnostic(
            code(weavegraph::emitter::emitter_fail),
            help("Check event emitter configuration and downstream handler.")
        )
    )]
    Other(String),
}

impl EmitterError {
    pub fn other(error: impl Into<String>) -> Self {
        Self::Other(error.into())
    }
}