testutils

Documentation

Index

• type MockAgent
  • func StartMockAgent() (*MockAgent, error)
  • func (s *MockAgent) AddSamplingStrategy(service string, strategy *sampling.SamplingStrategyResponse)
  • func (s *MockAgent) Close()
  • func (s *MockAgent) EmitZipkinBatch(spans []*zipkincore.Span) (err error)
  • func (s *MockAgent) GetZipkinSpans() []*zipkincore.Span
  • func (s *MockAgent) IsServing() bool
  • func (s *MockAgent) ResetZipkinSpans()
  • func (s *MockAgent) SamplingServerAddr() string
  • func (s *MockAgent) SpanServerAddr() string
  • func (s *MockAgent) SpanServerClient() (agent.Agent, error)
• type MockTCollector
  • func StartMockTCollector() (*MockTCollector, error)
  • func (s *MockTCollector) AddSamplingStrategy(service string, strategy *sampling.SamplingStrategyResponse)
  • func (s *MockTCollector) Close()
  • func (s *MockTCollector) GetSamplingStrategy(ctx thrift.Context, serviceName string) (*tcollector.SamplingStrategyResponse, error)
  • func (s *MockTCollector) GetTChannelSpans() []*tcollector.Span
  • func (s *MockTCollector) GetZipkinSpans() []*zipkincore.Span
  • func (s *MockTCollector) Submit(ctx thrift.Context, span *tcollector.Span) (*tcollector.Response, error)
  • func (s *MockTCollector) SubmitBatch(ctx thrift.Context, spans []*tcollector.Span) ([]*tcollector.Response, error)
  • func (s *MockTCollector) SubmitZipkinBatch(ctx thrift.Context, spans []*zipkincore.Span) ([]*zipkincore.Response, error)
• type TUDPTransport
  • func NewTUDPServerTransport(hostPort string) (*TUDPTransport, error)
  • func (p *TUDPTransport) Addr() net.Addr
  • func (p *TUDPTransport) Close() error
  • func (p *TUDPTransport) Conn() *net.UDPConn
  • func (p *TUDPTransport) Flush() error
  • func (p *TUDPTransport) IsOpen() bool
  • func (p *TUDPTransport) Open() error
  • func (p *TUDPTransport) Read(buf []byte) (int, error)
  • func (p *TUDPTransport) RemainingBytes() uint64
  • func (p *TUDPTransport) Write(buf []byte) (int, error)

Types

type MockAgent

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

MockAgent is a mock representation of Jaeger Agent. It receives spans over UDP, and has an HTTP endpoint for sampling strategies.

func StartMockAgent

func StartMockAgent() (*MockAgent, error)

StartMockAgent runs a mock representation of jaeger-agent. This function returns a started server.

func (*MockAgent) AddSamplingStrategy

func (s *MockAgent) AddSamplingStrategy(service string, strategy *sampling.SamplingStrategyResponse)

AddSamplingStrategy registers a sampling strategy for a service

func (*MockAgent) Close

func (s *MockAgent) Close()

Close stops the serving of traffic

func (*MockAgent) EmitZipkinBatch

func (s *MockAgent) EmitZipkinBatch(spans []*zipkincore.Span) (err error)

EmitZipkinBatch implements EmitZipkinBatch() of TChanSamplingManagerServer

func (*MockAgent) GetZipkinSpans

func (s *MockAgent) GetZipkinSpans() []*zipkincore.Span

GetZipkinSpans returns accumulated Zipkin spans

func (*MockAgent) IsServing

func (s *MockAgent) IsServing() bool

IsServing indicates whether the server is currently serving traffic

func (*MockAgent) ResetZipkinSpans

func (s *MockAgent) ResetZipkinSpans()

ResetZipkinSpans discards accumulated Zipkin spans

func (*MockAgent) SamplingServerAddr

func (s *MockAgent) SamplingServerAddr() string

SamplingServerAddr returns the host:port of HTTP server exposing sampling strategy endpoint

func (*MockAgent) SpanServerAddr

func (s *MockAgent) SpanServerAddr() string

SpanServerAddr returns the UDP host:port where MockAgent listens for spans

