tracing

package
v0.0.26 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 19, 2023 License: MIT Imports: 51 Imported by: 0

Documentation

Index

Constants

View Source 
const Name = "jaeger"

Variables

View Source 
var File_tracing_conf_proto protoreflect.FileDescriptor

Functions

func Client 

func Client(opts ...Option) middleware.Middleware

Client returns a new client middleware for OpenTelemetry.

func Server 

func Server(opts ...Option) middleware.Middleware

Server returns a new server middleware for OpenTelemetry.

func SpanID 

func SpanID() log.Valuer

SpanID returns a spanid valuer.

func TraceID 

func TraceID() log.Valuer

TraceID returns a traceid valuer.

Types

type ClientHandler 

type ClientHandler struct{}

ClientHandler is tracing ClientHandler

func (*ClientHandler) HandleConn 

func (c *ClientHandler) HandleConn(ctx context.Context, cs stats.ConnStats)

HandleConn exists to satisfy gRPC stats.Handler.

func (*ClientHandler) HandleRPC 

func (c *ClientHandler) HandleRPC(ctx context.Context, rs stats.RPCStats)

HandleRPC implements per-RPC tracing and stats instrumentation.

func (*ClientHandler) TagConn 

func (c *ClientHandler) TagConn(ctx context.Context, cti *stats.ConnTagInfo) context.Context

TagConn exists to satisfy gRPC stats.Handler.

func (*ClientHandler) TagRPC 

func (c *ClientHandler) TagRPC(ctx context.Context, rti *stats.RPCTagInfo) context.Context

TagRPC implements per-RPC context management.

type Conf 

