jaeger

package
v2.30.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 7, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Batch_SeqNo_DEFAULT int64
View Source
var CollectorSubmitBatchesResult_Success_DEFAULT []*BatchSubmitResponse
View Source
var GoUnusedProtection__ int
View Source
var Process_Tags_DEFAULT []*Tag
View Source
var Span_Logs_DEFAULT []*Log
View Source
var Span_References_DEFAULT []*SpanRef
View Source
var Span_Tags_DEFAULT []*Tag
View Source
var Tag_VBinary_DEFAULT []byte
View Source
var Tag_VBool_DEFAULT bool
View Source
var Tag_VDouble_DEFAULT float64
View Source
var Tag_VLong_DEFAULT int64
View Source
var Tag_VStr_DEFAULT string

Functions

This section is empty.

Types

type Batch

type Batch struct {
	Process *Process     `thrift:"process,1,required" db:"process" json:"process"`
	Spans   []*Span      `thrift:"spans,2,required" db:"spans" json:"spans"`
	SeqNo   *int64       `thrift:"seqNo,3" db:"seqNo" json:"seqNo,omitempty"`
	Stats   *ClientStats `thrift:"stats,4" db:"stats" json:"stats,omitempty"`
}

Attributes:

  • Process
  • Spans
  • SeqNo
  • Stats

func NewBatch

func NewBatch() *Batch

func (*Batch) Equals

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

func (*Batch) GetProcess

func (p *Batch) GetProcess() *Process

func (*Batch) GetSeqNo

func (p *Batch) GetSeqNo() int64

func (*Batch) GetSpans

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

func (*Batch) GetStats

func (p *Batch) GetStats() *ClientStats

func (*Batch) IsSetProcess

func (p *Batch) IsSetProcess() bool

func (*Batch) IsSetSeqNo

func (p *Batch) IsSetSeqNo() bool

func (*Batch) IsSetStats

func (p *Batch) IsSetStats() bool

func (*Batch) Read

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

func (*Batch) ReadField1

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

func (*Batch) ReadField2

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

func (*Batch) ReadField3

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

func (*Batch) ReadField4

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

func (*Batch) String

func (p *Batch) String() string

func (*Batch) Write

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

type BatchSubmitResponse

type BatchSubmitResponse struct {
	Ok bool `thrift:"ok,1,required" db:"ok" json:"ok"`
}

Attributes:

  • Ok

func NewBatchSubmitResponse

func NewBatchSubmitResponse() *BatchSubmitResponse

func (*BatchSubmitResponse) Equals

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

func (*BatchSubmitResponse) GetOk

func (p *BatchSubmitResponse) GetOk() bool

func (*BatchSubmitResponse) Read

func (*BatchSubmitResponse) ReadField1

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

func (*BatchSubmitResponse) String

func (p *BatchSubmitResponse) String() string

func (*BatchSubmitResponse) Write

type ClientStats

type ClientStats struct {
	FullQueueDroppedSpans int64 `thrift:"fullQueueDroppedSpans,1,required" db:"fullQueueDroppedSpans" json:"fullQueueDroppedSpans"`
	TooLargeDroppedSpans  int64 `thrift:"tooLargeDroppedSpans,2,required" db:"tooLargeDroppedSpans" json:"tooLargeDroppedSpans"`
	FailedToEmitSpans     int64 `thrift:"failedToEmitSpans,3,required" db:"failedToEmitSpans" json:"failedToEmitSpans"`
}

Attributes:

  • FullQueueDroppedSpans
  • TooLargeDroppedSpans
  • FailedToEmitSpans
var Batch_Stats_DEFAULT *ClientStats

func NewClientStats

func NewClientStats() *ClientStats

func (*ClientStats) Equals

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

func (*ClientStats) GetFailedToEmitSpans

func (p *ClientStats) GetFailedToEmitSpans() int64

func (*ClientStats) GetFullQueueDroppedSpans

func (p *ClientStats) GetFullQueueDroppedSpans() int64

func (*ClientStats) GetTooLargeDroppedSpans

func (p *ClientStats) GetTooLargeDroppedSpans() int64

