Documentation
¶
Index ¶
- func InitLangfuse() (flush func())
- func InitOTel(ctx context.Context) (shutdown func())
- type SlogEinoHandler
- func (h *SlogEinoHandler) Needed(context.Context, *callbacks.RunInfo, callbacks.CallbackTiming) bool
- func (h *SlogEinoHandler) OnEnd(ctx context.Context, info *callbacks.RunInfo, output callbacks.CallbackOutput) context.Context
- func (h *SlogEinoHandler) OnEndWithStreamOutput(ctx context.Context, info *callbacks.RunInfo, ...) context.Context
- func (h *SlogEinoHandler) OnError(ctx context.Context, info *callbacks.RunInfo, err error) context.Context
- func (h *SlogEinoHandler) OnStart(ctx context.Context, info *callbacks.RunInfo, input callbacks.CallbackInput) context.Context
- func (h *SlogEinoHandler) OnStartWithStreamInput(ctx context.Context, info *callbacks.RunInfo, ...) context.Context
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitLangfuse ¶
func InitLangfuse() (flush func())
InitLangfuse registers a global Langfuse callback handler if LANGFUSE_HOST, LANGFUSE_PUBLIC_KEY, and LANGFUSE_SECRET_KEY are set. Returns a flush function that must be called before process exit.
Types ¶
type SlogEinoHandler ¶
SlogEinoHandler logs full callback payloads as JSON for side-by-side comparison with tape / Langfuse. Stream callbacks only log a placeholder (the StreamReader is not drained here).
func NewSlogEinoHandler ¶
func NewSlogEinoHandler(log *slog.Logger) *SlogEinoHandler
func (*SlogEinoHandler) Needed ¶
func (h *SlogEinoHandler) Needed(context.Context, *callbacks.RunInfo, callbacks.CallbackTiming) bool
func (*SlogEinoHandler) OnEnd ¶
func (h *SlogEinoHandler) OnEnd(ctx context.Context, info *callbacks.RunInfo, output callbacks.CallbackOutput) context.Context
func (*SlogEinoHandler) OnEndWithStreamOutput ¶
func (h *SlogEinoHandler) OnEndWithStreamOutput(ctx context.Context, info *callbacks.RunInfo, output *schema.StreamReader[callbacks.CallbackOutput]) context.Context
func (*SlogEinoHandler) OnStart ¶
func (h *SlogEinoHandler) OnStart(ctx context.Context, info *callbacks.RunInfo, input callbacks.CallbackInput) context.Context
func (*SlogEinoHandler) OnStartWithStreamInput ¶
func (h *SlogEinoHandler) OnStartWithStreamInput(ctx context.Context, info *callbacks.RunInfo, input *schema.StreamReader[callbacks.CallbackInput]) context.Context
Source Files
Click to show internal directories.
Click to hide internal directories.