type Conf struct {
	Jaeger *Jaeger     `protobuf:"bytes,1,opt,name=jaeger,proto3" json:"jaeger,omitempty"`
	Stdout *Stdout     `protobuf:"bytes,2,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Otlp   *Otlp       `protobuf:"bytes,3,opt,name=otlp,proto3" json:"otlp,omitempty"`
	Prom   *Prometheus `protobuf:"bytes,4,opt,name=prom,proto3" json:"prom,omitempty"`
	// contains filtered or unexported fields
}

func (*Conf) Descriptor deprecated 

func (*Conf) Descriptor() ([]byte, []int)

Deprecated: Use Conf.ProtoReflect.Descriptor instead.

func (*Conf) GetJaeger 

func (x *Conf) GetJaeger() *Jaeger

func (*Conf) GetOtlp added in v0.0.8 

func (x *Conf) GetOtlp() *Otlp

func (*Conf) GetProm added in v0.0.8 

func (x *Conf) GetProm() *Prometheus

func (*Conf) GetStdout 

func (x *Conf) GetStdout() *Stdout

func (*Conf) ProtoMessage 

func (*Conf) ProtoMessage()

func (*Conf) ProtoReflect 

func (x *Conf) ProtoReflect() protoreflect.Message

func (*Conf) Reset 

func (x *Conf) Reset()

func (*Conf) String 

func (x *Conf) String() string

func (*Conf) Validate 

func (m *Conf) Validate() error

Validate checks the field values on Conf with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Conf) ValidateAll added in v0.0.8 

func (m *Conf) ValidateAll() error

ValidateAll checks the field values on Conf with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ConfMultiError, or nil if none found.

type ConfMultiError added in v0.0.8 

type ConfMultiError []error

ConfMultiError is an error wrapping multiple validation errors returned by Conf.ValidateAll() if the designated constraints aren't met.

func (ConfMultiError) AllErrors added in v0.0.8 

func (m ConfMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ConfMultiError) Error added in v0.0.8 

func (m ConfMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ConfValidationError 

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

ConfValidationError is the validation error returned by Conf.Validate if the designated constraints aren't met.

func (ConfValidationError) Cause 

func (e ConfValidationError) Cause() error

Cause function returns cause value.

func (ConfValidationError) Error 

func (e ConfValidationError) Error() string

Error satisfies the builtin error interface

func (ConfValidationError) ErrorName 

func (e ConfValidationError) ErrorName() string

ErrorName returns error name.

func (ConfValidationError) Field 

func (e ConfValidationError) Field() string

Field function returns field value.

func (ConfValidationError) Key 

func (e ConfValidationError) Key() bool

Key function returns key value.

func (ConfValidationError) Reason 

func (e ConfValidationError) Reason() string

Reason function returns reason value.

type Jaeger 

type Jaeger struct {
	Enable   bool   `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"`
	Endpoint string `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Metrics  bool   `protobuf:"varint,3,opt,name=metrics,proto3" json:"metrics,omitempty"`
	Traces   bool   `protobuf:"varint,4,opt,name=traces,proto3" json:"traces,omitempty"`
	// contains filtered or unexported fields
}

func (*Jaeger) Descriptor deprecated 

func (*Jaeger) Descriptor() ([]byte, []int)

Deprecated: Use Jaeger.ProtoReflect.Descriptor instead.

func (*Jaeger) GetEnable 

func (x *Jaeger) GetEnable() bool

func (*Jaeger) GetEndpoint 

func (x *Jaeger) GetEndpoint() string

func (*Jaeger) GetMetrics 

func (x *Jaeger) GetMetrics() bool

func (*Jaeger) GetTraces 

func (x *Jaeger) GetTraces() bool

func (*Jaeger) ProtoMessage 

func (*Jaeger) ProtoMessage()

func (*Jaeger) ProtoReflect 

func (x *Jaeger) ProtoReflect() protoreflect.Message

func (*Jaeger) Reset 

func (x *Jaeger) Reset()

func (*Jaeger) String 

func (x *Jaeger) String() string

func (*Jaeger) Validate 

func (m *Jaeger) Validate() error

Validate checks the field values on Jaeger with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Jaeger) ValidateAll added in v0.0.8 

func (m *Jaeger) ValidateAll() error

ValidateAll checks the field values on Jaeger with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in JaegerMultiError, or nil if none found.

type JaegerMultiError added in v0.0.8 

type JaegerMultiError []error

JaegerMultiError is an error wrapping multiple validation errors returned by Jaeger.ValidateAll() if the designated constraints aren't met.

func (JaegerMultiError) AllErrors added in v0.0.8 

func (m JaegerMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (JaegerMultiError) Error added in v0.0.8 

func (m JaegerMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type JaegerValidationError 

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

JaegerValidationError is the validation error returned by Jaeger.Validate if the designated constraints aren't met.

func (JaegerValidationError) Cause 

func (e JaegerValidationError) Cause() error

Cause function returns cause value.

func (JaegerValidationError) Error 

func (e JaegerValidationError) Error() string

Error satisfies the builtin error interface

func (JaegerValidationError) ErrorName 

func (e JaegerValidationError) ErrorName() string

ErrorName returns error name.

func (JaegerValidationError) Field 

func (e JaegerValidationError) Field() string

Field function returns field value.

func (JaegerValidationError) Key 

func (e JaegerValidationError) Key() bool

Key function returns key value.

func (JaegerValidationError) Reason 

func (e JaegerValidationError) Reason() string

Reason function returns reason value.

type Metadata 

type Metadata struct{}

Metadata is tracing metadata propagator

func (Metadata) Extract 

func (b Metadata) Extract(parent context.Context, carrier propagation.TextMapCarrier) context.Context

Extract returns a copy of parent with the metadata from the carrier added.

func (Metadata) Fields 

func (b Metadata) Fields() []string

Fields returns the keys who's values are set with Inject.

func (Metadata) Inject 

func (b Metadata) Inject(ctx context.Context, carrier propagation.TextMapCarrier)

Inject sets metadata key-values from ctx into the carrier.

type Option 

type Option func(*options)

Option is tracing option.

func WithPropagator 

func WithPropagator(propagator propagation.TextMapPropagator) Option

WithPropagator with tracer propagator.

func WithTracerProvider 

func WithTracerProvider(provider trace.TracerProvider) Option

WithTracerProvider with tracer provider. Deprecated: use otel.SetTracerProvider(provider) instead.

type Otlp added in v0.0.8 

type Otlp struct {
	Enable   bool   `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"`
	Endpoint string `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Metrics  bool   `protobuf:"varint,3,opt,name=metrics,proto3" json:"metrics,omitempty"`
	Traces   bool   `protobuf:"varint,4,opt,name=traces,proto3" json:"traces,omitempty"`
	// contains filtered or unexported fields
}

func (*Otlp) Descriptor deprecated added in v0.0.8 

func (*Otlp) Descriptor() ([]byte, []int)

Deprecated: Use Otlp.ProtoReflect.Descriptor instead.

func (*Otlp) GetEnable added in v0.0.8 

func (x *Otlp) GetEnable() bool

func (*Otlp) GetEndpoint added in v0.0.8 

func (x *Otlp) GetEndpoint() string

func (*Otlp) GetMetrics added in v0.0.8 

func (x *Otlp) GetMetrics() bool

func (*Otlp) GetTraces added in v0.0.8 

func (x *Otlp) GetTraces() bool

func (*Otlp) ProtoMessage added in v0.0.8 

func (*Otlp) ProtoMessage()

func (*Otlp) ProtoReflect added in v0.0.8 

func (x *Otlp) ProtoReflect() protoreflect.Message

func (*Otlp) Reset added in v0.0.8 

func (x *Otlp) Reset()

func (*Otlp) String added in v0.0.8 

func (x *Otlp) String() string

func (*Otlp) Validate added in v0.0.8 

func (m *Otlp) Validate() error

Validate checks the field values on Otlp with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Otlp) ValidateAll added in v0.0.8 

func (m *Otlp) ValidateAll() error

ValidateAll checks the field values on Otlp with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in OtlpMultiError, or nil if none found.

type OtlpMultiError added in v0.0.8 

type OtlpMultiError []error

OtlpMultiError is an error wrapping multiple validation errors returned by Otlp.ValidateAll() if the designated constraints aren't met.

func (OtlpMultiError) AllErrors added in v0.0.8 

func (m OtlpMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (OtlpMultiError) Error added in v0.0.8 

func (m OtlpMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type OtlpValidationError added in v0.0.8 

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

OtlpValidationError is the validation error returned by Otlp.Validate if the designated constraints aren't met.

func (OtlpValidationError) Cause added in v0.0.8 

func (e OtlpValidationError) Cause() error

Cause function returns cause value.

func (OtlpValidationError) Error added in v0.0.8 

func (e OtlpValidationError) Error() string

Error satisfies the builtin error interface

func (OtlpValidationError) ErrorName added in v0.0.8 

func (e OtlpValidationError) ErrorName() string

ErrorName returns error name.

func (OtlpValidationError) Field added in v0.0.8 

func (e OtlpValidationError) Field() string

Field function returns field value.

func (OtlpValidationError) Key added in v0.0.8 

func (e OtlpValidationError) Key() bool

Key function returns key value.

func (OtlpValidationError) Reason added in v0.0.8 

func (e OtlpValidationError) Reason() string

Reason function returns reason value.

type Prometheus added in v0.0.8 

type Prometheus struct {
	Enable  bool `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"`
	Metrics bool `protobuf:"varint,2,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*Prometheus) Descriptor deprecated added in v0.0.8 

func (*Prometheus) Descriptor() ([]byte, []int)

Deprecated: Use Prometheus.ProtoReflect.Descriptor instead.

func (*Prometheus) GetEnable added in v0.0.8 

func (x *Prometheus) GetEnable() bool

func (*Prometheus) GetMetrics added in v0.0.8 

func (x *Prometheus) GetMetrics() bool

func (*Prometheus) ProtoMessage added in v0.0.8 

func (*Prometheus) ProtoMessage()

func (*Prometheus) ProtoReflect added in v0.0.8 

func (x *Prometheus) ProtoReflect() protoreflect.Message

func (*Prometheus) Reset added in v0.0.8 

func (x *Prometheus) Reset()

func (*Prometheus) String added in v0.0.8 

func (x *Prometheus) String() string

func (*Prometheus) Validate added in v0.0.8 

func (m *Prometheus) Validate() error

Validate checks the field values on Prometheus with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Prometheus) ValidateAll added in v0.0.8 

func (m *Prometheus) ValidateAll() error

ValidateAll checks the field values on Prometheus with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PrometheusMultiError, or nil if none found.

type PrometheusMultiError added in v0.0.8 

type PrometheusMultiError []error

PrometheusMultiError is an error wrapping multiple validation errors returned by Prometheus.ValidateAll() if the designated constraints aren't met.

func (PrometheusMultiError) AllErrors added in v0.0.8 

func (m PrometheusMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PrometheusMultiError) Error added in v0.0.8 

func (m PrometheusMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PrometheusValidationError added in v0.0.8 

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

PrometheusValidationError is the validation error returned by Prometheus.Validate if the designated constraints aren't met.

func (PrometheusValidationError) Cause added in v0.0.8 

func (e PrometheusValidationError) Cause() error

Cause function returns cause value.

func (PrometheusValidationError) Error added in v0.0.8 

func (e PrometheusValidationError) Error() string

Error satisfies the builtin error interface

func (PrometheusValidationError) ErrorName added in v0.0.8 

func (e PrometheusValidationError) ErrorName() string

ErrorName returns error name.

func (PrometheusValidationError) Field added in v0.0.8 

func (e PrometheusValidationError) Field() string

Field function returns field value.

func (PrometheusValidationError) Key added in v0.0.8 

func (e PrometheusValidationError) Key() bool

Key function returns key value.

func (PrometheusValidationError) Reason added in v0.0.8 

func (e PrometheusValidationError) Reason() string

Reason function returns reason value.

type Provider 

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

func MustNewProvider 

func MustNewProvider(c *Conf, serviceName string, uuid string) *Provider

func NewProvider 

func NewProvider(c *Conf, serviceName string, uuid string) (*Provider, error)

NewProvider Get trace provider

func (*Provider) Close 

func (o *Provider) Close()

type Stdout 

type Stdout struct {
	Enable       bool   `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"`
	Traces       bool   `protobuf:"varint,2,opt,name=traces,proto3" json:"traces,omitempty"`
	TraceOutput  string `protobuf:"bytes,3,opt,name=trace_output,json=traceOutput,proto3" json:"trace_output,omitempty"`
	Metrics      bool   `protobuf:"varint,4,opt,name=metrics,proto3" json:"metrics,omitempty"`
	MetricOutput string `protobuf:"bytes,5,opt,name=metric_output,json=metricOutput,proto3" json:"metric_output,omitempty"`
	// contains filtered or unexported fields
}

