Versions in this module Expand all Collapse all v0 v0.4.1 Mar 14, 2016 v0.4.0 Mar 14, 2016 v0.3.0 Feb 19, 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