Skip to main content

StreamNodeResult

lellm_graph::node

Enum StreamNodeResult

pub enum StreamNodeResult {
    Done {
        next: NextStep,
        span_id: SpanId,
    },
    BarrierPaused {
        barrier_id: BarrierId,
        node_name: String,
        span_id: SpanId,
        timeout: Option<Duration>,
        default_action: BarrierDefaultAction,
    },
    Observed {
        error: ObservedError,
        next: NextStep,
        span_id: SpanId,
    },
}

Expand description

节点流式执行结果。

Variants§

Done

节点正常完成

Fields

§next: NextStep

下一步

§span_id: SpanId

执行实例 ID（由调用方传入）

BarrierPaused

Barrier 暂停，等待外部决策

Fields

§barrier_id: BarrierId

Barrier 审批请求 ID（由 executor 生成）

§node_name: String

节点名称

§span_id: SpanId

执行实例 ID

§timeout: Option<Duration>

超时时间（None = 无限等待）

§default_action: BarrierDefaultAction

超时默认行为

Observed

观测错误 — 仅事件，不影响 control flow。

节点通过此变体声明式地报告非致命异常，executor 负责：

发送 GraphEvent::ObservedError 事件
按 next 继续推进控制流

Fields

§error: ObservedError

观测错误

§next: NextStep

下一步

§span_id: SpanId

执行实例 ID

Trait Implementations§

impl Debug for StreamNodeResult

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

impl Freeze for StreamNodeResult

impl RefUnwindSafe for StreamNodeResult

impl Send for StreamNodeResult

impl Sync for StreamNodeResult

impl Unpin for StreamNodeResult

impl UnsafeUnpin for StreamNodeResult

impl UnwindSafe for StreamNodeResult

Blanket Implementations§

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

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

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

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

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

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

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

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

fn into(self) -> U

Calls U::from(self).

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

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

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more

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

type Error = Infallible

The type returned in the event of a conversion error.

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

Performs the conversion.

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

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

The type returned in the event of a conversion error.

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

Performs the conversion.

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more