Documentation ¶
Index ¶
- Variables
- type Batch
- func (p *Batch) Equals(other *Batch) bool
- func (p *Batch) GetProcess() *Process
- func (p *Batch) GetSeqNo() int64
- func (p *Batch) GetSpans() []*Span
- func (p *Batch) GetStats() *ClientStats
- func (p *Batch) IsSetProcess() bool
- func (p *Batch) IsSetSeqNo() bool
- func (p *Batch) IsSetStats() bool
- func (p *Batch) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Batch) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Batch) ReadField2(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Batch) ReadField3(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Batch) ReadField4(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Batch) String() string
- func (p *Batch) Write(ctx context.Context, oprot thrift.TProtocol) error
- type BatchSubmitResponse
- func (p *BatchSubmitResponse) Equals(other *BatchSubmitResponse) bool
- func (p *BatchSubmitResponse) GetOk() bool
- func (p *BatchSubmitResponse) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *BatchSubmitResponse) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
- func (p *BatchSubmitResponse) String() string
- func (p *BatchSubmitResponse) Write(ctx context.Context, oprot thrift.TProtocol) error
- type 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 Collector
- type CollectorClient
- func (p *CollectorClient) Client_() thrift.TClient
- func (p *CollectorClient) LastResponseMeta_() thrift.ResponseMeta
- func (p *CollectorClient) SetLastResponseMeta_(meta thrift.ResponseMeta)
- func (p *CollectorClient) SubmitBatches(ctx context.Context, batches []*Batch) (_r []*BatchSubmitResponse, _err error)
- type 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
- func (p *CollectorSubmitBatchesArgs) GetBatches() []*Batch
- func (p *CollectorSubmitBatchesArgs) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *CollectorSubmitBatchesArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
- func (p *CollectorSubmitBatchesArgs) String() string
- func (p *CollectorSubmitBatchesArgs) Write(ctx context.Context, oprot thrift.TProtocol) error
- type CollectorSubmitBatchesResult
- func (p *CollectorSubmitBatchesResult) GetSuccess() []*BatchSubmitResponse
- func (p *CollectorSubmitBatchesResult) IsSetSuccess() bool
- func (p *CollectorSubmitBatchesResult) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *CollectorSubmitBatchesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error
- func (p *CollectorSubmitBatchesResult) String() string
- func (p *CollectorSubmitBatchesResult) Write(ctx context.Context, oprot thrift.TProtocol) error
- type Log
- func (p *Log) Equals(other *Log) bool
- func (p *Log) GetFields() []*Tag
- func (p *Log) GetTimestamp() int64
- func (p *Log) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Log) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Log) ReadField2(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Log) String() string
- func (p *Log) Write(ctx context.Context, oprot thrift.TProtocol) error
- type Process
- func (p *Process) Equals(other *Process) bool
- func (p *Process) GetServiceName() string
- func (p *Process) GetTags() []*Tag
- func (p *Process) IsSetTags() bool
- func (p *Process) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Process) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Process) ReadField2(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Process) String() string
- func (p *Process) Write(ctx context.Context, oprot thrift.TProtocol) error
- type Span
- func (p *Span) Equals(other *Span) bool
- 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(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Span) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Span) ReadField10(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Span) ReadField11(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Span) ReadField2(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Span) ReadField3(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Span) ReadField4(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Span) ReadField5(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Span) ReadField6(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Span) ReadField7(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Span) ReadField8(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Span) ReadField9(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Span) String() string
- func (p *Span) Write(ctx context.Context, oprot thrift.TProtocol) error
- type SpanRef
- func (p *SpanRef) Equals(other *SpanRef) bool
- func (p *SpanRef) GetRefType() SpanRefType
- func (p *SpanRef) GetSpanId() int64
- func (p *SpanRef) GetTraceIdHigh() int64
- func (p *SpanRef) GetTraceIdLow() int64
- func (p *SpanRef) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *SpanRef) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
- func (p *SpanRef) ReadField2(ctx context.Context, iprot thrift.TProtocol) error
- func (p *SpanRef) ReadField3(ctx context.Context, iprot thrift.TProtocol) error
- func (p *SpanRef) ReadField4(ctx context.Context, iprot thrift.TProtocol) error
- func (p *SpanRef) String() string
- func (p *SpanRef) Write(ctx context.Context, oprot thrift.TProtocol) error
- type SpanRefType
- type Tag
- func (p *Tag) Equals(other *Tag) bool
- 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(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Tag) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Tag) ReadField2(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Tag) ReadField3(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Tag) ReadField4(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Tag) ReadField5(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Tag) ReadField6(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Tag) ReadField7(ctx context.Context, iprot thrift.TProtocol) error
- func (p *Tag) String() string
- func (p *Tag) Write(ctx context.Context, oprot thrift.TProtocol) error
- type TagType
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 (*Batch) GetProcess ¶
func (*Batch) GetStats ¶ added in v1.17.0
func (p *Batch) GetStats() *ClientStats
func (*Batch) IsSetProcess ¶
func (*Batch) IsSetSeqNo ¶ added in v1.17.0
func (*Batch) IsSetStats ¶ added in v1.17.0
func (*Batch) ReadField1 ¶ added in v1.19.0
func (*Batch) ReadField2 ¶ added in v1.19.0
func (*Batch) ReadField3 ¶ added in v1.19.0
func (*Batch) ReadField4 ¶ added in v1.19.0
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 ¶ added in v1.23.0
func (p *BatchSubmitResponse) Equals(other *BatchSubmitResponse) bool
func (*BatchSubmitResponse) GetOk ¶
func (p *BatchSubmitResponse) GetOk() bool
func (*BatchSubmitResponse) ReadField1 ¶ added in v1.19.0
func (*BatchSubmitResponse) String ¶
func (p *BatchSubmitResponse) String() string
type ClientStats ¶ added in v1.17.0
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 ¶ added in v1.17.0
func NewClientStats() *ClientStats
func (*ClientStats) Equals ¶ added in v1.23.0
func (p *ClientStats) Equals(other *ClientStats) bool
func (*ClientStats) GetFailedToEmitSpans ¶ added in v1.17.0
func (p *ClientStats) GetFailedToEmitSpans() int64
func (*ClientStats) GetFullQueueDroppedSpans ¶ added in v1.17.0
func (p *ClientStats) GetFullQueueDroppedSpans() int64
func (*ClientStats) GetTooLargeDroppedSpans ¶ added in v1.17.0
func (p *ClientStats) GetTooLargeDroppedSpans() int64
func (*ClientStats) ReadField1 ¶ added in v1.19.0
func (*ClientStats) ReadField2 ¶ added in v1.19.0
func (*ClientStats) ReadField3 ¶ added in v1.19.0
func (*ClientStats) String ¶ added in v1.17.0
func (p *ClientStats) String() string
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 ¶ added in v1.19.0
func NewCollectorClient(c thrift.TClient) *CollectorClient
func NewCollectorClientFactory ¶
func NewCollectorClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *CollectorClient
func NewCollectorClientProtocol ¶
func NewCollectorClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *CollectorClient
func (*CollectorClient) Client_ ¶ added in v1.19.0
func (p *CollectorClient) Client_() thrift.TClient
func (*CollectorClient) LastResponseMeta_ ¶ added in v1.23.0
func (p *CollectorClient) LastResponseMeta_() thrift.ResponseMeta
func (*CollectorClient) SetLastResponseMeta_ ¶ added in v1.23.0
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) ReadField1 ¶ added in v1.19.0
func (*CollectorSubmitBatchesArgs) String ¶
func (p *CollectorSubmitBatchesArgs) String() string
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 (p *CollectorSubmitBatchesResult) GetSuccess() []*BatchSubmitResponse
func (*CollectorSubmitBatchesResult) IsSetSuccess ¶
func (p *CollectorSubmitBatchesResult) IsSetSuccess() bool
func (*CollectorSubmitBatchesResult) ReadField0 ¶ added in v1.19.0
func (*CollectorSubmitBatchesResult) String ¶
func (p *CollectorSubmitBatchesResult) String() string
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 (*Log) GetTimestamp ¶
func (*Log) ReadField1 ¶ added in v1.19.0
func (*Log) ReadField2 ¶ added in v1.19.0
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) GetServiceName ¶
func (*Process) ReadField1 ¶ added in v1.19.0
func (*Process) ReadField2 ¶ added in v1.19.0
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 (*Span) GetDuration ¶
func (*Span) GetOperationName ¶
func (*Span) GetParentSpanId ¶
func (*Span) GetReferences ¶
func (*Span) GetStartTime ¶
func (*Span) GetTraceIdHigh ¶
func (*Span) GetTraceIdLow ¶
func (*Span) IsSetReferences ¶
func (*Span) ReadField1 ¶ added in v1.19.0
func (*Span) ReadField10 ¶ added in v1.19.0
func (*Span) ReadField11 ¶ added in v1.19.0
func (*Span) ReadField2 ¶ added in v1.19.0
func (*Span) ReadField3 ¶ added in v1.19.0
func (*Span) ReadField4 ¶ added in v1.19.0
func (*Span) ReadField5 ¶ added in v1.19.0
func (*Span) ReadField6 ¶ added in v1.19.0
func (*Span) ReadField7 ¶ added in v1.19.0
func (*Span) ReadField8 ¶ added in v1.19.0
func (*Span) ReadField9 ¶ added in v1.19.0
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) GetRefType ¶
func (p *SpanRef) GetRefType() SpanRefType
func (*SpanRef) GetTraceIdHigh ¶
func (*SpanRef) GetTraceIdLow ¶
func (*SpanRef) ReadField1 ¶ added in v1.19.0
func (*SpanRef) ReadField2 ¶ added in v1.19.0
func (*SpanRef) ReadField3 ¶ added in v1.19.0
func (*SpanRef) ReadField4 ¶ added in v1.19.0
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 ¶ added in v1.19.0
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
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 (*Tag) GetVBinary ¶
func (*Tag) GetVDouble ¶
func (*Tag) IsSetVBinary ¶
func (*Tag) IsSetVBool ¶
func (*Tag) IsSetVDouble ¶
func (*Tag) IsSetVLong ¶
func (*Tag) ReadField1 ¶ added in v1.19.0
func (*Tag) ReadField2 ¶ added in v1.19.0
func (*Tag) ReadField3 ¶ added in v1.19.0
func (*Tag) ReadField4 ¶ added in v1.19.0
func (*Tag) ReadField5 ¶ added in v1.19.0
func (*Tag) ReadField6 ¶ added in v1.19.0
func (*Tag) ReadField7 ¶ added in v1.19.0
type TagType ¶
type TagType int64
func TagTypeFromString ¶
func TagTypePtr ¶
func (TagType) MarshalText ¶
func (*TagType) UnmarshalText ¶
Click to show internal directories.
Click to hide internal directories.