func (*MockAgent) SpanServerClient

func (s *MockAgent) SpanServerClient() (agent.Agent, error)

SpanServerClient returns a UDP client that can be used to send spans to the MockAgent

type MockTCollector

type MockTCollector struct {
	Channel *tchannel.Channel
	// contains filtered or unexported fields
}

MockTCollector is a mock representation of Jaeger Collector.

func StartMockTCollector

func StartMockTCollector() (*MockTCollector, error)

StartMockTCollector runs a mock representation of Jaeger Collector. This function returns a started server, with a Channel that knows how to find that server, which can be used in clients or Jaeger tracer.

func (*MockTCollector) AddSamplingStrategy

func (s *MockTCollector) AddSamplingStrategy(service string, strategy *sampling.SamplingStrategyResponse)

AddSamplingStrategy registers a sampling strategy for a service

func (*MockTCollector) Close

func (s *MockTCollector) Close()

Close stops/closes the underlying channel and server

func (*MockTCollector) GetSamplingStrategy

func (s *MockTCollector) GetSamplingStrategy(ctx thrift.Context, serviceName string) (*tcollector.SamplingStrategyResponse, error)

GetSamplingStrategy implements handler method of TChanTCollectorServer

func (*MockTCollector) GetTChannelSpans

func (s *MockTCollector) GetTChannelSpans() []*tcollector.Span

GetTChannelSpans returns accumulated TChannel spans

func (*MockTCollector) GetZipkinSpans

func (s *MockTCollector) GetZipkinSpans() []*zipkincore.Span

GetZipkinSpans returns accumulated Zipkin spans

func (*MockTCollector) Submit

func (s *MockTCollector) Submit(ctx thrift.Context, span *tcollector.Span) (*tcollector.Response, error)

Submit implements handler method of TChanTCollectorServer

func (*MockTCollector) SubmitBatch

func (s *MockTCollector) SubmitBatch(ctx thrift.Context, spans []*tcollector.Span) ([]*tcollector.Response, error)

SubmitBatch implements handler method of TChanTCollectorServer

func (*MockTCollector) SubmitZipkinBatch

func (s *MockTCollector) SubmitZipkinBatch(ctx thrift.Context, spans []*zipkincore.Span) ([]*zipkincore.Response, error)

SubmitZipkinBatch implements handler method of TChanZipkinCollectorServer

type TUDPTransport

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

TUDPTransport does UDP as a thrift.TTransport (read-only, write functions not implemented).

func NewTUDPServerTransport

func NewTUDPServerTransport(hostPort string) (*TUDPTransport, error)

NewTUDPServerTransport creates a net.UDPConn-backed TTransport for Thrift servers It will listen for incoming udp packets on the specified host/port Example:

trans, err := utils.NewTUDPClientTransport("localhost:9001")

func (*TUDPTransport) Addr

func (p *TUDPTransport) Addr() net.Addr

Addr returns the address that the transport is listening on or writing to

func (*TUDPTransport) Close

func (p *TUDPTransport) Close() error

Close closes the connection

func (*TUDPTransport) Conn

func (p *TUDPTransport) Conn() *net.UDPConn

Conn retrieves the underlying net.UDPConn

func (*TUDPTransport) Flush

func (p *TUDPTransport) Flush() error

Flush flushes the write buffer as one udp packet

func (*TUDPTransport) IsOpen

func (p *TUDPTransport) IsOpen() bool

IsOpen returns true if the connection is open

func (*TUDPTransport) Open

func (p *TUDPTransport) Open() error

Open does nothing as connection is opened on creation Required to maintain thrift.TTransport interface

func (*TUDPTransport) Read

func (p *TUDPTransport) Read(buf []byte) (int, error)

Read reads one UDP packet and puts it in the specified buf

func (*TUDPTransport) RemainingBytes

func (p *TUDPTransport) RemainingBytes() uint64

RemainingBytes returns the max number of bytes (same as Thrift's StreamTransport) as we do not know how many bytes we have left.

func (*TUDPTransport) Write

func (p *TUDPTransport) Write(buf []byte) (int, error)

Write writes specified buf to the write buffer