你想知道"每个节点耗时多少、输入输出是啥、有没有报错"，用来做监控和排查。但你不想在每个组件里手写 log.Print——那样代码脏、还改不动第三方组件。回调让你从外部统一挂上这些逻辑。

Eino 在每个节点执行的关键点触发回调（callbacks/、internal/callbacks）：

一个回调 handler 实现这些方法（callbacks/interface.go，用 Builder 构造更方便）：

handler := callbacks.NewHandlerBuilder().
    OnStartFn(func(ctx, info *RunInfo, input CallbackInput) context.Context {
        // 节点开始：记下开始时间、打日志
        return context.WithValue(ctx, startKey, now)
    }).
    OnEndFn(func(ctx, info *RunInfo, output CallbackOutput) context.Context {
        // 节点成功：算耗时、上报监控
        return ctx
    }).
    OnErrorFn(func(ctx, info *RunInfo, err error) context.Context {
        // 节点出错：记录错误
        return ctx
    }).Build()

// 你的极简版：埋点和业务混在一起，每个组件都要改
func (m *MyModel) Generate(ctx, msgs) (*Message, error) {
    log.Print("start", time.Now())        // ← 手插埋点
    out, err := 真正调模型(msgs)
    log.Print("end", time.Now())          // ← 又手插一遍
    return out, err
}

handler := callbacks.NewHandlerBuilder().
    OnStartFn(...).OnEndFn(...).Build()   // ← 埋点集中在这，业务代码零改动

两种挂法：全局（对所有执行生效）或运行时（这一次执行生效）：

// 方式一：全局挂（进程启动时，对之后所有调用生效）
callbacks.AppendGlobalHandlers(handler)

// 方式二：运行时挂（只对这一次 Invoke/Stream 生效）
r.Invoke(ctx, input, compose.WithCallbacks(handler))

每次回调都带一个 RunInfo，告诉你当前是哪个节点、什么组件类型、叫什么名字：

type RunInfo struct {
    Name      string   // 节点名
    Type      string   // 具体类型
    Component components.Component   // 组件类别（ChatModel/Tool/...）
}

流式场景（OnEndWithStreamOutput）里，回调拿到的是一个 StreamReader（Day 03）。而流只能被消费一次——如果你的 handler 把流读完了，真正的业务下游就读不到了！

• 日志：每个节点的输入输出打点，排查问题。
• 指标监控：节点耗时、成功率、token 用量 → Prometheus。
• 链路追踪：给每个节点开一个 span，串成一条 trace（OpenTelemetry/Langfuse）。
• 成本核算：在模型节点的 OnEnd 里累加 token → 算这次请求花了多少钱（Day 01 成本经济学）。

✋ 动手

sed -n '1,80p' callbacks/interface.go | head -60
grep -rn 'OnStart\|OnEnd\|OnError\|WithStream' callbacks/ | head
grep -rn 'AppendGlobalHandlers\|WithCallbacks' . | head