runtime

Documentation

Index

• type Engine
  • func NewEngine(cfg EngineConfig) (*Engine, error)
  • func (e *Engine) Close(ctx context.Context) error
  • func (e *Engine) FlushDue(ctx context.Context) error
  • func (e *Engine) Ingest(ctx context.Context, spans []traces.Span, receivedAt time.Time) error
  • func (e *Engine) IngestWithSource(ctx context.Context, spans []traces.Span, receivedAt time.Time, ...) error
• type EngineConfig
• type FileSink
  • func (s FileSink) Write(_ context.Context, env snapshot.Envelope) error
• type Metrics
  • func NewMetrics() *Metrics
  • func (m *Metrics) AddDropped(count int)
  • func (m *Metrics) AddIngested(count int)
  • func (m *Metrics) Handler() http.Handler
  • func (m *Metrics) RecordSnapshot(env snapshot.Envelope, buildDuration time.Duration, now time.Time)
  • func (m *Metrics) SetWindowLag(now, end time.Time)
• type Service
  • func NewService(cfg config.ServeConfig, overlays []overlay.File, logger *slog.Logger) (*Service, error)
  • func (s *Service) Addr() string
  • func (s *Service) GRPCAddr() string
  • func (s *Service) Run(ctx context.Context) error
• type SnapshotSink

Types

type Engine

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

func NewEngine

func NewEngine(cfg EngineConfig) (*Engine, error)

func (*Engine) Close

func (e *Engine) Close(ctx context.Context) error

func (*Engine) FlushDue

func (e *Engine) FlushDue(ctx context.Context) error

func (*Engine) Ingest

func (e *Engine) Ingest(ctx context.Context, spans []traces.Span, receivedAt time.Time) error

func (*Engine) IngestWithSource

func (e *Engine) IngestWithSource(ctx context.Context, spans []traces.Span, receivedAt time.Time, source snapshot.SourceSummary) error

type EngineConfig

type EngineConfig struct {
	WindowSize       time.Duration
	MaxInMemorySpans int
	LateSpanPolicy   string
	Sink             SnapshotSink
	Metrics          *Metrics
	Logger           *slog.Logger
	Now              func() time.Time
	SourceRef        string
	Sources          []snapshot.SourceSummary
	Overlays         []overlay.File
}

type FileSink

type FileSink struct {
	Directory  string
	LatestPath string
}

func (FileSink) Write

func (s FileSink) Write(_ context.Context, env snapshot.Envelope) error

type Metrics

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

func NewMetrics

func NewMetrics() *Metrics

func (*Metrics) AddDropped

func (m *Metrics) AddDropped(count int)

func (*Metrics) AddIngested

func (m *Metrics) AddIngested(count int)

func (*Metrics) Handler

func (m *Metrics) Handler() http.Handler

func (*Metrics) RecordSnapshot

func (m *Metrics) RecordSnapshot(env snapshot.Envelope, buildDuration time.Duration, now time.Time)

func (*Metrics) SetWindowLag

func (m *Metrics) SetWindowLag(now, end time.Time)

type Service

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

func NewService

func NewService(cfg config.ServeConfig, overlays []overlay.File, logger *slog.Logger) (*Service, error)

func (*Service) Addr

func (s *Service) Addr() string

func (*Service) GRPCAddr

func (s *Service) GRPCAddr() string

func (*Service) Run

func (s *Service) Run(ctx context.Context) error

type SnapshotSink

type SnapshotSink interface {
	Write(context.Context, snapshot.Envelope) error
}