otelx

Documentation

Index

• Constants
• Variables
• func AddConfigSchema(c interface{ ... }) error
• func NewHandler(handler http.Handler, operation string) http.Handler
• func SetupJaeger(t *Tracer, tracerName string) (trace.Tracer, error)
• func StringAttrs(attrs map[string]string) []attribute.KeyValue
• type Config
• type JaegerConfig
• type JaegerSampling
• type ProvidersConfig
• type Tracer
  • func New(name string, l *logrusx.Logger, c *Config) (*Tracer, error)
  • func NewNoop(l *logrusx.Logger, c *Config) *Tracer
  • func (t *Tracer) IsLoaded() bool
  • func (t *Tracer) Tracer() trace.Tracer

Constants

const ConfigSchemaID = "ory://tracing-config"

Variables

var ConfigSchema string

Functions

func AddConfigSchema

func AddConfigSchema(c interface {
	AddResource(url string, r io.Reader) error
}) error

AddConfigSchema adds the tracing schema to the compiler. The interface is specified instead of `jsonschema.Compiler` to allow the use of any jsonschema library fork or version.

func NewHandler

func NewHandler(handler http.Handler, operation string) http.Handler

func SetupJaeger

func SetupJaeger(t *Tracer, tracerName string) (trace.Tracer, error)

Optionally, Config.Providers.Jaeger.LocalAgentAddress can be set. NOTE: If Config.Providers.Jaeger.Sampling.ServerURL is not specfied, AlwaysSample is used.

func StringAttrs

func StringAttrs(attrs map[string]string) []attribute.KeyValue

Types

type Config

type Config struct {
	ServiceName string          `json:"service_name"`
	Provider    string          `json:"provider"`
	Providers   ProvidersConfig `json:"providers"`
}

type JaegerConfig

type JaegerConfig struct {
	LocalAgentAddress string         `json:"local_agent_address"`
	Sampling          JaegerSampling `json:"sampling"`
}

type JaegerSampling

type JaegerSampling struct {
	ServerURL string `json:"server_url"`
}

type ProvidersConfig

type ProvidersConfig struct {
	Jaeger JaegerConfig `json:"jaeger"`
}

type Tracer

type Tracer struct {
	Config *Config
	// contains filtered or unexported fields
}

func New

func New(name string, l *logrusx.Logger, c *Config) (*Tracer, error)

Creates a new tracer. If name is empty, a default tracer name is used instead. See: https://godocs.io/go.opentelemetry.io/otel/sdk/trace#TracerProvider.Tracer

func NewNoop

func NewNoop(l *logrusx.Logger, c *Config) *Tracer

Creates a new no-op tracer.

func (*Tracer) IsLoaded

func (t *Tracer) IsLoaded() bool

IsLoaded returns true if the tracer has been loaded.

func (*Tracer) Tracer

func (t *Tracer) Tracer() trace.Tracer

Returns the wrapped tracer.