tcollector

package
v0.0.0-...-a1a640b Latest Latest
Warning

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

 Go to latest Published: Aug 29, 2015 License: MIT Imports: 4 Imported by: 0

Documentation

Overview

Autogenerated by thrift-gen. Do not modify.

Index

Constants

This section is empty.

Variables

View Source 
var Annotation_Duration_DEFAULT int32
View Source 
var BinaryAnnotation_BoolValue_DEFAULT bool
View Source 
var BinaryAnnotation_BytesValue_DEFAULT []byte
View Source 
var BinaryAnnotation_DoubleValue_DEFAULT float64
View Source 
var BinaryAnnotation_IntValue_DEFAULT int64
View Source 
var BinaryAnnotation_StringValue_DEFAULT string
View Source 
var GoUnusedProtection__ int
View Source 
var MultiSubmitResult_Success_DEFAULT []*Response
View Source 
var Span_Debug_DEFAULT bool = false

Functions

func NewTChanTCollectorServer 

func NewTChanTCollectorServer(handler TChanTCollector) thrift.TChanServer

Types

type Annotation 

type Annotation struct {
	Timestamp float64 `thrift:"timestamp,1" json:"timestamp"`
	Value     string  `thrift:"value,2" json:"value"`
	Duration  *int32  `thrift:"duration,3" json:"duration"`
}

func NewAnnotation 

func NewAnnotation() *Annotation

func (*Annotation) GetDuration 

func (p *Annotation) GetDuration() int32

func (*Annotation) GetTimestamp 

func (p *Annotation) GetTimestamp() float64

func (*Annotation) GetValue 

func (p *Annotation) GetValue() string

func (*Annotation) IsSetDuration 

func (p *Annotation) IsSetDuration() bool

func (*Annotation) Read 

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

func (*Annotation) ReadField1 

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

func (*Annotation) ReadField2 

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

func (*Annotation) ReadField3 

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

func (*Annotation) String 

func (p *Annotation) String() string

func (*Annotation) Write 

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

type AnnotationType 

type AnnotationType int64
const (
	AnnotationType_BOOL   AnnotationType = 0
	AnnotationType_BYTES  AnnotationType = 1
	AnnotationType_I16    AnnotationType = 2
	AnnotationType_I32    AnnotationType = 3
	AnnotationType_I64    AnnotationType = 4
	AnnotationType_DOUBLE AnnotationType = 5
	AnnotationType_STRING AnnotationType = 6
)

func AnnotationTypeFromString 

func AnnotationTypeFromString(s string) (AnnotationType, error)

func AnnotationTypePtr 

func AnnotationTypePtr(v AnnotationType) *AnnotationType

func (AnnotationType) String 

func (p AnnotationType) String() string

type BinaryAnnotation 

type BinaryAnnotation struct {
	Key            string         `thrift:"key,1" json:"key"`
	StringValue    *string        `thrift:"stringValue,2" json:"stringValue"`
	DoubleValue    *float64       `thrift:"doubleValue,3" json:"doubleValue"`
	BoolValue      *bool          `thrift:"boolValue,4" json:"boolValue"`
	BytesValue     []byte         `thrift:"bytesValue,5" json:"bytesValue"`
	IntValue       *int64         `thrift:"intValue,6" json:"intValue"`
	AnnotationType AnnotationType `thrift:"annotationType,7" json:"annotationType"`
}

func NewBinaryAnnotation 

func NewBinaryAnnotation() *BinaryAnnotation

func (*BinaryAnnotation) GetAnnotationType 

func (p *BinaryAnnotation) GetAnnotationType() AnnotationType

func (*BinaryAnnotation) GetBoolValue 

func (p *BinaryAnnotation) GetBoolValue() bool

func (*BinaryAnnotation) GetBytesValue 

func (p *BinaryAnnotation) GetBytesValue() []byte

func (*BinaryAnnotation) GetDoubleValue 

func (p *BinaryAnnotation) GetDoubleValue() float64

func (*BinaryAnnotation) GetIntValue 

func (p *BinaryAnnotation) GetIntValue() int64

func (*BinaryAnnotation) GetKey 

func (p *BinaryAnnotation) GetKey() string

func (*BinaryAnnotation) GetStringValue 

