otel

package

v1.17.2 Latest Latest Go to latest Published: Mar 19, 2026 License: Apache-2.0 Imports: 24 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Collector struct {
	coltracepb.UnimplementedTraceServiceServer
	// contains filtered or unexported fields
}

Collector is an in-memory OTLP collector for testing.

func New(t *testing.T, fopts ...Option) *Collector

func (c *Collector) Cleanup(t *testing.T)

Cleanup implements framework.Process

func (c *Collector) Export(ctx context.Context, req *coltracepb.ExportTraceServiceRequest) (*coltracepb.ExportTraceServiceResponse, error)

Export implements the OTLP trace service Export method

func (c *Collector) ExportTraces(ctx context.Context, req *coltracepb.ExportTraceServiceRequest) (*coltracepb.ExportTraceServiceResponse, error)

ExportTraces implements the OTLP trace service ExportTraces method

func (c *Collector) GRPCDaprdConfiguration(t *testing.T) daprd.Option

func (c *Collector) GRPCProvider(t *testing.T, ctx context.Context) *sdktrace.TracerProvider

func (c *Collector) GetHeaders() metadata.MD

GetHeaders returns the gRPC metadata received from the last Export request.

func (c *Collector) GetSpans() []*tracepb.ResourceSpans

GetSpans returns a copy of all received spans

func (c *Collector) OTLPGRPCAddress() string

OTLPGRPCAddress returns the gRPC endpoint address for the collector

func (c *Collector) Run(t *testing.T, ctx context.Context)

func (c *Collector) TraceSpans(traceID trace.TraceID) []*tracepb.Span

func (c *Collector) WaitUntilRunning(t *testing.T, ctx context.Context)

type Option func(*options)

Option is a function that configures the process.