func (*ClientStats) Read

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

func (*ClientStats) ReadField1

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

func (*ClientStats) ReadField2

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

func (*ClientStats) ReadField3

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

func (*ClientStats) String

func (p *ClientStats) String() string

func (*ClientStats) Write

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

type Collector

type Collector interface {
	// Parameters:
	//  - Batches
	SubmitBatches(ctx context.Context, batches []*Batch) (_r []*BatchSubmitResponse, _err error)
}

type CollectorClient

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

func NewCollectorClient

func NewCollectorClient(c thrift.TClient) *CollectorClient

func NewCollectorClientProtocol

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

func (*CollectorClient) Client_

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

func (*CollectorClient) LastResponseMeta_

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

func (*CollectorClient) SetLastResponseMeta_

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

func (*CollectorClient) SubmitBatches

func (p *CollectorClient) SubmitBatches(ctx context.Context, batches []*Batch) (_r []*BatchSubmitResponse, _err error)

Parameters:

  • Batches

type CollectorProcessor

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

func NewCollectorProcessor

func NewCollectorProcessor(handler Collector) *CollectorProcessor

func (*CollectorProcessor) AddToProcessorMap

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

func (*CollectorProcessor) GetProcessorFunction

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

func (*CollectorProcessor) Process

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

func (*CollectorProcessor) ProcessorMap

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

type CollectorSubmitBatchesArgs

type CollectorSubmitBatchesArgs struct {
	Batches []*Batch `thrift:"batches,1" db:"batches" json:"batches"`
}

Attributes:

  • Batches

func NewCollectorSubmitBatchesArgs

func NewCollectorSubmitBatchesArgs() *CollectorSubmitBatchesArgs

func (*CollectorSubmitBatchesArgs) GetBatches

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

func (*CollectorSubmitBatchesArgs) Read

func (*CollectorSubmitBatchesArgs) ReadField1

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

func (*CollectorSubmitBatchesArgs) String

func (p *CollectorSubmitBatchesArgs) String() string

func (*CollectorSubmitBatchesArgs) Write

type CollectorSubmitBatchesResult

