telemetry

Documentation

Index

• Constants
• func ConfiguredCloudExporters(ctx context.Context) (sdktrace.SpanExporter, sdklog.Exporter, bool)
• func MeasuringStreamClientInterceptor() grpc.StreamClientInterceptor
• func MeasuringUnaryClientInterceptor() grpc.UnaryClientInterceptor
• func MeasuringUnaryServerInterceptor() grpc.UnaryServerInterceptor
• func URLForTrace(ctx context.Context) (url string, msg string, ok bool)
• type LabelFlag
  • func NewLabelFlag() LabelFlag
  • func (flag LabelFlag) Set(s string) error
  • func (flag LabelFlag) String() string
  • func (flag LabelFlag) Type() string
• type Labels
  • func LoadDefaultLabels(workdir, clientEngineVersion string) Labels
  • func (labels *Labels) UnmarshalJSON(dt []byte) error
  • func (labels Labels) UserAgent() string
  • func (labels Labels) WithAnonymousGitLabels(workdir string) Labels
  • func (labels Labels) WithCILabels() Labels
  • func (labels Labels) WithCircleCILabels() Labels
  • func (labels Labels) WithClientLabels(engineVersion string) Labels
  • func (labels Labels) WithEngineLabel(engineName string) Labels
  • func (labels Labels) WithGitHubLabels() Labels
  • func (labels Labels) WithGitLabLabels() Labels
  • func (labels Labels) WithGitLabels(workdir string) Labels
  • func (labels Labels) WithJenkinsLabels() Labels
  • func (labels Labels) WithServerLabels(engineVersion, os, arch string, cacheEnabled bool) Labels
  • func (labels Labels) WithVCSLabels(workdir string) Labels
• type SpanHeartbeater
  • func NewSpanHeartbeater(exp sdktrace.SpanExporter) *SpanHeartbeater
  • func (p *SpanHeartbeater) ExportSpans(ctx context.Context, spans []sdktrace.ReadOnlySpan) error
  • func (p *SpanHeartbeater) Shutdown(ctx context.Context) error

Constants

const HeartbeatInterval = 30 * time.Second

Functions

func ConfiguredCloudExporters

func ConfiguredCloudExporters(ctx context.Context) (sdktrace.SpanExporter, sdklog.Exporter, bool)

func MeasuringStreamClientInterceptor

func MeasuringStreamClientInterceptor() grpc.StreamClientInterceptor

func MeasuringUnaryClientInterceptor

func MeasuringUnaryClientInterceptor() grpc.UnaryClientInterceptor

func MeasuringUnaryServerInterceptor

func MeasuringUnaryServerInterceptor() grpc.UnaryServerInterceptor

func URLForTrace

func URLForTrace(ctx context.Context) (url string, msg string, ok bool)

Types

type LabelFlag

type LabelFlag struct {
	Labels
}

func NewLabelFlag

func NewLabelFlag() LabelFlag

func (LabelFlag) Set

func (flag LabelFlag) Set(s string) error

func (LabelFlag) String

func (flag LabelFlag) String() string

func (LabelFlag) Type

func (flag LabelFlag) Type() string

type Labels

type Labels map[string]string

func LoadDefaultLabels

func LoadDefaultLabels(workdir, clientEngineVersion string) Labels

func (*Labels) UnmarshalJSON

func (labels *Labels) UnmarshalJSON(dt []byte) error

func (Labels) UserAgent

func (labels Labels) UserAgent() string

func (Labels) WithAnonymousGitLabels

func (labels Labels) WithAnonymousGitLabels(workdir string) Labels

func (Labels) WithCILabels

func (labels Labels) WithCILabels() Labels

func (Labels) WithCircleCILabels

func (labels Labels) WithCircleCILabels() Labels

func (Labels) WithClientLabels

func (labels Labels) WithClientLabels(engineVersion string) Labels

func (Labels) WithEngineLabel

func (labels Labels) WithEngineLabel(engineName string) Labels

func (Labels) WithGitHubLabels

func (labels Labels) WithGitHubLabels() Labels

func (Labels) WithGitLabLabels

func (labels Labels) WithGitLabLabels() Labels

func (Labels) WithGitLabels

func (labels Labels) WithGitLabels(workdir string) Labels

func (Labels) WithJenkinsLabels

func (labels Labels) WithJenkinsLabels() Labels

func (Labels) WithServerLabels

func (labels Labels) WithServerLabels(engineVersion, os, arch string, cacheEnabled bool) Labels

func (Labels) WithVCSLabels

func (labels Labels) WithVCSLabels(workdir string) Labels

type SpanHeartbeater

type SpanHeartbeater struct {
	sdktrace.SpanExporter
	// contains filtered or unexported fields
}

SpanHeartbeater is a SpanExporter that keeps track of live spans and re-exports them periodically to the underlying SpanExporter to indicate that they are indeed still live.

func NewSpanHeartbeater

func NewSpanHeartbeater(exp sdktrace.SpanExporter) *SpanHeartbeater

func (*SpanHeartbeater) ExportSpans

func (p *SpanHeartbeater) ExportSpans(ctx context.Context, spans []sdktrace.ReadOnlySpan) error

func (*SpanHeartbeater) Shutdown

func (p *SpanHeartbeater) Shutdown(ctx context.Context) error