jaeger

Apr 23, 2021

Changes in this version

+ var Batch_SeqNo_DEFAULT int64

type Batch

+ SeqNo *int64

+ Stats *ClientStats

+ func (p *Batch) Equals(other *Batch) bool

+ func (p *Batch) GetSeqNo() int64

+ func (p *Batch) GetStats() *ClientStats

+ func (p *Batch) IsSetSeqNo() bool

+ func (p *Batch) IsSetStats() bool

+ func (p *Batch) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *Batch) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

type BatchSubmitResponse

+ func (p *BatchSubmitResponse) Equals(other *BatchSubmitResponse) bool

+ type ClientStats struct

+ FailedToEmitSpans int64

+ FullQueueDroppedSpans int64

+ TooLargeDroppedSpans int64

+ var Batch_Stats_DEFAULT *ClientStats

+ func NewClientStats() *ClientStats

+ func (p *ClientStats) Equals(other *ClientStats) bool

+ func (p *ClientStats) GetFailedToEmitSpans() int64

+ func (p *ClientStats) GetFullQueueDroppedSpans() int64

+ func (p *ClientStats) GetTooLargeDroppedSpans() int64

+ func (p *ClientStats) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ClientStats) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ClientStats) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ClientStats) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ClientStats) String() string

+ func (p *ClientStats) Write(ctx context.Context, oprot thrift.TProtocol) error

type CollectorClient

+ func (p *CollectorClient) Client_() thrift.TClient

+ func (p *CollectorClient) LastResponseMeta_() thrift.ResponseMeta

+ func (p *CollectorClient) SetLastResponseMeta_(meta thrift.ResponseMeta)

type Log

+ func (p *Log) Equals(other *Log) bool

type Process

+ func (p *Process) Equals(other *Process) bool

type Span

+ func (p *Span) Equals(other *Span) bool

type SpanRef

+ func (p *SpanRef) Equals(other *SpanRef) bool

type Tag

+ func (p *Tag) Equals(other *Tag) bool

Mar 4, 2020

Changes in this version

+ var CollectorSubmitBatchesResult_Success_DEFAULT []*BatchSubmitResponse

+ var GoUnusedProtection__ int

+ var Process_Tags_DEFAULT []*Tag

+ var Span_Logs_DEFAULT []*Log

+ var Span_References_DEFAULT []*SpanRef

+ var Span_Tags_DEFAULT []*Tag

+ var Tag_VBinary_DEFAULT []byte

+ var Tag_VBool_DEFAULT bool

+ var Tag_VDouble_DEFAULT float64

+ var Tag_VLong_DEFAULT int64

+ var Tag_VStr_DEFAULT string

+ type Agent interface

+ EmitBatch func(batch *Batch) (err error)

+ type AgentClient struct

+ InputProtocol thrift.TProtocol

+ OutputProtocol thrift.TProtocol

+ ProtocolFactory thrift.TProtocolFactory

+ SeqId int32

+ Transport thrift.TTransport

+ 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(batch *Batch) (err error)

+ type AgentEmitBatchArgs struct

+ Batch *Batch

+ func NewAgentEmitBatchArgs() *AgentEmitBatchArgs

+ func (p *AgentEmitBatchArgs) GetBatch() *Batch

+ func (p *AgentEmitBatchArgs) IsSetBatch() bool

+ func (p *AgentEmitBatchArgs) Read(iprot thrift.TProtocol) error

+ func (p *AgentEmitBatchArgs) String() string

