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 *zap.SugaredLogger)
• func InitializeIfNeeded(enabled bool, version string, logger *zap.SugaredLogger) bool
• func LoggerFor(logger *zap.SugaredLogger, span *Span) *zap.SugaredLogger
• func NewGRPCConnection(address string, maxMsgSize int, opts ...grpc.DialOption) (*grpc.ClientConn, error)
• func NewGRPCServer(maxMsgSize int, opts ...grpc.ServerOption) *grpc.Server
• 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 *zap.SugaredLogger, opts ...any) (context.Context, *Span, *zap.SugaredLogger)
  • func StartSpan(ctx context.Context, spanName string, logger *zap.SugaredLogger, opts ...any) (context.Context, *Span, *zap.SugaredLogger)
  • 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 *zap.SugaredLogger)

func InitializeIfNeeded

func InitializeIfNeeded(enabled bool, version string, logger *zap.SugaredLogger) bool

func LoggerFor

func LoggerFor(logger *zap.SugaredLogger, span *Span) *zap.SugaredLogger

func NewGRPCConnection

func NewGRPCConnection(address string, maxMsgSize int, opts ...grpc.DialOption) (*grpc.ClientConn, error)

func NewGRPCServer

func NewGRPCServer(maxMsgSize int, opts ...grpc.ServerOption) *grpc.Server

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 *zap.SugaredLogger, opts ...any) (context.Context, *Span, *zap.SugaredLogger)

func StartSpan

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

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