telemetry

Documentation

Overview

Content managed by Project Forge, see [projectforge.md] for details.

Content managed by Project Forge, see [projectforge.md] for details.

Content managed by Project Forge, see [projectforge.md] for details.

Content managed by Project Forge, see [projectforge.md] for details.

Content managed by Project Forge, see [projectforge.md] for details.

Content managed by Project Forge, see [projectforge.md] for details.

Index

• func Close() error
• func Initialize(version string, logger util.Logger)
• func InitializeIfNeeded(enabled bool, version string, logger util.Logger) bool
• func LoggerFor(logger util.Logger, span *Span) util.Logger
• func RunProcess(ctx context.Context, cmd string, path string, in io.Reader, out io.Writer, ...) (int, error)
• func RunProcessSimple(ctx context.Context, cmd string, path string, logger util.Logger) (int, string, error)
• func WrapHTTPClient(cl *http.Client) *http.Client
• type Attribute
  • func (a *Attribute) ToOT() attribute.KeyValue
• type ErrHandler
  • func (e *ErrHandler) Handle(err error)
• type Span
  • func StartAsyncSpan(ctx context.Context, spanName string, logger util.Logger, opts ...any) (context.Context, *Span, util.Logger)
  • func StartSpan(ctx context.Context, spanName string, logger util.Logger, opts ...any) (context.Context, *Span, util.Logger)
  • func (s *Span) Attribute(k string, v any)
  • func (s *Span) Attributes(attrs ...*Attribute)
  • func (s *Span) Complete()
  • func (s *Span) Event(name string, attrs ...*Attribute)
  • func (s *Span) OnError(err error)
  • func (s *Span) SetHTTPStatus(code int)
  • func (s *Span) SetName(name string)
  • func (s *Span) SetStatus(status string, description string)
  • func (s *Span) SpanID() string
  • func (s *Span) String() string
  • func (s *Span) TraceID() string

Functions

func Close

func Close() error

func Initialize

func Initialize(version string, logger util.Logger)

func InitializeIfNeeded

func InitializeIfNeeded(enabled bool, version string, logger util.Logger) bool

func LoggerFor

func LoggerFor(logger util.Logger, span *Span) util.Logger

func RunProcess

func RunProcess(ctx context.Context, cmd string, path string, in io.Reader, out io.Writer, er io.Writer, logger util.Logger) (int, error)

func RunProcessSimple

func RunProcessSimple(ctx context.Context, cmd string, path string, logger util.Logger) (int, string, error)

func WrapHTTPClient

func WrapHTTPClient(cl *http.Client) *http.Client

Types

type Attribute

type Attribute struct {
	Key   string `json:"key"`
	Value any    `json:"value"`
}

func (*Attribute) ToOT

func (a *Attribute) ToOT() attribute.KeyValue

type ErrHandler

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

func (*ErrHandler) Handle

func (e *ErrHandler) Handle(err error)

type Span

type Span struct {
	OT trace.Span
	// contains filtered or unexported fields
}

func StartAsyncSpan

func StartAsyncSpan(ctx context.Context, spanName string, logger util.Logger, opts ...any) (context.Context, *Span, util.Logger)

func StartSpan

func StartSpan(ctx context.Context, spanName string, logger util.Logger, opts ...any) (context.Context, *Span, util.Logger)

func (*Span) Attribute

func (s *Span) Attribute(k string, v any)

func (*Span) Attributes

func (s *Span) Attributes(attrs ...*Attribute)

func (*Span) Complete

func (s *Span) Complete()

Complete must be called, usually through a `defer` block.

func (*Span) Event

func (s *Span) Event(name string, attrs ...*Attribute)

func (*Span) OnError

func (s *Span) OnError(err error)

func (*Span) SetHTTPStatus

func (s *Span) SetHTTPStatus(code int)

func (*Span) SetName

func (s *Span) SetName(name string)

func (*Span) SetStatus

func (s *Span) SetStatus(status string, description string)

func (*Span) SpanID

func (s *Span) SpanID() string

func (*Span) String

func (s *Span) String() string

func (*Span) TraceID

func (s *Span) TraceID() string