func (*Stdout) Descriptor deprecated 

func (*Stdout) Descriptor() ([]byte, []int)

Deprecated: Use Stdout.ProtoReflect.Descriptor instead.

func (*Stdout) GetEnable 

func (x *Stdout) GetEnable() bool

func (*Stdout) GetMetricOutput added in v0.0.8 

func (x *Stdout) GetMetricOutput() string

func (*Stdout) GetMetrics 

func (x *Stdout) GetMetrics() bool

func (*Stdout) GetTraceOutput added in v0.0.8 

func (x *Stdout) GetTraceOutput() string

func (*Stdout) GetTraces 

func (x *Stdout) GetTraces() bool

func (*Stdout) ProtoMessage 

func (*Stdout) ProtoMessage()

func (*Stdout) ProtoReflect 

func (x *Stdout) ProtoReflect() protoreflect.Message

func (*Stdout) Reset 

func (x *Stdout) Reset()

func (*Stdout) String 

func (x *Stdout) String() string

func (*Stdout) Validate 

func (m *Stdout) Validate() error

Validate checks the field values on Stdout with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Stdout) ValidateAll added in v0.0.8 

func (m *Stdout) ValidateAll() error

ValidateAll checks the field values on Stdout with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StdoutMultiError, or nil if none found.

type StdoutMultiError added in v0.0.8 

