jaeger

package
v1.15.1 Latest Latest
Warning

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

 Go to latest Published: Nov 7, 2019 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation ¶

Overview ¶

Package jaeger is generated code used to make or handle TChannel calls using Thrift.

Index ¶

Constants ¶

This section is empty.

Variables ¶

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 ¶

func NewTChanCollectorInheritedClient ¶ 

func NewTChanCollectorInheritedClient(thriftService string, client thrift.TChanClient) *tchanCollectorClient

func NewTChanCollectorServer ¶ 

func NewTChanCollectorServer(handler TChanCollector) thrift.TChanServer

NewTChanCollectorServer wraps a handler for TChanCollector so it can be registered with a thrift.Server.

Types ¶

type Agent ¶ 

type Agent interface {
	// Parameters:
	//  - Batch
	EmitBatch(batch *Batch) (err error)
}

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 (p *Batch) GetProcess() *Process

func (*Batch) GetSpans ¶ 

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

func (*Batch) IsSetProcess ¶ 

func (p *Batch) IsSetProcess() bool

func (*Batch) Read ¶ 

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

func (*Batch) String ¶ 

func (p *Batch) String() string

func (*Batch) Write ¶ 

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

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 Collector ¶ 

type Collector interface {
	// Parameters:
	//  - Batches
	SubmitBatches(batches []*Batch) (r []*BatchSubmitResponse, err error)
}

type CollectorClient ¶ 

type CollectorClient struct {
	Transport       thrift.TTransport
	ProtocolFactory thrift.TProtocolFactory
	InputProtocol   thrift.TProtocol
	OutputProtocol  thrift.TProtocol
	SeqId           int32
}

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) SubmitBatches ¶ 

func (p *CollectorClient) SubmitBatches(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(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" json:"batches"`
}

Attributes:

  • Batches

func NewCollectorSubmitBatchesArgs ¶ 

func NewCollectorSubmitBatchesArgs() *CollectorSubmitBatchesArgs

func (*CollectorSubmitBatchesArgs) GetBatches ¶ 

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

func (*CollectorSubmitBatchesArgs) Read ¶ 

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

func (*CollectorSubmitBatchesArgs) String ¶ 

func (p *CollectorSubmitBatchesArgs) String() string

func (*CollectorSubmitBatchesArgs) Write ¶ 

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

type CollectorSubmitBatchesResult ¶ 

type CollectorSubmitBatchesResult struct {
	Success []*BatchSubmitResponse `thrift:"success,0" 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) Read ¶ 

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

func (*CollectorSubmitBatchesResult) String ¶ 

func (p *CollectorSubmitBatchesResult) String() string

func (*CollectorSubmitBatchesResult) Write ¶ 

func (p *CollectorSubmitBatchesResult) 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 (p *Log) GetFields() []*Tag

func (*Log) GetTimestamp ¶ 

func (p *Log) GetTimestamp() int64

func (*Log) Read ¶ 

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

func (*Log) String ¶ 

func (p *Log) String() string

func (*Log) Write ¶ 

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

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 (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(iprot thrift.TProtocol) error

func (*Process) String ¶ 

func (p *Process) String() string

func (*Process) Write ¶ 

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

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 (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(iprot thrift.TProtocol) error

func (*Span) String ¶ 

func (p *Span) String() string

func (*Span) Write ¶ 

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

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 (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(iprot thrift.TProtocol) error

func (*SpanRef) String ¶ 

func (p *SpanRef) String() string

func (*SpanRef) Write ¶ 

func (p *SpanRef) Write(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) String ¶ 

func (p SpanRefType) String() string

func (*SpanRefType) UnmarshalText ¶ 

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

type TChanCollector ¶ 

type TChanCollector interface {
	SubmitBatches(ctx thrift.Context, batches []*Batch) ([]*BatchSubmitResponse, error)
}

TChanCollector is the interface that defines the server handler and client interface.

func NewTChanCollectorClient ¶ 

func NewTChanCollectorClient(client thrift.TChanClient) TChanCollector

NewTChanCollectorClient creates a client that can be used to make remote calls.

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 (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(iprot thrift.TProtocol) error

func (*Tag) String ¶ 

func (p *Tag) String() string

func (*Tag) Write ¶ 

func (p *Tag) Write(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) String ¶ 

func (p TagType) String() string

func (*TagType) UnmarshalText ¶ 

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

Source Files ¶

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.