tracing

Documentation

Index

• Variables
• func NewFileTraceExporter(_ context.Context, o *FileTracingOptions) (sdktrace.SpanExporter, error)
• func NewGRPCTraceExporter(ctx context.Context, o *GRPCClientOptions) (sdktrace.SpanExporter, error)
• func NewHTTPTraceExporter(ctx context.Context, o *HTTPClientOptions) (sdktrace.SpanExporter, error)
• func NewNopTraceExporter(_ context.Context) (sdktrace.SpanExporter, error)
• func NewTraceProvider(ctx context.Context, o *TraceOptions) (p *sdktrace.TracerProvider, err error)
• func NewZipkinTraceExporter(_ context.Context, o *ZipkinClientOptions) (sdktrace.SpanExporter, error)
• func SetTraceOptions(o *TraceOptions)
• type Compression
  • func (c *Compression) UnmarshalJSON(data []byte) (err error)
• type FileTracing
  • func (t *FileTracing) Shutdown(ctx context.Context) error
• type FileTracingOptions
• type GRPCClientOptions
• type HTTPClientOptions
  • func (c *HTTPClientOptions) UnmarshalJSON(data []byte) (err error)
• type RetryOptions
  • func (c *RetryOptions) UnmarshalJSON(data []byte) (err error)
• type TraceOptions
  • func (o *TraceOptions) MarshalJSONPB(marshaller *jsonpb.Marshaler) ([]byte, error)
  • func (o *TraceOptions) ProtoMessage()
  • func (o *TraceOptions) Reset()
  • func (o TraceOptions) String() string
  • func (o *TraceOptions) UnmarshalJSON(data []byte) (err error)
• type ZipkinClientOptions

Variables

var DefaultRetryConfig = RetryOptions{
	Enabled:         true,
	InitialInterval: 5 * time.Second,
	MaxInterval:     30 * time.Second,
	MaxElapsedTime:  time.Minute,
}

Functions

func NewFileTraceExporter

func NewFileTraceExporter(_ context.Context, o *FileTracingOptions) (sdktrace.SpanExporter, error)

func NewGRPCTraceExporter

func NewGRPCTraceExporter(ctx context.Context, o *GRPCClientOptions) (sdktrace.SpanExporter, error)

func NewHTTPTraceExporter

func NewHTTPTraceExporter(ctx context.Context, o *HTTPClientOptions) (sdktrace.SpanExporter, error)

func NewNopTraceExporter

func NewNopTraceExporter(_ context.Context) (sdktrace.SpanExporter, error)

func NewTraceProvider

func NewTraceProvider(ctx context.Context, o *TraceOptions) (p *sdktrace.TracerProvider, err error)

func NewZipkinTraceExporter

func NewZipkinTraceExporter(_ context.Context, o *ZipkinClientOptions) (sdktrace.SpanExporter, error)

func SetTraceOptions

func SetTraceOptions(o *TraceOptions)

Types

type Compression

type Compression int

func (*Compression) UnmarshalJSON

func (c *Compression) UnmarshalJSON(data []byte) (err error)

type FileTracing

type FileTracing struct {
	*stdouttrace.Exporter
	// contains filtered or unexported fields
}

func (*FileTracing) Shutdown

func (t *FileTracing) Shutdown(ctx context.Context) error

type FileTracingOptions

type FileTracingOptions struct {
	Path string `json:"path" yaml:"path" mapstructure:"path"`
}

type GRPCClientOptions

type GRPCClientOptions struct {
	Endpoint           string            `json:"endpoint" yaml:"endpoint" mapstructure:"endpoint"`
	Timeout            time.Duration     `json:"timeout" yaml:"timeout" mapstructure:"timeout"`
	Insecure           bool              `json:"insecure" yaml:"insecure" mapstructure:"insecure"`
	Retry              RetryOptions      `json:"retry" yaml:"retry" mapstructure:"retry"`
	Compression        Compression       `json:"compression" yaml:"compression" mapstructure:"compression"`
	Header             map[string]string `json:"header" yaml:"header" mapstructure:"header"`
	TLSConfig          tls.TLSOptions    `json:"tls_config" yaml:"tls_config" mapstructure:"tls_config"`
	URLPath            string            `json:"url_path" yaml:"url_path" mapstructure:"url_path"`
	ReconnectionPeriod time.Duration     `json:"reconnection_period" yaml:"reconnection_period" mapstructure:"reconnection_period"`
	ServiceConfig      string            `json:"service_config" yaml:"service_config" mapstructure:"service_config"`
}

type HTTPClientOptions

type HTTPClientOptions struct {
	Endpoint    string            `json:"endpoint" yaml:"endpoint" mapstructure:"endpoint"`
	Timeout     time.Duration     `json:"timeout" yaml:"timeout" mapstructure:"timeout"`
	Insecure    bool              `json:"insecure" yaml:"insecure" mapstructure:"insecure"`
	Retry       RetryOptions      `json:"retry" yaml:"retry" mapstructure:"retry"`
	Compression Compression       `json:"compression" yaml:"compression" mapstructure:"compression"`
	Header      map[string]string `json:"header" yaml:"header" mapstructure:"header"`
	TLSConfig   *tls.TLSOptions   `json:"tls_config" yaml:"tls_config" mapstructure:"tls_config"`
	URLPath     string            `json:"url_path" yaml:"url_path" mapstructure:"url_path"`
}

func (*HTTPClientOptions) UnmarshalJSON

func (c *HTTPClientOptions) UnmarshalJSON(data []byte) (err error)

type RetryOptions

type RetryOptions struct {
	Enabled         bool
	InitialInterval time.Duration
	MaxInterval     time.Duration
	MaxElapsedTime  time.Duration
}

func (*RetryOptions) UnmarshalJSON

func (c *RetryOptions) UnmarshalJSON(data []byte) (err error)

type TraceOptions

type TraceOptions struct {
	HTTP        *HTTPClientOptions   `json:"http" yaml:"http" mapstructure:"http"`
	GRPC        *GRPCClientOptions   `json:"grpc" yaml:"grpc" mapstructure:"grpc"`
	Zipkin      *ZipkinClientOptions `json:"zipkin" yaml:"zipkin" mapstructure:"zipkin"`
	File        *FileTracingOptions  `json:"file" yaml:"file" mapstructure:"file"`
	ServiceName string               `json:"service_name" yaml:"service_name" mapstructure:"service_name"`
}

var DefaultOptions *TraceOptions

func (*TraceOptions) MarshalJSONPB

func (o *TraceOptions) MarshalJSONPB(marshaller *jsonpb.Marshaler) ([]byte, error)

func (*TraceOptions) ProtoMessage

func (o *TraceOptions) ProtoMessage()

ProtoMessage implement proto.Message

func (*TraceOptions) Reset

func (o *TraceOptions) Reset()

Reset *implement proto.Message*

func (TraceOptions) String

func (o TraceOptions) String() string

String implement proto.Message

func (*TraceOptions) UnmarshalJSON

func (o *TraceOptions) UnmarshalJSON(data []byte) (err error)

type ZipkinClientOptions

type ZipkinClientOptions struct {
	Endpoint string `json:"endpoint" yaml:"endpoint" mapstructure:"endpoint"`
}