Documentation
¶
Index ¶
- type MockAgent
- 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 (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 (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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶
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) 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) ResetZipkinSpans ¶
func (s *MockAgent) ResetZipkinSpans()
ResetZipkinSpans discards accumulated Zipkin spans
func (*MockAgent) SamplingServerAddr ¶
SamplingServerAddr returns the host:port of HTTP server exposing sampling strategy endpoint
func (*MockAgent) SpanServerAddr ¶
SpanServerAddr returns the UDP host:port where MockAgent listens for spans
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) 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.
Source Files