type CollectorSubmitBatchesResult struct {
	Success []*BatchSubmitResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewCollectorSubmitBatchesResult

func NewCollectorSubmitBatchesResult() *CollectorSubmitBatchesResult

func (*CollectorSubmitBatchesResult) GetSuccess

func (*CollectorSubmitBatchesResult) IsSetSuccess

func (p *CollectorSubmitBatchesResult) IsSetSuccess() bool

func (*CollectorSubmitBatchesResult) Read

func (*CollectorSubmitBatchesResult) ReadField0

func (*CollectorSubmitBatchesResult) String

func (*CollectorSubmitBatchesResult) Write

type Log

type Log struct {
	Timestamp int64  `thrift:"timestamp,1,required" db:"timestamp" json:"timestamp"`
	Fields    []*Tag `thrift:"fields,2,required" db:"fields" json:"fields"`
}

Attributes:

  • Timestamp
  • Fields

func NewLog

func NewLog() *Log

func (*Log) Equals

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

func (*Log) GetFields

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

func (*Log) GetTimestamp

func (p *Log) GetTimestamp() int64

func (*Log) Read

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

func (*Log) ReadField1

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

func (*Log) ReadField2

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

func (*Log) String

func (p *Log) String() string

func (*Log) Write

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

type Process

type Process struct {
	ServiceName string `thrift:"serviceName,1,required" db:"serviceName" json:"serviceName"`
	Tags        []*Tag `thrift:"tags,2" db:"tags" json:"tags,omitempty"`
}

Attributes:

  • ServiceName
  • Tags
var Batch_Process_DEFAULT *Process

func NewProcess

func NewProcess() *Process

func (*Process) Equals

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

func (*Process) GetServiceName

func (p *Process) GetServiceName() string

func (*Process) GetTags

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

func (*Process) IsSetTags

func (p *Process) IsSetTags() bool

func (*Process) Read

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

func (*Process) ReadField1

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

func (*Process) ReadField2

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

func (*Process) String

func (p *Process) String() string

func (*Process) Write

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

type Span

type Span struct {
	TraceIdLow    int64      `thrift:"traceIdLow,1,required" db:"traceIdLow" json:"traceIdLow"`
	TraceIdHigh   int64      `thrift:"traceIdHigh,2,required" db:"traceIdHigh" json:"traceIdHigh"`
	SpanId        int64      `thrift:"spanId,3,required" db:"spanId" json:"spanId"`
	ParentSpanId  int64      `thrift:"parentSpanId,4,required" db:"parentSpanId" json:"parentSpanId"`
	OperationName string     `thrift:"operationName,5,required" db:"operationName" json:"operationName"`
	References    []*SpanRef `thrift:"references,6" db:"references" json:"references,omitempty"`
	Flags         int32      `thrift:"flags,7,required" db:"flags" json:"flags"`
	StartTime     int64      `thrift:"startTime,8,required" db:"startTime" json:"startTime"`
	Duration      int64      `thrift:"duration,9,required" db:"duration" json:"duration"`
	Tags          []*Tag     `thrift:"tags,10" db:"tags" json:"tags,omitempty"`
	Logs          []*Log     `thrift:"logs,11" db:"logs" json:"logs,omitempty"`
}

Attributes:

  • TraceIdLow
  • TraceIdHigh
  • SpanId
  • ParentSpanId
  • OperationName
  • References
  • Flags
  • StartTime
  • Duration
  • Tags
  • Logs

func NewSpan

func NewSpan() *Span

func (*Span) Equals

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

func (*Span) GetDuration

func (p *Span) GetDuration() int64

func (*Span) GetFlags

func (p *Span) GetFlags() int32

func (*Span) GetLogs

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

func (*Span) GetOperationName

func (p *Span) GetOperationName() string

func (*Span) GetParentSpanId

func (p *Span) GetParentSpanId() int64

func (*Span) GetReferences

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

func (*Span) GetSpanId

func (p *Span) GetSpanId() int64

func (*Span) GetStartTime

func (p *Span) GetStartTime() int64

func (*Span) GetTags

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

func (*Span) GetTraceIdHigh

func (p *Span) GetTraceIdHigh() int64

func (*Span) GetTraceIdLow

func (p *Span) GetTraceIdLow() int64

func (*Span) IsSetLogs

func (p *Span) IsSetLogs() bool

func (*Span) IsSetReferences

func (p *Span) IsSetReferences() bool

func (*Span) IsSetTags

func (p *Span) IsSetTags() bool

func (*Span) Read

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

func (*Span) ReadField1

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

func (*Span) ReadField10

func (p *Span) ReadField10(ctx context.Context, iprot thrift.TProtocol) error

func (*Span) ReadField11

func (p *Span) ReadField11(ctx context.Context, iprot thrift.TProtocol) error

func (*Span) ReadField2

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

func (*Span) ReadField3

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

func (*Span) ReadField4

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

func (*Span) ReadField5

func (p *Span) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*Span) ReadField6

func (p *Span) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*Span) ReadField7

func (p *Span) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*Span) ReadField8

func (p *Span) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*Span) ReadField9

func (p *Span) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*Span) String

func (p *Span) String() string

func (*Span) Write

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

type SpanRef

type SpanRef struct {
	RefType     SpanRefType `thrift:"refType,1,required" db:"refType" json:"refType"`
	TraceIdLow  int64       `thrift:"traceIdLow,2,required" db:"traceIdLow" json:"traceIdLow"`
	TraceIdHigh int64       `thrift:"traceIdHigh,3,required" db:"traceIdHigh" json:"traceIdHigh"`
	SpanId      int64       `thrift:"spanId,4,required" db:"spanId" json:"spanId"`
}

Attributes:

  • RefType
  • TraceIdLow
  • TraceIdHigh
  • SpanId

func NewSpanRef

func NewSpanRef() *SpanRef

func (*SpanRef) Equals

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

func (*SpanRef) GetRefType

func (p *SpanRef) GetRefType() SpanRefType

func (*SpanRef) GetSpanId

