testutils

Documentation

Index

• func NewJaegerThriftUDPClient(hostPort string, protocolFactory thrift.TProtocolFactory) (*agent.AgentClient, io.Closer, error)
• func NewZipkinThriftUDPClient(hostPort string) (*agent.AgentClient, io.Closer, error)
• type GrpcCollector
  • func StartGRPCCollector(t *testing.T) *GrpcCollector
  • func (c *GrpcCollector) Close() error
  • func (h GrpcCollector) GetJaegerBatches() []model.Batch
  • func (c *GrpcCollector) Listener() net.Listener
  • func (h GrpcCollector) PostSpans(_ context.Context, r *api_v2.PostSpansRequest) (*api_v2.PostSpansResponse, error)
• type InMemoryReporter
  • func NewInMemoryReporter() *InMemoryReporter
  • func (i *InMemoryReporter) EmitBatch(_ context.Context, batch *jaeger.Batch) (err error)
  • func (i *InMemoryReporter) EmitZipkinBatch(_ context.Context, spans []*zipkincore.Span) error
  • func (i *InMemoryReporter) Spans() []*jaeger.Span
  • func (i *InMemoryReporter) ZipkinSpans() []*zipkincore.Span

Functions

func NewJaegerThriftUDPClient

func NewJaegerThriftUDPClient(hostPort string, protocolFactory thrift.TProtocolFactory) (*agent.AgentClient, io.Closer, error)

NewJaegerThriftUDPClient creates a new jaeger agent client that works like Jaeger client

func NewZipkinThriftUDPClient

func NewZipkinThriftUDPClient(hostPort string) (*agent.AgentClient, io.Closer, error)

NewZipkinThriftUDPClient creates a new zipking agent client that works like Jaeger client

Types

type GrpcCollector

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

GrpcCollector is a mock collector for tests

func StartGRPCCollector

func StartGRPCCollector(t *testing.T) *GrpcCollector

StartGRPCCollector starts GRPC collector on a random port

func (*GrpcCollector) Close

func (c *GrpcCollector) Close() error

Close closes the server

func (GrpcCollector) GetJaegerBatches

func (h GrpcCollector) GetJaegerBatches() []model.Batch

GetJaegerBatches returns accumulated Jaeger batches

func (*GrpcCollector) Listener

func (c *GrpcCollector) Listener() net.Listener

Listener returns server's listener

func (GrpcCollector) PostSpans

func (h GrpcCollector) PostSpans(_ context.Context, r *api_v2.PostSpansRequest) (*api_v2.PostSpansResponse, error)

type InMemoryReporter

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

InMemoryReporter collects spans in memory

func NewInMemoryReporter

func NewInMemoryReporter() *InMemoryReporter

NewInMemoryReporter creates new InMemoryReporter

func (*InMemoryReporter) EmitBatch

func (i *InMemoryReporter) EmitBatch(_ context.Context, batch *jaeger.Batch) (err error)

EmitBatch implements the corresponding method of the Reporter interface

func (*InMemoryReporter) EmitZipkinBatch

func (i *InMemoryReporter) EmitZipkinBatch(_ context.Context, spans []*zipkincore.Span) error

EmitZipkinBatch implements the corresponding method of the Reporter interface

func (*InMemoryReporter) Spans

func (i *InMemoryReporter) Spans() []*jaeger.Span

Spans returns accumulated spans as a copied slice

func (*InMemoryReporter) ZipkinSpans

func (i *InMemoryReporter) ZipkinSpans() []*zipkincore.Span

ZipkinSpans returns accumulated Zipkin spans as a copied slice