Versions in this module Expand all Collapse all v0 v0.3.0 Feb 12, 2018 v0.2.0 Jan 30, 2018 Changes in this version + var AgentEmitBatchArgs_Batch_DEFAULT *jaeger.Batch + var GoUnusedProtection__ int + type Agent interface + EmitBatch func(ctx context.Context, batch *jaeger.Batch) (err error) + EmitZipkinBatch func(ctx context.Context, spans []*zipkincore.Span) (err error) + type AgentClient struct + func NewAgentClient(c thrift.TClient) *AgentClient + func NewAgentClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *AgentClient + func NewAgentClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *AgentClient + func (p *AgentClient) EmitBatch(ctx context.Context, batch *jaeger.Batch) (err error) + func (p *AgentClient) EmitZipkinBatch(ctx context.Context, spans []*zipkincore.Span) (err error) + type AgentEmitBatchArgs struct + Batch *jaeger.Batch + func NewAgentEmitBatchArgs() *AgentEmitBatchArgs + func (p *AgentEmitBatchArgs) GetBatch() *jaeger.Batch + func (p *AgentEmitBatchArgs) IsSetBatch() bool + func (p *AgentEmitBatchArgs) Read(iprot thrift.TProtocol) error + func (p *AgentEmitBatchArgs) ReadField1(iprot thrift.TProtocol) error + func (p *AgentEmitBatchArgs) String() string + func (p *AgentEmitBatchArgs) Write(oprot thrift.TProtocol) error + type AgentEmitZipkinBatchArgs struct + Spans []*zipkincore.Span + func NewAgentEmitZipkinBatchArgs() *AgentEmitZipkinBatchArgs + func (p *AgentEmitZipkinBatchArgs) GetSpans() []*zipkincore.Span + func (p *AgentEmitZipkinBatchArgs) Read(iprot thrift.TProtocol) error + func (p *AgentEmitZipkinBatchArgs) ReadField1(iprot thrift.TProtocol) error + func (p *AgentEmitZipkinBatchArgs) String() string + func (p *AgentEmitZipkinBatchArgs) Write(oprot thrift.TProtocol) error + type AgentProcessor struct + func NewAgentProcessor(handler Agent) *AgentProcessor + func (p *AgentProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *AgentProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *AgentProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *AgentProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
Go to main page