func (p *BinaryAnnotation) GetStringValue() string

func (*BinaryAnnotation) IsSetBoolValue 

func (p *BinaryAnnotation) IsSetBoolValue() bool

func (*BinaryAnnotation) IsSetBytesValue 

func (p *BinaryAnnotation) IsSetBytesValue() bool

func (*BinaryAnnotation) IsSetDoubleValue 

func (p *BinaryAnnotation) IsSetDoubleValue() bool

func (*BinaryAnnotation) IsSetIntValue 

func (p *BinaryAnnotation) IsSetIntValue() bool

func (*BinaryAnnotation) IsSetStringValue 

func (p *BinaryAnnotation) IsSetStringValue() bool

func (*BinaryAnnotation) Read 

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

func (*BinaryAnnotation) ReadField1 

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

func (*BinaryAnnotation) ReadField2 

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

func (*BinaryAnnotation) ReadField3 

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

func (*BinaryAnnotation) ReadField4 

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

func (*BinaryAnnotation) ReadField5 

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

func (*BinaryAnnotation) ReadField6 

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

func (*BinaryAnnotation) ReadField7 

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

func (*BinaryAnnotation) String 

func (p *BinaryAnnotation) String() string

func (*BinaryAnnotation) Write 

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

type Endpoint 

type Endpoint struct {
	Ipv4        int32  `thrift:"ipv4,1" json:"ipv4"`
	Port        int32  `thrift:"port,2" json:"port"`
	ServiceName string `thrift:"serviceName,3" json:"serviceName"`
}
var Span_Host_DEFAULT *Endpoint

func NewEndpoint 

func NewEndpoint() *Endpoint

func (*Endpoint) GetIpv4 

func (p *Endpoint) GetIpv4() int32

func (*Endpoint) GetPort 

func (p *Endpoint) GetPort() int32

func (*Endpoint) GetServiceName 

func (p *Endpoint) GetServiceName() string

func (*Endpoint) Read 

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

func (*Endpoint) ReadField1 

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

func (*Endpoint) ReadField2 

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

func (*Endpoint) ReadField3 

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

func (*Endpoint) String 

func (p *Endpoint) String() string

func (*Endpoint) Write 

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

type MultiSubmitArgs 

type MultiSubmitArgs struct {
	Spans []*Span `thrift:"spans,1" json:"spans"`
}

func NewMultiSubmitArgs 

func NewMultiSubmitArgs() *MultiSubmitArgs

func (*MultiSubmitArgs) GetSpans 

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

func (*MultiSubmitArgs) Read 

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

func (*MultiSubmitArgs) ReadField1 

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

func (*MultiSubmitArgs) String 

func (p *MultiSubmitArgs) String() string

func (*MultiSubmitArgs) Write 

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

type MultiSubmitResult 

type MultiSubmitResult struct {
	Success []*Response `thrift:"success,0" json:"success"`
}

func NewMultiSubmitResult 

func NewMultiSubmitResult() *MultiSubmitResult

func (*MultiSubmitResult) GetSuccess 

func (p *MultiSubmitResult) GetSuccess() []*Response

func (*MultiSubmitResult) IsSetSuccess 

func (p *MultiSubmitResult) IsSetSuccess() bool

func (*MultiSubmitResult) Read 

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

func (*MultiSubmitResult) ReadField0 

func (p *MultiSubmitResult) ReadField0(iprot thrift.TProtocol) error

func (*MultiSubmitResult) String 

func (p *MultiSubmitResult) String() string

func (*MultiSubmitResult) Write 

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

type Response 

type Response struct {
	Ok bool `thrift:"ok,1" json:"ok"`
}
var SubmitResult_Success_DEFAULT *Response

func NewResponse 

func NewResponse() *Response

func (*Response) GetOk 

func (p *Response) GetOk() bool

func (*Response) Read 

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

func (*Response) ReadField1 

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

func (*Response) String 

func (p *Response) String() string

func (*Response) Write 

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

type Span 