+ func (p *AgentEmitBatchArgs) 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(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

+ func (p *AgentProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

+ type Batch struct

+ Process *Process

+ Spans []*Span

+ var AgentEmitBatchArgs_Batch_DEFAULT *Batch

+ func NewBatch() *Batch

+ func (p *Batch) GetProcess() *Process

+ func (p *Batch) GetSpans() []*Span

+ func (p *Batch) IsSetProcess() bool

+ func (p *Batch) Read(iprot thrift.TProtocol) error

+ func (p *Batch) ReadField1(iprot thrift.TProtocol) error

+ func (p *Batch) ReadField2(iprot thrift.TProtocol) error

+ func (p *Batch) String() string

+ func (p *Batch) Write(oprot thrift.TProtocol) error

+ type BatchSubmitResponse struct

+ Ok bool

+ func NewBatchSubmitResponse() *BatchSubmitResponse

+ func (p *BatchSubmitResponse) GetOk() bool

+ func (p *BatchSubmitResponse) Read(iprot thrift.TProtocol) error

+ func (p *BatchSubmitResponse) ReadField1(iprot thrift.TProtocol) error

+ func (p *BatchSubmitResponse) String() string

+ func (p *BatchSubmitResponse) Write(oprot thrift.TProtocol) error

+ type Collector interface

+ SubmitBatches func(ctx context.Context, batches []*Batch) (r []*BatchSubmitResponse, err error)

+ type CollectorClient struct

+ func NewCollectorClient(c thrift.TClient) *CollectorClient

+ func NewCollectorClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *CollectorClient

+ func NewCollectorClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *CollectorClient

+ func (p *CollectorClient) SubmitBatches(ctx context.Context, batches []*Batch) (r []*BatchSubmitResponse, err error)

+ type CollectorProcessor struct

+ func NewCollectorProcessor(handler Collector) *CollectorProcessor

+ func (p *CollectorProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

+ func (p *CollectorProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

+ func (p *CollectorProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

+ func (p *CollectorProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

+ type CollectorSubmitBatchesArgs struct

+ Batches []*Batch

+ func NewCollectorSubmitBatchesArgs() *CollectorSubmitBatchesArgs

+ func (p *CollectorSubmitBatchesArgs) GetBatches() []*Batch

+ func (p *CollectorSubmitBatchesArgs) Read(iprot thrift.TProtocol) error

+ func (p *CollectorSubmitBatchesArgs) ReadField1(iprot thrift.TProtocol) error

+ func (p *CollectorSubmitBatchesArgs) String() string

+ func (p *CollectorSubmitBatchesArgs) Write(oprot thrift.TProtocol) error

+ type CollectorSubmitBatchesResult struct

+ Success []*BatchSubmitResponse

+ func NewCollectorSubmitBatchesResult() *CollectorSubmitBatchesResult

+ func (p *CollectorSubmitBatchesResult) GetSuccess() []*BatchSubmitResponse

+ func (p *CollectorSubmitBatchesResult) IsSetSuccess() bool

+ func (p *CollectorSubmitBatchesResult) Read(iprot thrift.TProtocol) error

+ func (p *CollectorSubmitBatchesResult) ReadField0(iprot thrift.TProtocol) error

+ func (p *CollectorSubmitBatchesResult) String() string

+ func (p *CollectorSubmitBatchesResult) Write(oprot thrift.TProtocol) error

+ type Log struct

+ Fields []*Tag

+ Timestamp int64

+ func NewLog() *Log

+ func (p *Log) GetFields() []*Tag

+ func (p *Log) GetTimestamp() int64

+ func (p *Log) Read(iprot thrift.TProtocol) error

+ func (p *Log) ReadField1(iprot thrift.TProtocol) error

+ func (p *Log) ReadField2(iprot thrift.TProtocol) error

+ func (p *Log) String() string

+ func (p *Log) Write(oprot thrift.TProtocol) error

+ type Process struct

+ ServiceName string

+ Tags []*Tag

+ var Batch_Process_DEFAULT *Process

+ func NewProcess() *Process

+ func (p *Process) GetServiceName() string

+ func (p *Process) GetTags() []*Tag

+ func (p *Process) IsSetTags() bool

+ func (p *Process) Read(iprot thrift.TProtocol) error

+ func (p *Process) ReadField1(iprot thrift.TProtocol) error

+ func (p *Process) ReadField2(iprot thrift.TProtocol) error

+ func (p *Process) String() string

+ func (p *Process) Write(oprot thrift.TProtocol) error

+ type Span struct

+ Duration int64

+ Flags int32

+ Logs []*Log

+ OperationName string

+ ParentSpanId int64

+ References []*SpanRef

+ SpanId int64

+ StartTime int64

+ Tags []*Tag

+ TraceIdHigh int64

+ TraceIdLow int64

+ func NewSpan() *Span

+ func (p *Span) GetDuration() int64

+ func (p *Span) GetFlags() int32

+ func (p *Span) GetLogs() []*Log

+ func (p *Span) GetOperationName() string

+ func (p *Span) GetParentSpanId() int64

+ func (p *Span) GetReferences() []*SpanRef

+ func (p *Span) GetSpanId() int64

+ func (p *Span) GetStartTime() int64

+ func (p *Span) GetTags() []*Tag

+ func (p *Span) GetTraceIdHigh() int64

+ func (p *Span) GetTraceIdLow() int64

+ func (p *Span) IsSetLogs() bool

+ func (p *Span) IsSetReferences() bool

+ func (p *Span) IsSetTags() bool

+ func (p *Span) Read(iprot thrift.TProtocol) error

+ func (p *Span) ReadField1(iprot thrift.TProtocol) error

+ func (p *Span) ReadField10(iprot thrift.TProtocol) error

+ func (p *Span) ReadField11(iprot thrift.TProtocol) error

+ func (p *Span) ReadField2(iprot thrift.TProtocol) error

+ func (p *Span) ReadField3(iprot thrift.TProtocol) error

+ func (p *Span) ReadField4(iprot thrift.TProtocol) error

+ func (p *Span) ReadField5(iprot thrift.TProtocol) error

+ func (p *Span) ReadField6(iprot thrift.TProtocol) error

+ func (p *Span) ReadField7(iprot thrift.TProtocol) error

+ func (p *Span) ReadField8(iprot thrift.TProtocol) error

+ func (p *Span) ReadField9(iprot thrift.TProtocol) error

+ func (p *Span) String() string

+ func (p *Span) Write(oprot thrift.TProtocol) error

+ type SpanRef struct

+ RefType SpanRefType

+ SpanId int64

+ TraceIdHigh int64

+ TraceIdLow int64

+ func NewSpanRef() *SpanRef

+ func (p *SpanRef) GetRefType() SpanRefType

+ func (p *SpanRef) GetSpanId() int64

+ func (p *SpanRef) GetTraceIdHigh() int64

+ func (p *SpanRef) GetTraceIdLow() int64

+ func (p *SpanRef) Read(iprot thrift.TProtocol) error

+ func (p *SpanRef) ReadField1(iprot thrift.TProtocol) error

+ func (p *SpanRef) ReadField2(iprot thrift.TProtocol) error

+ func (p *SpanRef) ReadField3(iprot thrift.TProtocol) error

+ func (p *SpanRef) ReadField4(iprot thrift.TProtocol) error

+ func (p *SpanRef) String() string

+ func (p *SpanRef) Write(oprot thrift.TProtocol) error

+ type SpanRefType int64

+ const SpanRefType_CHILD_OF

+ const SpanRefType_FOLLOWS_FROM

+ func SpanRefTypeFromString(s string) (SpanRefType, error)

+ func SpanRefTypePtr(v SpanRefType) *SpanRefType

+ func (p *SpanRefType) Scan(value interface{}) error

+ func (p *SpanRefType) UnmarshalText(text []byte) error

+ func (p *SpanRefType) Value() (driver.Value, error)

+ func (p SpanRefType) MarshalText() ([]byte, error)

+ func (p SpanRefType) String() string

+ type Tag struct

+ Key string

+ VBinary []byte

+ VBool *bool

+ VDouble *float64

+ VLong *int64

+ VStr *string

+ VType TagType

+ func NewTag() *Tag

+ func (p *Tag) GetKey() string

+ func (p *Tag) GetVBinary() []byte

+ func (p *Tag) GetVBool() bool

+ func (p *Tag) GetVDouble() float64

+ func (p *Tag) GetVLong() int64

+ func (p *Tag) GetVStr() string

+ func (p *Tag) GetVType() TagType

+ func (p *Tag) IsSetVBinary() bool

+ func (p *Tag) IsSetVBool() bool

+ func (p *Tag) IsSetVDouble() bool

+ func (p *Tag) IsSetVLong() bool

+ func (p *Tag) IsSetVStr() bool

+ func (p *Tag) Read(iprot thrift.TProtocol) error

+ func (p *Tag) ReadField1(iprot thrift.TProtocol) error

+ func (p *Tag) ReadField2(iprot thrift.TProtocol) error

+ func (p *Tag) ReadField3(iprot thrift.TProtocol) error

+ func (p *Tag) ReadField4(iprot thrift.TProtocol) error

+ func (p *Tag) ReadField5(iprot thrift.TProtocol) error

+ func (p *Tag) ReadField6(iprot thrift.TProtocol) error

+ func (p *Tag) ReadField7(iprot thrift.TProtocol) error

+ func (p *Tag) String() string

+ func (p *Tag) Write(oprot thrift.TProtocol) error

+ type TagType int64

+ const TagType_BINARY

+ const TagType_BOOL

+ const TagType_DOUBLE

+ const TagType_LONG

+ const TagType_STRING

+ func TagTypeFromString(s string) (TagType, error)

+ func TagTypePtr(v TagType) *TagType

+ func (p *TagType) Scan(value interface{}) error

+ func (p *TagType) UnmarshalText(text []byte) error

+ func (p *TagType) Value() (driver.Value, error)

+ func (p TagType) MarshalText() ([]byte, error)

+ func (p TagType) String() string