testtelemetry

type MemoryCollector ¶

type MemoryCollector struct {
	ctrace.UnimplementedTraceServiceServer
	// contains filtered or unexported fields
}

MemoryCollector is a gRPC-based OTEL collector that collects spans in memory.

func StartMemoryCollector(tb testing.TB) (*MemoryCollector, error)

func (l *MemoryCollector) Addr() string

func (l *MemoryCollector) Export(
	ctx context.Context,
	request *ctrace.ExportTraceServiceRequest,
) (*ctrace.ExportTraceServiceResponse, error)

func (l *MemoryCollector) Spans() []*trace.ResourceSpans

type MemoryExporter ¶

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

MemoryExporter is a span exporter that collects spans in memory.

Note that internally it defers to otlptrace.Exporter to handle the actual export, since the code to transform spans to the exportable format is quite complex and not exported directly. By providing a custom "client", we can intercept the exported spans and write them to a file on request.

func NewFileExporter(outDir string) *MemoryExporter

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

func (e *MemoryExporter) Shutdown(ctx context.Context) error

func (e *MemoryExporter) Write(filename string) (string, error)