type Span struct {
	TraceId           []byte              `thrift:"traceId,1" json:"traceId"`
	Host              *Endpoint           `thrift:"host,2" json:"host"`
	Name              string              `thrift:"name,3" json:"name"`
	Id                []byte              `thrift:"id,4" json:"id"`
	ParentId          []byte              `thrift:"parentId,5" json:"parentId"`
	Annotations       []*Annotation       `thrift:"annotations,6" json:"annotations"`
	BinaryAnnotations []*BinaryAnnotation `thrift:"binaryAnnotations,7" json:"binaryAnnotations"`
	Debug             bool                `thrift:"debug,8" json:"debug"`
}
var SubmitArgs_Span_DEFAULT *Span

func NewSpan 

func NewSpan() *Span

func (*Span) GetAnnotations 

func (p *Span) GetAnnotations() []*Annotation

func (*Span) GetBinaryAnnotations 

func (p *Span) GetBinaryAnnotations() []*BinaryAnnotation

func (*Span) GetDebug 

func (p *Span) GetDebug() bool

func (*Span) GetHost 

func (p *Span) GetHost() *Endpoint

func (*Span) GetId 

func (p *Span) GetId() []byte

func (*Span) GetName 

func (p *Span) GetName() string

func (*Span) GetParentId 

func (p *Span) GetParentId() []byte

func (*Span) GetTraceId 

func (p *Span) GetTraceId() []byte

func (*Span) IsSetDebug 

func (p *Span) IsSetDebug() bool

func (*Span) IsSetHost 

func (p *Span) IsSetHost() 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) 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) String 

func (p *Span) String() string

func (*Span) Write 

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

type SubmitArgs 

type SubmitArgs struct {
	Span *Span `thrift:"span,1" json:"span"`
}

func NewSubmitArgs 

func NewSubmitArgs() *SubmitArgs

func (*SubmitArgs) GetSpan 

func (p *SubmitArgs) GetSpan() *Span

func (*SubmitArgs) IsSetSpan 

func (p *SubmitArgs) IsSetSpan() bool

func (*SubmitArgs) Read 

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

func (*SubmitArgs) ReadField1 

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

func (*SubmitArgs) String 

func (p *SubmitArgs) String() string

func (*SubmitArgs) Write 

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

type SubmitResult 

type SubmitResult struct {
	Success *Response `thrift:"success,0" json:"success"`
}

func NewSubmitResult 

func NewSubmitResult() *SubmitResult

func (*SubmitResult) GetSuccess 

func (p *SubmitResult) GetSuccess() *Response

func (*SubmitResult) IsSetSuccess 

func (p *SubmitResult) IsSetSuccess() bool

func (*SubmitResult) Read 

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

func (*SubmitResult) ReadField0 

func (p *SubmitResult) ReadField0(iprot thrift.TProtocol) error

func (*SubmitResult) String 

func (p *SubmitResult) String() string

func (*SubmitResult) Write 

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

type TChanTCollector 

type TChanTCollector interface {
	MultiSubmit(ctx thrift.Context, spans []*Span) ([]*Response, error)
	Submit(ctx thrift.Context, span *Span) (*Response, error)
}

func NewTChanTCollectorClient 

func NewTChanTCollectorClient(client thrift.TChanClient) TChanTCollector

type TCollector 

type TCollector interface {
	// Parameters:
	//  - Span
	Submit(span *Span) (r *Response, err error)
	// Parameters:
	//  - Spans
	MultiSubmit(spans []*Span) (r []*Response, err error)
}

type TCollectorClient 

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

func NewTCollectorClientFactory 

func NewTCollectorClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *TCollectorClient

func NewTCollectorClientProtocol 

func NewTCollectorClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TCollectorClient

func (*TCollectorClient) MultiSubmit 

func (p *TCollectorClient) MultiSubmit(spans []*Span) (r []*Response, err error)

Parameters:

  • Spans

func (*TCollectorClient) Submit 

func (p *TCollectorClient) Submit(span *Span) (r *Response, err error)

Parameters:

  • Span

type TCollectorProcessor 

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

func NewTCollectorProcessor 

func NewTCollectorProcessor(handler TCollector) *TCollectorProcessor

func (*TCollectorProcessor) AddToProcessorMap 

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

func (*TCollectorProcessor) GetProcessorFunction 

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

func (*TCollectorProcessor) Process 

func (p *TCollectorProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*TCollectorProcessor) ProcessorMap 

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

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.