type StdoutMultiError []error

StdoutMultiError is an error wrapping multiple validation errors returned by Stdout.ValidateAll() if the designated constraints aren't met.

func (StdoutMultiError) AllErrors added in v0.0.8 

func (m StdoutMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StdoutMultiError) Error added in v0.0.8 

func (m StdoutMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type StdoutValidationError 

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

StdoutValidationError is the validation error returned by Stdout.Validate if the designated constraints aren't met.

func (StdoutValidationError) Cause 

func (e StdoutValidationError) Cause() error

Cause function returns cause value.

func (StdoutValidationError) Error 

func (e StdoutValidationError) Error() string

Error satisfies the builtin error interface

func (StdoutValidationError) ErrorName 

func (e StdoutValidationError) ErrorName() string

ErrorName returns error name.

func (StdoutValidationError) Field 

func (e StdoutValidationError) Field() string

Field function returns field value.

func (StdoutValidationError) Key 

func (e StdoutValidationError) Key() bool

Key function returns key value.

func (StdoutValidationError) Reason 

func (e StdoutValidationError) Reason() string

Reason function returns reason value.

type TraceContext 

type TraceContext struct{}

TraceContext is a propagator that supports the W3C Trace Context format (https://www.w3.org/TR/trace-context/)

This propagator will propagate the traceparent and tracestate headers to guarantee traces are not broken. It is up to the users of this propagator to choose if they want to participate in a trace by modifying the traceparent header and relevant parts of the tracestate header containing their proprietary information.

func (TraceContext) Extract 

func (tc TraceContext) Extract(ctx context.Context, carrier propagation.TextMapCarrier) context.Context

Extract reads tracecontext from the carrier into a returned Context.

The returned Context will be a copy of ctx and contain the extracted tracecontext as the remote SpanContext. If the extracted tracecontext is invalid, the passed ctx will be returned directly instead.

func (TraceContext) Fields 

func (tc TraceContext) Fields() []string

Fields returns the keys who's values are set with Inject.

func (TraceContext) Inject 

func (tc TraceContext) Inject(ctx context.Context, carrier propagation.TextMapCarrier)

Inject set tracecontext from the Context into the carrier.

type Tracer 

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

Tracer is otel span tracer

func NewTracer 

func NewTracer(kind trace.SpanKind, opts ...Option) *Tracer

NewTracer create tracer instance

func (*Tracer) End 

func (t *Tracer) End(ctx context.Context, span trace.Span, m interface{}, err error)

End finish tracing span

func (*Tracer) Start 

func (t *Tracer) Start(ctx context.Context, operation string, carrier propagation.TextMapCarrier) (context.Context, trace.Span)

Start start tracing span

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.