testutil

Mar 20, 2024

Changes in this version

+ func RandomSpanLink() *pb.SpanLink

+ func RandomSpanLinks() []*pb.SpanLink

May 31, 2023

Changes in this version

type OTLPSpan

+ Links []OTLPSpanLink

+ type OTLPSpanLink struct

+ Attributes map[string]interface{}

+ Dropped uint32

+ SpanID string

+ TraceID string

+ TraceState string

Jan 18, 2023

Changes in this version

+ func WithStatsClient(c metrics.StatsClient) func()

Oct 31, 2022

Changes in this version

+ func StatsPayloadSample() pb.ClientStatsPayload

May 23, 2022

Changes in this version

+ var OTLPFixedSpanID = pdata.NewSpanID([8]byte{ ... })

+ var OTLPFixedTraceID = pdata.NewTraceID([16]byte{ ... })

+ var YearNS = (time.Hour * 24 * 365).Nanoseconds()

+ func BucketWithSpans(spans []*pb.Span) pb.ClientStatsBucket

+ func FindTCPPort() (int, error)

+ func FreeTCPPort(t *testing.T) int

+ func GeneratePayload(n int, tc *TraceConfig, sc *SpanConfig) pb.Traces

+ func GenerateSpan(c *SpanConfig) *pb.Span

+ func GenerateTrace(tc *TraceConfig, sc *SpanConfig) pb.Trace

+ func GetTestSpan() *pb.Span

+ func GetTestTraceChunks(traceN, size int, realisticIDs bool) []*pb.TraceChunk

+ func GetTestTraces(traceN, size int, realisticIDs bool) pb.Traces

+ func NewOTLPSpan(s *OTLPSpan) pdata.Span

+ func NewOTLPTracesRequest(defs []OTLPResourceSpan) otlpgrpc.TracesRequest

+ func RandomBucket(n int) pb.ClientStatsBucket

+ func RandomSizedBytes(size int) []byte

+ func RandomSpan() *pb.Span

+ func RandomSpanDuration() int64

+ func RandomSpanError() int32

+ func RandomSpanID() uint64

+ func RandomSpanMeta() map[string]string

+ func RandomSpanMetrics() map[string]float64

+ func RandomSpanName() string

+ func RandomSpanParentID() uint64

+ func RandomSpanResource() string

+ func RandomSpanService() string

+ func RandomSpanStart() int64

+ func RandomSpanTraceID() uint64

+ func RandomSpanType() string

+ func RandomStringMap() map[string]string

+ func RandomTrace(maxLevels, maxSpans int) pb.Trace

+ func RandomTraceChunk(maxLevels, maxSpans int) *pb.TraceChunk

+ func SetOTLPSpan(span pdata.Span, s *OTLPSpan)

+ func TestSpan() *pb.Span

+ func TraceChunkWithSpan(span *pb.Span) *pb.TraceChunk

+ func TraceChunkWithSpanAndPriority(span *pb.Span, priority int32) *pb.TraceChunk

+ func TraceChunkWithSpans(spans []*pb.Span) *pb.TraceChunk

+ func TraceChunkWithSpansAndPriority(spans []*pb.Span, priority int32) *pb.TraceChunk

+ func TracerPayloadWithChunk(chunk *pb.TraceChunk) *pb.TracerPayload

+ func TracerPayloadWithChunks(chunks []*pb.TraceChunk) *pb.TracerPayload

+ func WithFeatures(feats string) (undo func())

+ type CountSummary struct

+ Calls []MetricsArgs

+ Sum int64

+ type GaugeSummary struct

+ Calls []MetricsArgs

+ Last float64

+ Max float64

+ type MetricsArgs struct

+ Name string

+ Rate float64

+ Tags []string

+ Value float64

+ type OTLPResourceSpan struct

+ Attributes map[string]interface{}

+ LibName string

+ LibVersion string

+ Spans []*OTLPSpan

+ type OTLPSpan struct

+ Attributes map[string]interface{}

+ End uint64

+ Events []OTLPSpanEvent

+ Kind pdata.SpanKind

+ Name string

+ ParentID [8]byte

+ SpanID [8]byte

+ Start uint64

+ StatusCode pdata.StatusCode

+ StatusMsg string

+ TraceID [16]byte

+ TraceState string

+ type OTLPSpanEvent struct

+ Attributes map[string]interface{}

+ Dropped uint32

+ Name string

+ Timestamp uint64

+ type SpanConfig struct

+ MaxTags int

+ MinTags int

+ type TestBackoffTimer struct

+ func NewTestBackoffTimer() *TestBackoffTimer

+ func (t *TestBackoffTimer) Close()

+ func (t *TestBackoffTimer) CurrentDelay() time.Duration

+ func (t *TestBackoffTimer) NumRetries() int

+ func (t *TestBackoffTimer) ReceiveTick() <-chan time.Time

+ func (t *TestBackoffTimer) Reset()

+ func (t *TestBackoffTimer) ScheduleRetry(err error) (int, time.Duration)

+ func (t *TestBackoffTimer) Stop()

+ func (t *TestBackoffTimer) TriggerTick()

+ type TestStatsClient struct

+ CountCalls []MetricsArgs

+ CountErr error

+ GaugeCalls []MetricsArgs

+ GaugeErr error

+ HistogramCalls []MetricsArgs

+ HistogramErr error

+ TimingCalls []MetricsArgs

+ TimingErr error

+ func (c *TestStatsClient) Count(name string, value int64, tags []string, rate float64) error

+ func (c *TestStatsClient) Flush() error

+ func (c *TestStatsClient) Gauge(name string, value float64, tags []string, rate float64) error

+ func (c *TestStatsClient) GetCountSummaries() map[string]*CountSummary

+ func (c *TestStatsClient) GetGaugeSummaries() map[string]*GaugeSummary

+ func (c *TestStatsClient) Histogram(name string, value float64, tags []string, rate float64) error

+ func (c *TestStatsClient) Reset()

+ func (c *TestStatsClient) Timing(name string, value time.Duration, tags []string, rate float64) error

+ type TraceConfig struct

+ Keep bool

+ MaxSpans int

+ MinSpans int