package otlptest

import "go.opentelemetry.io/otel/exporters/otlp/internal/otlptest"

Index ¶

• func RunEndToEndTest(ctx context.Context, t *testing.T, exp *otlp.Exporter, mcTraces, mcMetrics Collector)
• func SingleSpanSnapshot() []*tracesdk.SpanSnapshot
• type Collector
• type EmptyCheckpointSet
• func (EmptyCheckpointSet) ForEach(kindSelector exportmetric.ExportKindSelector, recordFunc func(exportmetric.Record) error) error
• func (EmptyCheckpointSet) Lock()
• func (EmptyCheckpointSet) RLock()
• func (EmptyCheckpointSet) RUnlock()
• func (EmptyCheckpointSet) Unlock()
• type FailCheckpointSet
• func (FailCheckpointSet) ForEach(kindSelector exportmetric.ExportKindSelector, recordFunc func(exportmetric.Record) error) error
• func (FailCheckpointSet) Lock()
• func (FailCheckpointSet) RLock()
• func (FailCheckpointSet) RUnlock()
• func (FailCheckpointSet) Unlock()
• type MetricsStorage
• func NewMetricsStorage() MetricsStorage
• func (s *MetricsStorage) AddMetrics(request *collectormetricpb.ExportMetricsServiceRequest)
• func (s *MetricsStorage) GetMetrics() []*metricpb.Metric
• type OneRecordCheckpointSet
• func (OneRecordCheckpointSet) ForEach(kindSelector exportmetric.ExportKindSelector, recordFunc func(exportmetric.Record) error) error
• func (OneRecordCheckpointSet) Lock()
• func (OneRecordCheckpointSet) RLock()
• func (OneRecordCheckpointSet) RUnlock()
• func (OneRecordCheckpointSet) Unlock()
• type SpansStorage
• func NewSpansStorage() SpansStorage
• func (s *SpansStorage) AddSpans(request *collectortracepb.ExportTraceServiceRequest)
• func (s *SpansStorage) GetResourceSpans() []*tracepb.ResourceSpans
• func (s *SpansStorage) GetSpans() []*tracepb.Span

Functions ¶

func RunEndToEndTest ¶

func RunEndToEndTest(ctx context.Context, t *testing.T, exp *otlp.Exporter, mcTraces, mcMetrics Collector)

RunEndToEndTest can be used by protocol driver tests to validate themselves.

func SingleSpanSnapshot ¶

func SingleSpanSnapshot() []*tracesdk.SpanSnapshot

SingleSpanSnapshot returns a one-element slice with a snapshot. It may be useful for testing driver's trace export.

Types ¶

type Collector ¶

type Collector interface {
	Stop() error
	GetResourceSpans() []*tracepb.ResourceSpans
	GetMetrics() []*metricpb.Metric
}

Collector is an interface that mock collectors should implements, so they can be used for the end-to-end testing.

type EmptyCheckpointSet ¶

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

EmptyCheckpointSet is a checkpointer that has no records at all.

func (EmptyCheckpointSet) ForEach ¶

func (EmptyCheckpointSet) ForEach(kindSelector exportmetric.ExportKindSelector, recordFunc func(exportmetric.Record) error) error

ForEach implements exportmetric.CheckpointSet. It never invokes the callback.

func (EmptyCheckpointSet) Lock ¶

func (EmptyCheckpointSet) Lock()

Lock implements sync.Locker, which is needed for exportmetric.CheckpointSet.

func (EmptyCheckpointSet) RLock ¶

func (EmptyCheckpointSet) RLock()

RLock implements exportmetric.CheckpointSet.

func (EmptyCheckpointSet) RUnlock ¶

func (EmptyCheckpointSet) RUnlock()

RUnlock implements exportmetric.CheckpointSet.

func (EmptyCheckpointSet) Unlock ¶

func (EmptyCheckpointSet) Unlock()

Unlock implements sync.Locker, which is needed for exportmetric.CheckpointSet.

type FailCheckpointSet ¶

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

FailCheckpointSet is a checkpointer that returns an error during ForEach.

func (FailCheckpointSet) ForEach ¶

func (FailCheckpointSet) ForEach(kindSelector exportmetric.ExportKindSelector, recordFunc func(exportmetric.Record) error) error

ForEach implements exportmetric.CheckpointSet. It always fails.

func (FailCheckpointSet) Lock ¶

func (FailCheckpointSet) Lock()

Lock implements sync.Locker, which is needed for exportmetric.CheckpointSet.

func (FailCheckpointSet) RLock ¶

func (FailCheckpointSet) RLock()

RLock implements exportmetric.CheckpointSet.

func (FailCheckpointSet) RUnlock ¶

func (FailCheckpointSet) RUnlock()

RUnlock implements exportmetric.CheckpointSet.

func (FailCheckpointSet) Unlock ¶

func (FailCheckpointSet) Unlock()

Unlock implements sync.Locker, which is needed for exportmetric.CheckpointSet.

type MetricsStorage ¶

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

MetricsStorage stores the metrics. Mock collectors could use it to store metrics they have received.

func NewMetricsStorage ¶

func NewMetricsStorage() MetricsStorage

NewMetricsStorage creates a new metrics storage.

func (*MetricsStorage) AddMetrics ¶

func (s *MetricsStorage) AddMetrics(request *collectormetricpb.ExportMetricsServiceRequest)

AddMetrics adds metrics to the metrics storage.

func (*MetricsStorage) GetMetrics ¶

func (s *MetricsStorage) GetMetrics() []*metricpb.Metric

GetMetrics returns the stored metrics.

type OneRecordCheckpointSet ¶

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

OneRecordCheckpointSet is a CheckpointSet that returns just one filled record. It may be useful for testing driver's metrics export.

func (OneRecordCheckpointSet) ForEach ¶

func (OneRecordCheckpointSet) ForEach(kindSelector exportmetric.ExportKindSelector, recordFunc func(exportmetric.Record) error) error

ForEach implements exportmetric.CheckpointSet. It always invokes the callback once with always the same record.

func (OneRecordCheckpointSet) Lock ¶

func (OneRecordCheckpointSet) Lock()

Lock implements sync.Locker, which is needed for exportmetric.CheckpointSet.

func (OneRecordCheckpointSet) RLock ¶

func (OneRecordCheckpointSet) RLock()

RLock implements exportmetric.CheckpointSet.

func (OneRecordCheckpointSet) RUnlock ¶

func (OneRecordCheckpointSet) RUnlock()

RUnlock implements exportmetric.CheckpointSet.

func (OneRecordCheckpointSet) Unlock ¶

func (OneRecordCheckpointSet) Unlock()

Unlock implements sync.Locker, which is needed for exportmetric.CheckpointSet.

type SpansStorage ¶

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

SpansStorage stores the spans. Mock collectors could use it to store spans they have received.

func NewSpansStorage ¶

func NewSpansStorage() SpansStorage

NewSpansStorage creates a new spans storage.

func (*SpansStorage) AddSpans ¶

func (s *SpansStorage) AddSpans(request *collectortracepb.ExportTraceServiceRequest)

AddSpans adds spans to the spans storage.

func (*SpansStorage) GetResourceSpans ¶

func (s *SpansStorage) GetResourceSpans() []*tracepb.ResourceSpans

GetResourceSpans returns the stored resource spans.

func (*SpansStorage) GetSpans ¶

func (s *SpansStorage) GetSpans() []*tracepb.Span

GetSpans returns the stored spans.

Source Files ¶

collector.go data.go otlptest.go