tcollector

package

Go to main page

Versions in this module

v1

v1.0.9

Jul 21, 2016

v1.0.8

Jul 16, 2016

Changes in this version

type Annotation

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

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

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

type AnnotationType

+ func (p *AnnotationType) Scan(value interface{}) error

+ func (p *AnnotationType) Value() (driver.Value, error)

type BinaryAnnotation

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

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

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

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

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

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

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

type Endpoint

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

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

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

type ProbabilisticSamplingStrategy

+ func (p *ProbabilisticSamplingStrategy) ReadField1(iprot thrift.TProtocol) error

type RateLimitingSamplingStrategy

+ func (p *RateLimitingSamplingStrategy) ReadField1(iprot thrift.TProtocol) error

type Response

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

type SamplingStrategyResponse

+ func (p *SamplingStrategyResponse) ReadField1(iprot thrift.TProtocol) error

+ func (p *SamplingStrategyResponse) ReadField2(iprot thrift.TProtocol) error

+ func (p *SamplingStrategyResponse) ReadField3(iprot thrift.TProtocol) error

type SamplingStrategyType

+ func (p *SamplingStrategyType) Scan(value interface{}) error

+ func (p *SamplingStrategyType) Value() (driver.Value, error)

type Span

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

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

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

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

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

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

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

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

+ func (p *Span) ReadField9(iprot thrift.TProtocol) error

type TCollectorGetSamplingStrategyArgs

+ func (p *TCollectorGetSamplingStrategyArgs) ReadField1(iprot thrift.TProtocol) error

type TCollectorGetSamplingStrategyResult

+ func (p *TCollectorGetSamplingStrategyResult) ReadField0(iprot thrift.TProtocol) error

type TCollectorSubmitArgs

+ func (p *TCollectorSubmitArgs) ReadField1(iprot thrift.TProtocol) error

type TCollectorSubmitBatchArgs

+ func (p *TCollectorSubmitBatchArgs) ReadField1(iprot thrift.TProtocol) error

type TCollectorSubmitBatchResult

+ func (p *TCollectorSubmitBatchResult) ReadField0(iprot thrift.TProtocol) error

type TCollectorSubmitResult

+ func (p *TCollectorSubmitResult) ReadField0(iprot thrift.TProtocol) error

v1.0.6

Jun 16, 2016

v1.0.6-dev

Apr 6, 2016

v1.0.5

Apr 4, 2016

v1.0.4

Mar 10, 2016

v1.0.3

Feb 16, 2016

v1.0.2

Jan 29, 2016

v1.0.1

Jan 19, 2016

v1.0.0

Jan 10, 2016

Changes in this version

+ var Annotation_Duration_DEFAULT int32

+ var BinaryAnnotation_BoolValue_DEFAULT bool

+ var BinaryAnnotation_BytesValue_DEFAULT []byte

+ var BinaryAnnotation_DoubleValue_DEFAULT float64

+ var BinaryAnnotation_IntValue_DEFAULT int64

+ var BinaryAnnotation_StringValue_DEFAULT string

+ var GoUnusedProtection__ int

+ var Span_Debug_DEFAULT bool = false

+ var TCollectorSubmitBatchResult_Success_DEFAULT []*Response

+ func NewTChanTCollectorInheritedClient(thriftService string, client thrift.TChanClient) *tchanTCollectorClient

+ func NewTChanTCollectorServer(handler TChanTCollector) thrift.TChanServer

+ type Annotation struct

+ Duration *int32

+ Timestamp float64

+ Value string

+ func NewAnnotation() *Annotation

+ func (p *Annotation) GetDuration() int32

+ func (p *Annotation) GetTimestamp() float64

+ func (p *Annotation) GetValue() string

+ func (p *Annotation) IsSetDuration() bool

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

+ func (p *Annotation) String() string

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

+ type AnnotationType int64

+ const AnnotationType_BOOL

+ const AnnotationType_BYTES

+ const AnnotationType_DOUBLE

+ const AnnotationType_I16

+ const AnnotationType_I32

+ const AnnotationType_I64

+ const AnnotationType_STRING

+ func AnnotationTypeFromString(s string) (AnnotationType, error)

+ func AnnotationTypePtr(v AnnotationType) *AnnotationType

+ func (p *AnnotationType) UnmarshalText(text []byte) error

+ func (p AnnotationType) MarshalText() ([]byte, error)

+ func (p AnnotationType) String() string

+ type BinaryAnnotation struct

+ AnnotationType AnnotationType

+ BoolValue *bool

+ BytesValue []byte

+ DoubleValue *float64

+ IntValue *int64

+ Key string

+ StringValue *string

+ func NewBinaryAnnotation() *BinaryAnnotation

+ func (p *BinaryAnnotation) GetAnnotationType() AnnotationType

+ func (p *BinaryAnnotation) GetBoolValue() bool

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

+ func (p *BinaryAnnotation) GetDoubleValue() float64

