telemetry

Documentation

Index

• func Init(cfg Config, logger *slog.Logger) error
• func InitMetrics(logger *slog.Logger)
• type Config
• type HealthChecker
  • func GetHealthChecker() *HealthChecker
  • func NewHealthChecker(logger *slog.Logger) *HealthChecker
  • func (h *HealthChecker) Check() (HealthStatus, map[string]bool)
  • func (h *HealthChecker) RegisterCheck(name string, check func() bool)
• type HealthStatus
• type Metrics
  • func GetMetrics() *Metrics
  • func NewMetrics(logger *slog.Logger) *Metrics
  • func (m *Metrics) DecSessionsActive()
  • func (m *Metrics) IncDangersBlocked()
  • func (m *Metrics) IncSessionsActive()
  • func (m *Metrics) IncSessionsErrors()
  • func (m *Metrics) IncSlackPermissionAllowed()
  • func (m *Metrics) IncSlackPermissionBlockedDM()
  • func (m *Metrics) IncSlackPermissionBlockedMention()
  • func (m *Metrics) IncSlackPermissionBlockedUser()
  • func (m *Metrics) IncToolsInvoked()
  • func (m *Metrics) RecordDuration(d time.Duration)
  • func (m *Metrics) Snapshot() MetricsSnapshot
• type MetricsSnapshot
• type Tracer
  • func Get() *Tracer
  • func NewTracer(cfg Config, logger *slog.Logger) (*Tracer, error)
  • func (t *Tracer) Close(ctx context.Context) error
  • func (t *Tracer) Enabled() bool
  • func (t *Tracer) EndSession(span trace.Span, err error)
  • func (t *Tracer) RecordDangerBlock(ctx context.Context, operation, reason string)
  • func (t *Tracer) StartSession(ctx context.Context, sessionID, namespace string) (context.Context, trace.Span)
  • func (t *Tracer) StartToolUse(ctx context.Context, toolName, toolID string) (context.Context, trace.Span)

Functions

func Init

func Init(cfg Config, logger *slog.Logger) error

func InitMetrics

func InitMetrics(logger *slog.Logger)

Types

type Config

type Config struct {
	ServiceName    string
	ServiceVersion string
	Environment    string
	OTLPEndpoint   string
	Sampled        float64
}

type HealthChecker

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

func GetHealthChecker

func GetHealthChecker() *HealthChecker

func NewHealthChecker

func NewHealthChecker(logger *slog.Logger) *HealthChecker

func (*HealthChecker) Check

func (h *HealthChecker) Check() (HealthStatus, map[string]bool)

func (*HealthChecker) RegisterCheck

func (h *HealthChecker) RegisterCheck(name string, check func() bool)

type HealthStatus

type HealthStatus string

const (
	StatusHealthy   HealthStatus = "healthy"
	StatusDegraded  HealthStatus = "degraded"
	StatusUnhealthy HealthStatus = "unhealthy"
)

type Metrics

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

func GetMetrics

func GetMetrics() *Metrics

func NewMetrics

func NewMetrics(logger *slog.Logger) *Metrics

func (*Metrics) DecSessionsActive

func (m *Metrics) DecSessionsActive()

func (*Metrics) IncDangersBlocked

func (m *Metrics) IncDangersBlocked()

func (*Metrics) IncSessionsActive

func (m *Metrics) IncSessionsActive()

func (*Metrics) IncSessionsErrors

func (m *Metrics) IncSessionsErrors()

func (*Metrics) IncSlackPermissionAllowed

func (m *Metrics) IncSlackPermissionAllowed()

func (*Metrics) IncSlackPermissionBlockedDM

func (m *Metrics) IncSlackPermissionBlockedDM()

func (*Metrics) IncSlackPermissionBlockedMention

func (m *Metrics) IncSlackPermissionBlockedMention()

func (*Metrics) IncSlackPermissionBlockedUser

func (m *Metrics) IncSlackPermissionBlockedUser()

func (*Metrics) IncToolsInvoked

func (m *Metrics) IncToolsInvoked()

func (*Metrics) RecordDuration

func (m *Metrics) RecordDuration(d time.Duration)

func (*Metrics) Snapshot

func (m *Metrics) Snapshot() MetricsSnapshot

type MetricsSnapshot

type MetricsSnapshot struct {
	SessionsActive  int64
	SessionsTotal   int64
	SessionsErrors  int64
	ToolsInvoked    int64
	DangersBlocked  int64
	RequestDuration time.Duration

	// Slack permission metrics
	SlackPermissionAllowed        int64
	SlackPermissionBlockedUser    int64
	SlackPermissionBlockedDM      int64
	SlackPermissionBlockedMention int64
}

type Tracer

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

func Get

func Get() *Tracer

func NewTracer

func NewTracer(cfg Config, logger *slog.Logger) (*Tracer, error)

func (*Tracer) Close

func (t *Tracer) Close(ctx context.Context) error

func (*Tracer) Enabled

func (t *Tracer) Enabled() bool

func (*Tracer) EndSession

func (t *Tracer) EndSession(span trace.Span, err error)

func (*Tracer) RecordDangerBlock

func (t *Tracer) RecordDangerBlock(ctx context.Context, operation, reason string)

func (*Tracer) StartSession

func (t *Tracer) StartSession(ctx context.Context, sessionID, namespace string) (context.Context, trace.Span)

func (*Tracer) StartToolUse

func (t *Tracer) StartToolUse(ctx context.Context, toolName, toolID string) (context.Context, trace.Span)