Versions in this module Expand all Collapse all v1 v1.8.1 Nov 23, 2018 v1.8.0 Nov 13, 2018 v1.7.0 Sep 19, 2018 v1.6.0 Jul 10, 2018 v1.5.0 May 28, 2018 v1.4.1 Apr 21, 2018 v1.4.0 Apr 20, 2018 v1.3.0 Mar 27, 2018 v1.2.0 Feb 7, 2018 v1.1.0 Jan 4, 2018 v1.0.0 Dec 6, 2017 Changes in this version + const MESSAGE_ADDR + const MESSAGE_RECV + const MESSAGE_SEND v0 v0.9.0 Oct 25, 2017 v0.8.0 Sep 24, 2017 v0.7.0 Aug 22, 2017 Changes in this version + var Endpoint_Ipv6_DEFAULT []byte + var Span_TraceIDHigh_DEFAULT int64 type Endpoint + Ipv6 []byte + func (p *Endpoint) GetIpv6() []byte + func (p *Endpoint) IsSetIpv6() bool type Span + TraceIDHigh *int64 + func (p *Span) GetTraceIDHigh() int64 + func (p *Span) IsSetTraceIDHigh() bool v0.6.0 Aug 10, 2017 v0.5.2 Jul 20, 2017 v0.5.1 Jul 4, 2017 v0.5.0 Jul 1, 2017 Changes in this version + const CLIENT_ADDR + const CLIENT_RECV + const CLIENT_RECV_FRAGMENT + const CLIENT_SEND + const CLIENT_SEND_FRAGMENT + const LOCAL_COMPONENT + const SERVER_ADDR + const SERVER_RECV + const SERVER_RECV_FRAGMENT + const SERVER_SEND + const SERVER_SEND_FRAGMENT + const WIRE_RECV + const WIRE_SEND + var GoUnusedProtection__ int + var Span_Debug_DEFAULT bool = false + var Span_Duration_DEFAULT int64 + var Span_ParentID_DEFAULT int64 + var Span_Timestamp_DEFAULT int64 + var ZipkinCollectorSubmitZipkinBatchResult_Success_DEFAULT []*Response + func NewTChanZipkinCollectorInheritedClient(thriftService string, client thrift.TChanClient) *tchanZipkinCollectorClient + func NewTChanZipkinCollectorServer(handler TChanZipkinCollector) thrift.TChanServer + type Annotation struct + Host *Endpoint + Timestamp int64 + Value string + func NewAnnotation() *Annotation + func (p *Annotation) GetHost() *Endpoint + func (p *Annotation) GetTimestamp() int64 + func (p *Annotation) GetValue() string + func (p *Annotation) IsSetHost() 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 + Host *Endpoint + Key string + Value []byte + func NewBinaryAnnotation() *BinaryAnnotation + func (p *BinaryAnnotation) GetAnnotationType() AnnotationType + func (p *BinaryAnnotation) GetHost() *Endpoint + func (p *BinaryAnnotation) GetKey() string + func (p *BinaryAnnotation) GetValue() []byte + func (p *BinaryAnnotation) IsSetHost() 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 int16 + ServiceName string + var Annotation_Host_DEFAULT *Endpoint + var BinaryAnnotation_Host_DEFAULT *Endpoint + func NewEndpoint() *Endpoint + func (p *Endpoint) GetIpv4() int32 + func (p *Endpoint) GetPort() int16 + 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 Response struct + Ok bool + 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 Span struct + Annotations []*Annotation + BinaryAnnotations []*BinaryAnnotation + Debug bool + Duration *int64 + ID int64 + Name string + ParentID *int64 + Timestamp *int64 + TraceID int64 + func NewSpan() *Span + func (p *Span) GetAnnotations() []*Annotation + func (p *Span) GetBinaryAnnotations() []*BinaryAnnotation + func (p *Span) GetDebug() bool + func (p *Span) GetDuration() int64 + func (p *Span) GetID() int64 + func (p *Span) GetName() string + func (p *Span) GetParentID() int64 + func (p *Span) GetTimestamp() int64 + func (p *Span) GetTraceID() int64 + func (p *Span) IsSetDebug() bool + func (p *Span) IsSetDuration() bool + func (p *Span) IsSetParentID() bool + func (p *Span) IsSetTimestamp() bool + func (p *Span) Read(iprot thrift.TProtocol) error + func (p *Span) String() string + func (p *Span) Write(oprot thrift.TProtocol) error + type TChanZipkinCollector interface + SubmitZipkinBatch func(ctx thrift.Context, spans []*Span) ([]*Response, error) + func NewTChanZipkinCollectorClient(client thrift.TChanClient) TChanZipkinCollector + type ZipkinCollector interface + SubmitZipkinBatch func(spans []*Span) (r []*Response, err error) + type ZipkinCollectorClient struct + InputProtocol thrift.TProtocol + OutputProtocol thrift.TProtocol + ProtocolFactory thrift.TProtocolFactory + SeqId int32 + Transport thrift.TTransport + func NewZipkinCollectorClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ZipkinCollectorClient + func NewZipkinCollectorClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *ZipkinCollectorClient + func (p *ZipkinCollectorClient) SubmitZipkinBatch(spans []*Span) (r []*Response, err error) + type ZipkinCollectorProcessor struct + func NewZipkinCollectorProcessor(handler ZipkinCollector) *ZipkinCollectorProcessor + func (p *ZipkinCollectorProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *ZipkinCollectorProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *ZipkinCollectorProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *ZipkinCollectorProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type ZipkinCollectorSubmitZipkinBatchArgs struct + Spans []*Span + func NewZipkinCollectorSubmitZipkinBatchArgs() *ZipkinCollectorSubmitZipkinBatchArgs + func (p *ZipkinCollectorSubmitZipkinBatchArgs) GetSpans() []*Span + func (p *ZipkinCollectorSubmitZipkinBatchArgs) Read(iprot thrift.TProtocol) error + func (p *ZipkinCollectorSubmitZipkinBatchArgs) String() string + func (p *ZipkinCollectorSubmitZipkinBatchArgs) Write(oprot thrift.TProtocol) error + type ZipkinCollectorSubmitZipkinBatchResult struct + Success []*Response + func NewZipkinCollectorSubmitZipkinBatchResult() *ZipkinCollectorSubmitZipkinBatchResult + func (p *ZipkinCollectorSubmitZipkinBatchResult) GetSuccess() []*Response + func (p *ZipkinCollectorSubmitZipkinBatchResult) IsSetSuccess() bool + func (p *ZipkinCollectorSubmitZipkinBatchResult) Read(iprot thrift.TProtocol) error + func (p *ZipkinCollectorSubmitZipkinBatchResult) String() string + func (p *ZipkinCollectorSubmitZipkinBatchResult) Write(oprot thrift.TProtocol) error
Go to main page