+ func (p *BinaryAnnotation) GetIntValue() int64

+ func (p *BinaryAnnotation) GetKey() string

+ func (p *BinaryAnnotation) GetStringValue() string

+ func (p *BinaryAnnotation) IsSetBoolValue() bool

+ func (p *BinaryAnnotation) IsSetBytesValue() bool

+ func (p *BinaryAnnotation) IsSetDoubleValue() bool

+ func (p *BinaryAnnotation) IsSetIntValue() bool

+ func (p *BinaryAnnotation) IsSetStringValue() bool

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

+ func (p *BinaryAnnotation) String() string

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

+ type Endpoint struct

+ Ipv4 int32

+ Port int32

+ ServiceName string

+ var Span_Host_DEFAULT *Endpoint

+ var Span_SpanHost_DEFAULT *Endpoint

+ func NewEndpoint() *Endpoint

+ func (p *Endpoint) GetIpv4() int32

+ func (p *Endpoint) GetPort() int32

+ func (p *Endpoint) GetServiceName() string

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

+ func (p *Endpoint) String() string

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

+ type ProbabilisticSamplingStrategy struct

+ SamplingRate float64

+ var SamplingStrategyResponse_ProbabilisticSampling_DEFAULT *ProbabilisticSamplingStrategy

+ func NewProbabilisticSamplingStrategy() *ProbabilisticSamplingStrategy

+ func (p *ProbabilisticSamplingStrategy) GetSamplingRate() float64

+ func (p *ProbabilisticSamplingStrategy) Read(iprot thrift.TProtocol) error

+ func (p *ProbabilisticSamplingStrategy) String() string

+ func (p *ProbabilisticSamplingStrategy) Write(oprot thrift.TProtocol) error

+ type RateLimitingSamplingStrategy struct

+ MaxTracesPerSecond int16

+ var SamplingStrategyResponse_RateLimitingSampling_DEFAULT *RateLimitingSamplingStrategy

+ func NewRateLimitingSamplingStrategy() *RateLimitingSamplingStrategy

+ func (p *RateLimitingSamplingStrategy) GetMaxTracesPerSecond() int16

+ func (p *RateLimitingSamplingStrategy) Read(iprot thrift.TProtocol) error

+ func (p *RateLimitingSamplingStrategy) String() string

+ func (p *RateLimitingSamplingStrategy) Write(oprot thrift.TProtocol) error

+ type Response struct

+ Ok bool

+ var TCollectorSubmitResult_Success_DEFAULT *Response

+ func NewResponse() *Response

+ func (p *Response) GetOk() bool

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

+ func (p *Response) String() string

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

+ type SamplingStrategyResponse struct

+ ProbabilisticSampling *ProbabilisticSamplingStrategy

+ RateLimitingSampling *RateLimitingSamplingStrategy

+ StrategyType SamplingStrategyType

+ var TCollectorGetSamplingStrategyResult_Success_DEFAULT *SamplingStrategyResponse

+ func NewSamplingStrategyResponse() *SamplingStrategyResponse

+ func (p *SamplingStrategyResponse) GetProbabilisticSampling() *ProbabilisticSamplingStrategy

+ func (p *SamplingStrategyResponse) GetRateLimitingSampling() *RateLimitingSamplingStrategy

+ func (p *SamplingStrategyResponse) GetStrategyType() SamplingStrategyType

+ func (p *SamplingStrategyResponse) IsSetProbabilisticSampling() bool

+ func (p *SamplingStrategyResponse) IsSetRateLimitingSampling() bool

+ func (p *SamplingStrategyResponse) Read(iprot thrift.TProtocol) error

+ func (p *SamplingStrategyResponse) String() string

+ func (p *SamplingStrategyResponse) Write(oprot thrift.TProtocol) error

+ type SamplingStrategyType int64

+ const SamplingStrategyType_PROBABILISTIC

+ const SamplingStrategyType_RATE_LIMITING

+ func SamplingStrategyTypeFromString(s string) (SamplingStrategyType, error)

+ func SamplingStrategyTypePtr(v SamplingStrategyType) *SamplingStrategyType

+ func (p *SamplingStrategyType) UnmarshalText(text []byte) error

+ func (p SamplingStrategyType) MarshalText() ([]byte, error)

+ func (p SamplingStrategyType) String() string

+ type Span struct

+ Annotations []*Annotation

+ BinaryAnnotations []*BinaryAnnotation

+ Debug bool

+ Host *Endpoint

+ ID []byte

+ Name string

+ ParentId []byte

+ SpanHost *Endpoint

+ TraceId []byte

+ var TCollectorSubmitArgs_Span_DEFAULT *Span

+ func NewSpan() *Span

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

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

+ func (p *Span) GetDebug() bool

+ func (p *Span) GetHost() *Endpoint

+ func (p *Span) GetID() []byte

+ func (p *Span) GetName() string

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

