telemetry

package
v0.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 15, 2026 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type LangfuseTracer

type LangfuseTracer struct {
	// contains filtered or unexported fields
}

LangfuseTracer wraps the Langfuse client and provides eino integration helpers.

func NewLangfuseTracer

func NewLangfuseTracer(cfg *config.LangfuseConfig) *LangfuseTracer

NewLangfuseTracer creates a LangfuseTracer from the config. Returns nil if required credentials are missing.

func (*LangfuseTracer) AgentMiddleware

func (t *LangfuseTracer) AgentMiddleware() adk.AgentMiddleware

AgentMiddleware returns an adk.AgentMiddleware that records model generations and tool-call spans to Langfuse, keyed by the traceID stored in the context.

func (*LangfuseTracer) Flush

func (t *LangfuseTracer) Flush()

Flush ensures all buffered events are sent to Langfuse. It blocks at most defaultFlushTimeout to avoid stalling program exit.

func (*LangfuseTracer) WithNewTrace

func (t *LangfuseTracer) WithNewTrace(ctx context.Context, name string) context.Context

WithNewTrace creates a new Langfuse trace and returns a context carrying its ID.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL