Versions in this module Expand all Collapse all v1 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