Versions in this module Expand all Collapse all v1 v1.6.0 Oct 14, 2016 v1.5.1 Sep 27, 2016 v1.5.0 Sep 27, 2016 v1.4.1 Sep 20, 2016 v1.4.0 Sep 14, 2016 v1.3.1 Sep 13, 2016 v1.2.0 Sep 6, 2016 v1.1.0 Sep 2, 2016 v1.0.0 Aug 29, 2016 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 + 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 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 Incompatible versions in this module v2.0.0+incompatible Feb 9, 2017
Go to main page