+ func (p *Span) GetSpanHost() *Endpoint

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

+ func (p *Span) IsSetDebug() bool

+ func (p *Span) IsSetHost() bool

+ func (p *Span) IsSetSpanHost() bool

+ func (p *Span) Read(iprot thrift.TProtocol) error

+ func (p *Span) String() string

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

+ type TChanTCollector interface

+ GetSamplingStrategy func(ctx thrift.Context, serviceName string) (*SamplingStrategyResponse, error)

+ Submit func(ctx thrift.Context, span *Span) (*Response, error)

+ SubmitBatch func(ctx thrift.Context, spans []*Span) ([]*Response, error)

+ func NewTChanTCollectorClient(client thrift.TChanClient) TChanTCollector

+ type TCollector interface

+ GetSamplingStrategy func(serviceName string) (r *SamplingStrategyResponse, err error)

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

+ SubmitBatch func(spans []*Span) (r []*Response, err error)

+ type TCollectorClient struct

+ InputProtocol thrift.TProtocol

+ OutputProtocol thrift.TProtocol

+ ProtocolFactory thrift.TProtocolFactory

+ SeqId int32

+ Transport thrift.TTransport

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

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

+ func (p *TCollectorClient) GetSamplingStrategy(serviceName string) (r *SamplingStrategyResponse, err error)

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

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

+ type TCollectorGetSamplingStrategyArgs struct

+ ServiceName string

+ func NewTCollectorGetSamplingStrategyArgs() *TCollectorGetSamplingStrategyArgs

+ func (p *TCollectorGetSamplingStrategyArgs) GetServiceName() string

+ func (p *TCollectorGetSamplingStrategyArgs) Read(iprot thrift.TProtocol) error

+ func (p *TCollectorGetSamplingStrategyArgs) String() string

+ func (p *TCollectorGetSamplingStrategyArgs) Write(oprot thrift.TProtocol) error

+ type TCollectorGetSamplingStrategyResult struct

+ Success *SamplingStrategyResponse

+ func NewTCollectorGetSamplingStrategyResult() *TCollectorGetSamplingStrategyResult

+ func (p *TCollectorGetSamplingStrategyResult) GetSuccess() *SamplingStrategyResponse

+ func (p *TCollectorGetSamplingStrategyResult) IsSetSuccess() bool

+ func (p *TCollectorGetSamplingStrategyResult) Read(iprot thrift.TProtocol) error

+ func (p *TCollectorGetSamplingStrategyResult) String() string

+ func (p *TCollectorGetSamplingStrategyResult) Write(oprot thrift.TProtocol) error

+ type TCollectorProcessor struct

+ func NewTCollectorProcessor(handler TCollector) *TCollectorProcessor

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

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

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

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

+ type TCollectorSubmitArgs struct

+ Span *Span

+ func NewTCollectorSubmitArgs() *TCollectorSubmitArgs

+ func (p *TCollectorSubmitArgs) GetSpan() *Span

+ func (p *TCollectorSubmitArgs) IsSetSpan() bool

+ func (p *TCollectorSubmitArgs) Read(iprot thrift.TProtocol) error

+ func (p *TCollectorSubmitArgs) String() string

+ func (p *TCollectorSubmitArgs) Write(oprot thrift.TProtocol) error

+ type TCollectorSubmitBatchArgs struct

+ Spans []*Span

+ func NewTCollectorSubmitBatchArgs() *TCollectorSubmitBatchArgs

+ func (p *TCollectorSubmitBatchArgs) GetSpans() []*Span

+ func (p *TCollectorSubmitBatchArgs) Read(iprot thrift.TProtocol) error

+ func (p *TCollectorSubmitBatchArgs) String() string

+ func (p *TCollectorSubmitBatchArgs) Write(oprot thrift.TProtocol) error

+ type TCollectorSubmitBatchResult struct

+ Success []*Response

+ func NewTCollectorSubmitBatchResult() *TCollectorSubmitBatchResult

+ func (p *TCollectorSubmitBatchResult) GetSuccess() []*Response

+ func (p *TCollectorSubmitBatchResult) IsSetSuccess() bool

+ func (p *TCollectorSubmitBatchResult) Read(iprot thrift.TProtocol) error

+ func (p *TCollectorSubmitBatchResult) String() string

+ func (p *TCollectorSubmitBatchResult) Write(oprot thrift.TProtocol) error

+ type TCollectorSubmitResult struct

+ Success *Response

+ func NewTCollectorSubmitResult() *TCollectorSubmitResult

+ func (p *TCollectorSubmitResult) GetSuccess() *Response

+ func (p *TCollectorSubmitResult) IsSetSuccess() bool

+ func (p *TCollectorSubmitResult) Read(iprot thrift.TProtocol) error

+ func (p *TCollectorSubmitResult) String() string

+ func (p *TCollectorSubmitResult) Write(oprot thrift.TProtocol) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL