emitter

Documentation

Index

• type DebugEmitter
  • func NewDebugEmitter(out io.Writer) *DebugEmitter
  • func (e *DebugEmitter) EmitMetrics(_ context.Context, rs *state.RunState, md pmetric.Metrics) error
  • func (e *DebugEmitter) EmitTraces(_ context.Context, rs *state.RunState, td ptrace.Traces) error
• type DebugMessage
• type Emitter
• type JSONEmitter
  • func NewJSONEmitter(out io.Writer) *JSONEmitter
  • func (e *JSONEmitter) EmitMetrics(ctx context.Context, rs *state.RunState, md pmetric.Metrics) error
  • func (e *JSONEmitter) EmitTraces(ctx context.Context, rs *state.RunState, td ptrace.Traces) error
• type OTLPEmitter
  • func NewOTLPEmitter(client *http.Client, endpoint string, headers map[string]string) (*OTLPEmitter, error)
  • func (e *OTLPEmitter) EmitMetrics(ctx context.Context, rs *state.RunState, md pmetric.Metrics) error
  • func (e *OTLPEmitter) EmitTraces(ctx context.Context, rs *state.RunState, td ptrace.Traces) error
• type TickerEmitter
  • func NewTickerEmitter(out io.Writer) *TickerEmitter
  • func (e *TickerEmitter) EmitMetrics(_ context.Context, rs *state.RunState, _ pmetric.Metrics) error
  • func (e *TickerEmitter) EmitTraces(_ context.Context, rs *state.RunState, _ ptrace.Traces) error

Types

type DebugEmitter

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

func NewDebugEmitter

func NewDebugEmitter(out io.Writer) *DebugEmitter

func (*DebugEmitter) EmitMetrics

func (e *DebugEmitter) EmitMetrics(_ context.Context, rs *state.RunState, md pmetric.Metrics) error

func (*DebugEmitter) EmitTraces

func (e *DebugEmitter) EmitTraces(_ context.Context, rs *state.RunState, td ptrace.Traces) error

type DebugMessage

type DebugMessage struct {
	Now      string    `json:"now"`
	Walltime time.Time `json:"walltime"`
	Metrics  any       `json:"metrics,omitempty"`
	Traces   any       `json:"traces,omitempty"`
}

type Emitter

type Emitter interface {
	EmitMetrics(ctx context.Context, state *state.RunState, m pmetric.Metrics) error
	EmitTraces(ctx context.Context, state *state.RunState, t ptrace.Traces) error
}

type JSONEmitter

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

func NewJSONEmitter

func NewJSONEmitter(out io.Writer) *JSONEmitter

func (*JSONEmitter) EmitMetrics

func (e *JSONEmitter) EmitMetrics(ctx context.Context, rs *state.RunState, md pmetric.Metrics) error

func (*JSONEmitter) EmitTraces

func (e *JSONEmitter) EmitTraces(ctx context.Context, rs *state.RunState, td ptrace.Traces) error

type OTLPEmitter

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

func NewOTLPEmitter

func NewOTLPEmitter(client *http.Client, endpoint string, headers map[string]string) (*OTLPEmitter, error)

func (*OTLPEmitter) EmitMetrics

func (e *OTLPEmitter) EmitMetrics(ctx context.Context, rs *state.RunState, md pmetric.Metrics) error

func (*OTLPEmitter) EmitTraces

func (e *OTLPEmitter) EmitTraces(ctx context.Context, rs *state.RunState, td ptrace.Traces) error

type TickerEmitter

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

func NewTickerEmitter

func NewTickerEmitter(out io.Writer) *TickerEmitter

func (*TickerEmitter) EmitMetrics

func (e *TickerEmitter) EmitMetrics(_ context.Context, rs *state.RunState, _ pmetric.Metrics) error

func (*TickerEmitter) EmitTraces

func (e *TickerEmitter) EmitTraces(_ context.Context, rs *state.RunState, _ ptrace.Traces) error