telemetry

Documentation

Index

• Variables
• func DatabaseConnect(ctx context.Context, driverName string, dataSourceName string) (*sqlx.DB, error)
• func GrpcDial(addr string, opts ...grpc.DialOption) (*grpc.ClientConn, error)
• func HeadersToAttributes(headers http.Header) []attribute.KeyValue
• func Init(ctx context.Context, cfg config.Config, service string) (func(), error)
• func InitLogs(ctx context.Context, cfg config.Config, service string) (*logsSDK.LoggerProvider, error)
• func InitMetric(ctx context.Context, cfg config.Config, service string) (*metric.MeterProvider, error)
• func InitTracer(ctx context.Context, cfg config.Config, service string) (*trace.TracerProvider, error)
• func NewGrpcServer(opts ...grpc.ServerOption) *grpc.Server
• func NewRouter() chi.Router

Variables

var Hook = zerolog.HookFunc(func(e *zerolog.Event, level zerolog.Level, message string) {
	if logHook == nil {
		return
	}

	logHook.Run(e, level, message)
})

var LogProvider *logsSDK.LoggerProvider

temporary until otel gets log handling

Functions

func DatabaseConnect

func DatabaseConnect(ctx context.Context, driverName string, dataSourceName string) (*sqlx.DB, error)

DatabaseConnect applies telemetry to a database/sql driver

func GrpcDial

func GrpcDial(addr string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

func HeadersToAttributes

func HeadersToAttributes(headers http.Header) []attribute.KeyValue

func Init

func Init(ctx context.Context, cfg config.Config, service string) (func(), error)

func InitLogs

func InitLogs(ctx context.Context, cfg config.Config, service string) (*logsSDK.LoggerProvider, error)

func InitMetric

func InitMetric(ctx context.Context, cfg config.Config, service string) (*metric.MeterProvider, error)

func InitTracer

func InitTracer(ctx context.Context, cfg config.Config, service string) (*trace.TracerProvider, error)

func NewGrpcServer

func NewGrpcServer(opts ...grpc.ServerOption) *grpc.Server

func NewRouter

func NewRouter() chi.Router