callbacks

Overview ¶

Package callbacks 提供非侵入的执行切面：在某个执行单元的开始/结束/出错时机 触发回调，用于统一注入可观测性（trace、metrics、日志）而不改动业务代码。

业务侧只需在入口/出口埋三个调用：

func (s *svc) Do(ctx context.Context, in Input) (Output, error) {
    info := &callbacks.RunInfo{Name: "Do", Component: "svc"}
    ctx = callbacks.OnStart(ctx, info, in)
    out, err := s.do(ctx, in)
    if err != nil {
        callbacks.OnError(ctx, info, err)
        return out, err
    }
    callbacks.OnEnd(ctx, info, out)
    return out, nil
}

观测侧注册 Handler（全局或随 ctx 局部），无需感知业务：

h := callbacks.NewHandlerBuilder().
    OnStart(func(ctx context.Context, info *callbacks.RunInfo, input any) context.Context {
        return context.WithValue(ctx, startKey{}, time.Now())
    }).
    OnEnd(func(ctx context.Context, info *callbacks.RunInfo, output any) context.Context {
        cost := time.Since(ctx.Value(startKey{}).(time.Time))
        metrics.Observe(info.Name, cost)
        return ctx
    }).
    Build()
callbacks.AppendGlobalHandlers(h)