func (p *SpanRef) GetSpanId() int64

func (*SpanRef) GetTraceIdHigh

func (p *SpanRef) GetTraceIdHigh() int64

func (*SpanRef) GetTraceIdLow

func (p *SpanRef) GetTraceIdLow() int64

func (*SpanRef) Read

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

func (*SpanRef) ReadField1

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

func (*SpanRef) ReadField2

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

func (*SpanRef) ReadField3

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

func (*SpanRef) ReadField4

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

func (*SpanRef) String

func (p *SpanRef) String() string

func (*SpanRef) Write

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

type SpanRefType

type SpanRefType int64
const (
	SpanRefType_CHILD_OF     SpanRefType = 0
	SpanRefType_FOLLOWS_FROM SpanRefType = 1
)

func SpanRefTypeFromString

func SpanRefTypeFromString(s string) (SpanRefType, error)

func SpanRefTypePtr

func SpanRefTypePtr(v SpanRefType) *SpanRefType

func (SpanRefType) MarshalText

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

func (*SpanRefType) Scan

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

func (SpanRefType) String

func (p SpanRefType) String() string

func (*SpanRefType) UnmarshalText

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

func (*SpanRefType) Value

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

type Tag

type Tag struct {
	Key     string   `thrift:"key,1,required" db:"key" json:"key"`
	VType   TagType  `thrift:"vType,2,required" db:"vType" json:"vType"`
	VStr    *string  `thrift:"vStr,3" db:"vStr" json:"vStr,omitempty"`
	VDouble *float64 `thrift:"vDouble,4" db:"vDouble" json:"vDouble,omitempty"`
	VBool   *bool    `thrift:"vBool,5" db:"vBool" json:"vBool,omitempty"`
	VLong   *int64   `thrift:"vLong,6" db:"vLong" json:"vLong,omitempty"`
	VBinary []byte   `thrift:"vBinary,7" db:"vBinary" json:"vBinary,omitempty"`
}

Attributes:

  • Key
  • VType
  • VStr
  • VDouble
  • VBool
  • VLong
  • VBinary

func NewTag

func NewTag() *Tag

func (*Tag) Equals

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

func (*Tag) GetKey

func (p *Tag) GetKey() string

func (*Tag) GetVBinary

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

func (*Tag) GetVBool

func (p *Tag) GetVBool() bool

func (*Tag) GetVDouble

func (p *Tag) GetVDouble() float64

func (*Tag) GetVLong

func (p *Tag) GetVLong() int64

func (*Tag) GetVStr

func (p *Tag) GetVStr() string

func (*Tag) GetVType

func (p *Tag) GetVType() TagType

func (*Tag) IsSetVBinary

func (p *Tag) IsSetVBinary() bool

func (*Tag) IsSetVBool

func (p *Tag) IsSetVBool() bool

func (*Tag) IsSetVDouble

func (p *Tag) IsSetVDouble() bool

func (*Tag) IsSetVLong

func (p *Tag) IsSetVLong() bool

func (*Tag) IsSetVStr

func (p *Tag) IsSetVStr() bool

func (*Tag) Read

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

func (*Tag) ReadField1

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

func (*Tag) ReadField2

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

func (*Tag) ReadField3

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

func (*Tag) ReadField4

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

func (*Tag) ReadField5

func (p *Tag) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*Tag) ReadField6

func (p *Tag) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*Tag) ReadField7

func (p *Tag) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*Tag) String

func (p *Tag) String() string

func (*Tag) Write

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

type TagType

type TagType int64
const (
	TagType_STRING TagType = 0
	TagType_DOUBLE TagType = 1
	TagType_BOOL   TagType = 2
	TagType_LONG   TagType = 3
	TagType_BINARY TagType = 4
)

func TagTypeFromString

func TagTypeFromString(s string) (TagType, error)

func TagTypePtr

func TagTypePtr(v TagType) *TagType

func (TagType) MarshalText

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

func (*TagType) Scan

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

func (TagType) String

func (p TagType) String() string

func (*TagType) UnmarshalText

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

func (*TagType) Value

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL