Documentation

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

This section is empty.

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 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" db:"process" json:"process"`
      	Spans   []*Span  `thrift:"spans,2,required" db:"spans" 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) ReadField1

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

        func (*Batch) ReadField2

        func (p *Batch) ReadField2(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" db:"ok" 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) ReadField1

          func (p *BatchSubmitResponse) ReadField1(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(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 NewCollectorClientFactory

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

            Deprecated: Use NewCollector instead

            func NewCollectorClientProtocol

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

              Deprecated: Use NewCollector instead

              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(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 (p *CollectorSubmitBatchesResult) ReadField0(iprot thrift.TProtocol) error

                    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) 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) ReadField1

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

                      func (*Log) ReadField2

                      func (p *Log) ReadField2(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" 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 (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) ReadField1

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

                        func (*Process) ReadField2

                        func (p *Process) ReadField2(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" 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) 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) ReadField1

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

                          func (*Span) ReadField10

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

                          func (*Span) ReadField11

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

                          func (*Span) ReadField2

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

                          func (*Span) ReadField3

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

                          func (*Span) ReadField4

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

                          func (*Span) ReadField5

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

                          func (*Span) ReadField6

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

                          func (*Span) ReadField7

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

                          func (*Span) ReadField8

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

                          func (*Span) ReadField9

                          func (p *Span) ReadField9(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" 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) 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) ReadField1

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

                            func (*SpanRef) ReadField2

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

                            func (*SpanRef) ReadField3

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

                            func (*SpanRef) ReadField4

                            func (p *SpanRef) ReadField4(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) 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) 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) ReadField1

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

                              func (*Tag) ReadField2

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

                              func (*Tag) ReadField3

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

                              func (*Tag) ReadField4

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

                              func (*Tag) ReadField5

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

                              func (*Tag) ReadField6

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

                              func (*Tag) ReadField7

                              func (p *Tag) ReadField7(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) 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)

                              Directories

                              Path Synopsis