package jaeger
import "github.com/uber/jaeger-client-go/thrift-gen/jaeger"
Index ¶
- Variables
- type Agent
- type 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(batch *Batch) (err error)
- type AgentEmitBatchArgs
- 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
- 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
- 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) String() string
- func (p *Batch) Write(oprot thrift.TProtocol) error
- type BatchSubmitResponse
- func NewBatchSubmitResponse() *BatchSubmitResponse
- func (p *BatchSubmitResponse) GetOk() bool
- func (p *BatchSubmitResponse) Read(iprot thrift.TProtocol) error
- func (p *BatchSubmitResponse) String() string
- func (p *BatchSubmitResponse) Write(oprot thrift.TProtocol) error
- type Log
- func NewLog() *Log
- func (p *Log) GetFields() []*Tag
- func (p *Log) GetTimestamp() int64
- func (p *Log) Read(iprot thrift.TProtocol) error
- func (p *Log) String() string
- func (p *Log) Write(oprot thrift.TProtocol) error
- type 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) String() string
- func (p *Process) Write(oprot thrift.TProtocol) error
- type Span
- 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) String() string
- func (p *Span) Write(oprot thrift.TProtocol) error
- type SpanRef
- 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) String() string
- func (p *SpanRef) Write(oprot thrift.TProtocol) error
- type SpanRefType
- func SpanRefTypeFromString(s string) (SpanRefType, error)
- func SpanRefTypePtr(v SpanRefType) *SpanRefType
- func (p SpanRefType) MarshalText() ([]byte, error)
- func (p SpanRefType) String() string
- func (p *SpanRefType) UnmarshalText(text []byte) error
- type Tag
- 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) String() string
- func (p *Tag) Write(oprot thrift.TProtocol) error
- type TagType
Variables ¶
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
Types ¶
type Agent ¶
type AgentClient ¶
type AgentClient struct { Transport thrift.TTransport ProtocolFactory thrift.TProtocolFactory InputProtocol thrift.TProtocol OutputProtocol thrift.TProtocol SeqId int32 }
func NewAgentClientFactory ¶
func NewAgentClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *AgentClient
func NewAgentClientProtocol ¶
func NewAgentClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *AgentClient
func (*AgentClient) EmitBatch ¶
func (p *AgentClient) EmitBatch(batch *Batch) (err error)
Parameters:
- Batch
type AgentEmitBatchArgs ¶
type AgentEmitBatchArgs struct { Batch *Batch `thrift:"batch,1" json:"batch"` }
Attributes:
- Batch
func NewAgentEmitBatchArgs ¶
func NewAgentEmitBatchArgs() *AgentEmitBatchArgs
func (*AgentEmitBatchArgs) GetBatch ¶
func (p *AgentEmitBatchArgs) GetBatch() *Batch
func (*AgentEmitBatchArgs) IsSetBatch ¶
func (p *AgentEmitBatchArgs) IsSetBatch() bool
func (*AgentEmitBatchArgs) Read ¶
func (p *AgentEmitBatchArgs) Read(iprot thrift.TProtocol) error
func (*AgentEmitBatchArgs) String ¶
func (p *AgentEmitBatchArgs) String() string
func (*AgentEmitBatchArgs) Write ¶
func (p *AgentEmitBatchArgs) Write(oprot thrift.TProtocol) error
type AgentProcessor ¶
type AgentProcessor struct {
// contains filtered or unexported fields
}
func NewAgentProcessor ¶
func NewAgentProcessor(handler Agent) *AgentProcessor
func (*AgentProcessor) AddToProcessorMap ¶
func (p *AgentProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
func (*AgentProcessor) GetProcessorFunction ¶
func (p *AgentProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
func (*AgentProcessor) Process ¶
func (p *AgentProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
func (*AgentProcessor) ProcessorMap ¶
func (p *AgentProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
type Batch ¶
type Batch struct { Process *Process `thrift:"process,1,required" json:"process"` Spans []*Span `thrift:"spans,2,required" json:"spans"` }
Attributes:
- Process
- Spans
var AgentEmitBatchArgs_Batch_DEFAULT *Batch
func NewBatch ¶
func NewBatch() *Batch
func (*Batch) GetProcess ¶
func (*Batch) GetSpans ¶
func (*Batch) IsSetProcess ¶
func (*Batch) Read ¶
func (*Batch) String ¶
func (*Batch) Write ¶
type BatchSubmitResponse ¶
type BatchSubmitResponse struct { Ok bool `thrift:"ok,1,required" json:"ok"` }
Attributes:
- Ok
func NewBatchSubmitResponse ¶
func NewBatchSubmitResponse() *BatchSubmitResponse
func (*BatchSubmitResponse) GetOk ¶
func (p *BatchSubmitResponse) GetOk() bool
func (*BatchSubmitResponse) Read ¶
func (p *BatchSubmitResponse) Read(iprot thrift.TProtocol) error
func (*BatchSubmitResponse) String ¶
func (p *BatchSubmitResponse) String() string
func (*BatchSubmitResponse) Write ¶
func (p *BatchSubmitResponse) Write(oprot thrift.TProtocol) error
type Log ¶
type Log struct { Timestamp int64 `thrift:"timestamp,1,required" json:"timestamp"` Fields []*Tag `thrift:"fields,2,required" json:"fields"` }
Attributes:
- Timestamp
- Fields
func NewLog ¶
func NewLog() *Log
func (*Log) GetFields ¶
func (*Log) GetTimestamp ¶
func (*Log) Read ¶
func (*Log) String ¶
func (*Log) Write ¶
type Process ¶
type Process struct { ServiceName string `thrift:"serviceName,1,required" json:"serviceName"` Tags []*Tag `thrift:"tags,2" json:"tags,omitempty"` }
Attributes:
- ServiceName
- Tags
var Batch_Process_DEFAULT *Process
func NewProcess ¶
func NewProcess() *Process
func (*Process) GetServiceName ¶
func (*Process) GetTags ¶
func (*Process) IsSetTags ¶
func (*Process) Read ¶
func (*Process) String ¶
func (*Process) Write ¶
type Span ¶
type Span struct { TraceIdLow int64 `thrift:"traceIdLow,1,required" json:"traceIdLow"` TraceIdHigh int64 `thrift:"traceIdHigh,2,required" json:"traceIdHigh"` SpanId int64 `thrift:"spanId,3,required" json:"spanId"` ParentSpanId int64 `thrift:"parentSpanId,4,required" json:"parentSpanId"` OperationName string `thrift:"operationName,5,required" json:"operationName"` References []*SpanRef `thrift:"references,6" json:"references,omitempty"` Flags int32 `thrift:"flags,7,required" json:"flags"` StartTime int64 `thrift:"startTime,8,required" json:"startTime"` Duration int64 `thrift:"duration,9,required" json:"duration"` Tags []*Tag `thrift:"tags,10" json:"tags,omitempty"` Logs []*Log `thrift:"logs,11" json:"logs,omitempty"` }
Attributes:
- TraceIdLow
- TraceIdHigh
- SpanId
- ParentSpanId
- OperationName
- References
- Flags
- StartTime
- Duration
- Tags
- Logs
func NewSpan ¶
func NewSpan() *Span
func (*Span) GetDuration ¶
func (*Span) GetFlags ¶
func (*Span) GetLogs ¶
func (*Span) GetOperationName ¶
func (*Span) GetParentSpanId ¶
func (*Span) GetReferences ¶
func (*Span) GetSpanId ¶
func (*Span) GetStartTime ¶
func (*Span) GetTags ¶
func (*Span) GetTraceIdHigh ¶
func (*Span) GetTraceIdLow ¶
func (*Span) IsSetLogs ¶
func (*Span) IsSetReferences ¶
func (*Span) IsSetTags ¶
func (*Span) Read ¶
func (*Span) String ¶
func (*Span) Write ¶
type SpanRef ¶
type SpanRef struct { RefType SpanRefType `thrift:"refType,1,required" json:"refType"` TraceIdLow int64 `thrift:"traceIdLow,2,required" json:"traceIdLow"` TraceIdHigh int64 `thrift:"traceIdHigh,3,required" json:"traceIdHigh"` SpanId int64 `thrift:"spanId,4,required" json:"spanId"` }
Attributes:
- RefType
- TraceIdLow
- TraceIdHigh
- SpanId
func NewSpanRef ¶
func NewSpanRef() *SpanRef
func (*SpanRef) GetRefType ¶
func (p *SpanRef) GetRefType() SpanRefType
func (*SpanRef) GetSpanId ¶
func (*SpanRef) GetTraceIdHigh ¶
func (*SpanRef) GetTraceIdLow ¶
func (*SpanRef) Read ¶
func (*SpanRef) String ¶
func (*SpanRef) Write ¶
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) 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" json:"key"` VType TagType `thrift:"vType,2,required" json:"vType"` VStr *string `thrift:"vStr,3" json:"vStr,omitempty"` VDouble *float64 `thrift:"vDouble,4" json:"vDouble,omitempty"` VBool *bool `thrift:"vBool,5" json:"vBool,omitempty"` VLong *int64 `thrift:"vLong,6" json:"vLong,omitempty"` VBinary []byte `thrift:"vBinary,7" json:"vBinary,omitempty"` }
Attributes:
- Key
- VType
- VStr
- VDouble
- VBool
- VLong
- VBinary
func NewTag ¶
func NewTag() *Tag
func (*Tag) GetKey ¶
func (*Tag) GetVBinary ¶
func (*Tag) GetVBool ¶
func (*Tag) GetVDouble ¶
func (*Tag) GetVLong ¶
func (*Tag) GetVStr ¶
func (*Tag) GetVType ¶
func (*Tag) IsSetVBinary ¶
func (*Tag) IsSetVBool ¶
func (*Tag) IsSetVDouble ¶
func (*Tag) IsSetVLong ¶
func (*Tag) IsSetVStr ¶
func (*Tag) Read ¶
func (*Tag) String ¶
func (*Tag) Write ¶
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 TagTypePtr ¶
func (TagType) MarshalText ¶
func (TagType) String ¶
func (*TagType) UnmarshalText ¶
Source Files ¶
agent.go constants.go ttypes.go
- Version
- v2.11.2+incompatible
- Published
- Jan 12, 2018
- Platform
- darwin/amd64
- Imports
- 3 packages
- Last checked
- 30 minutes ago –
Tools for package owners.