testutils

Aug 29, 2016

Changes in this version

+ type MockAgent struct

+ 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 TUDPTransport struct

+ 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)