Versions in this module Expand all Collapse all v1 v1.15.1 Nov 7, 2019 Changes in this version + func NewJaegerThriftUDPClient(hostPort string, protocolFactory thrift.TProtocolFactory) (*jaeger.AgentClient, io.Closer, error) + func NewZipkinThriftUDPClient(hostPort string) (*agent.AgentClient, io.Closer, error) + type InMemoryReporter struct + func NewInMemoryReporter() *InMemoryReporter + func (i *InMemoryReporter) EmitBatch(batch *jaeger.Batch) (err error) + func (i *InMemoryReporter) EmitZipkinBatch(spans []*zipkincore.Span) error + func (i *InMemoryReporter) Spans() []*jaeger.Span + func (i *InMemoryReporter) ZipkinSpans() []*zipkincore.Span + type MockTCollector struct + Channel *tchannel.Channel + ReturnErr bool + func InitMockCollector(t *testing.T) (*metricstest.Factory, *MockTCollector) + func StartMockTCollector() (*MockTCollector, error) + func (s *MockTCollector) AddBaggageRestrictions(service string, restrictions []*baggage.BaggageRestriction) + func (s *MockTCollector) AddSamplingStrategy(service string, strategy *sampling.SamplingStrategyResponse) + func (s *MockTCollector) Close() + func (s *MockTCollector) GetJaegerBatches() []*jaeger.Batch + func (s *MockTCollector) GetZipkinSpans() []*zipkincore.Span + func (s *MockTCollector) SubmitBatches(ctx thrift.Context, batches []*jaeger.Batch) ([]*jaeger.BatchSubmitResponse, error) + func (s *MockTCollector) SubmitZipkinBatch(ctx thrift.Context, spans []*zipkincore.Span) ([]*zipkincore.Response, error)