Versions in this module Expand all Collapse all v0 v0.3.0 Feb 12, 2018 v0.2.0 Jan 30, 2018 Changes in this version + var CollectorSubmitBatchesResult_Success_DEFAULT []*BatchSubmitResponse + var GoUnusedProtection__ int + var Process_Tags_DEFAULT []*Tag + var Span_Logs_DEFAULT []*Log + var Span_References_DEFAULT []*SpanRef + var Span_Tags_DEFAULT []*Tag + var Tag_VBinary_DEFAULT []byte + var Tag_VBool_DEFAULT bool + var Tag_VDouble_DEFAULT float64 + var Tag_VLong_DEFAULT int64 + var Tag_VStr_DEFAULT string + type Batch struct + Process *Process + Spans []*Span + func NewBatch() *Batch + func (p *Batch) GetProcess() *Process + func (p *Batch) GetSpans() []*Span + func (p *Batch) IsSetProcess() bool + func (p *Batch) Read(iprot thrift.TProtocol) error + func (p *Batch) ReadField1(iprot thrift.TProtocol) error + func (p *Batch) ReadField2(iprot thrift.TProtocol) error + func (p *Batch) String() string + func (p *Batch) Write(oprot thrift.TProtocol) error + type BatchSubmitResponse struct + Ok bool + func NewBatchSubmitResponse() *BatchSubmitResponse + func (p *BatchSubmitResponse) GetOk() bool + func (p *BatchSubmitResponse) Read(iprot thrift.TProtocol) error + func (p *BatchSubmitResponse) ReadField1(iprot thrift.TProtocol) error + func (p *BatchSubmitResponse) String() string + func (p *BatchSubmitResponse) Write(oprot thrift.TProtocol) error + type Collector interface + SubmitBatches func(ctx context.Context, batches []*Batch) (r []*BatchSubmitResponse, err error) + type CollectorClient struct + func NewCollectorClient(c thrift.TClient) *CollectorClient + func NewCollectorClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *CollectorClient + func NewCollectorClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *CollectorClient + func (p *CollectorClient) SubmitBatches(ctx context.Context, batches []*Batch) (r []*BatchSubmitResponse, err error) + type CollectorProcessor struct + func NewCollectorProcessor(handler Collector) *CollectorProcessor + func (p *CollectorProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *CollectorProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *CollectorProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *CollectorProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type CollectorSubmitBatchesArgs struct + Batches []*Batch + func NewCollectorSubmitBatchesArgs() *CollectorSubmitBatchesArgs + func (p *CollectorSubmitBatchesArgs) GetBatches() []*Batch + func (p *CollectorSubmitBatchesArgs) Read(iprot thrift.TProtocol) error + func (p *CollectorSubmitBatchesArgs) ReadField1(iprot thrift.TProtocol) error + func (p *CollectorSubmitBatchesArgs) String() string + func (p *CollectorSubmitBatchesArgs) Write(oprot thrift.TProtocol) error + type CollectorSubmitBatchesResult struct + Success []*BatchSubmitResponse + func NewCollectorSubmitBatchesResult() *CollectorSubmitBatchesResult + func (p *CollectorSubmitBatchesResult) GetSuccess() []*BatchSubmitResponse + func (p *CollectorSubmitBatchesResult) IsSetSuccess() bool + func (p *CollectorSubmitBatchesResult) Read(iprot thrift.TProtocol) error + func (p *CollectorSubmitBatchesResult) ReadField0(iprot thrift.TProtocol) error + func (p *CollectorSubmitBatchesResult) String() string + func (p *CollectorSubmitBatchesResult) Write(oprot thrift.TProtocol) error + type Log struct + Fields []*Tag + Timestamp int64 + func NewLog() *Log + func (p *Log) GetFields() []*Tag + func (p *Log) GetTimestamp() int64 + func (p *Log) Read(iprot thrift.TProtocol) error + func (p *Log) ReadField1(iprot thrift.TProtocol) error + func (p *Log) ReadField2(iprot thrift.TProtocol) error + func (p *Log) String() string + func (p *Log) Write(oprot thrift.TProtocol) error + type Process struct + ServiceName string + Tags []*Tag + var Batch_Process_DEFAULT *Process + func NewProcess() *Process + func (p *Process) GetServiceName() string + func (p *Process) GetTags() []*Tag + func (p *Process) IsSetTags() bool + func (p *Process) Read(iprot thrift.TProtocol) error + func (p *Process) ReadField1(iprot thrift.TProtocol) error + func (p *Process) ReadField2(iprot thrift.TProtocol) error + func (p *Process) String() string + func (p *Process) Write(oprot thrift.TProtocol) error + type Span struct + Duration int64 + Flags int32 + Logs []*Log + OperationName string + ParentSpanId int64 + References []*SpanRef + SpanId int64 + StartTime int64 + Tags []*Tag + TraceIdHigh int64 + TraceIdLow int64 + func NewSpan() *Span + func (p *Span) GetDuration() int64 + func (p *Span) GetFlags() int32 + func (p *Span) GetLogs() []*Log + func (p *Span) GetOperationName() string + func (p *Span) GetParentSpanId() int64 + func (p *Span) GetReferences() []*SpanRef + func (p *Span) GetSpanId() int64 + func (p *Span) GetStartTime() int64 + func (p *Span) GetTags() []*Tag + func (p *Span) GetTraceIdHigh() int64 + func (p *Span) GetTraceIdLow() int64 + func (p *Span) IsSetLogs() bool + func (p *Span) IsSetReferences() bool + func (p *Span) IsSetTags() bool + func (p *Span) Read(iprot thrift.TProtocol) error + func (p *Span) ReadField1(iprot thrift.TProtocol) error + func (p *Span) ReadField10(iprot thrift.TProtocol) error + func (p *Span) ReadField11(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 + func (p *Span) String() string + func (p *Span) Write(oprot thrift.TProtocol) error + type SpanRef struct + RefType SpanRefType + SpanId int64 + TraceIdHigh int64 + TraceIdLow int64 + func NewSpanRef() *SpanRef + func (p *SpanRef) GetRefType() SpanRefType + func (p *SpanRef) GetSpanId() int64 + func (p *SpanRef) GetTraceIdHigh() int64 + func (p *SpanRef) GetTraceIdLow() int64 + func (p *SpanRef) Read(iprot thrift.TProtocol) error + func (p *SpanRef) ReadField1(iprot thrift.TProtocol) error + func (p *SpanRef) ReadField2(iprot thrift.TProtocol) error + func (p *SpanRef) ReadField3(iprot thrift.TProtocol) error + func (p *SpanRef) ReadField4(iprot thrift.TProtocol) error + func (p *SpanRef) String() string + func (p *SpanRef) Write(oprot thrift.TProtocol) error + type SpanRefType int64 + const SpanRefType_CHILD_OF + const SpanRefType_FOLLOWS_FROM + func SpanRefTypeFromString(s string) (SpanRefType, error) + func SpanRefTypePtr(v SpanRefType) *SpanRefType + func (p *SpanRefType) Scan(value interface{}) error + func (p *SpanRefType) UnmarshalText(text []byte) error + func (p *SpanRefType) Value() (driver.Value, error) + func (p SpanRefType) MarshalText() ([]byte, error) + func (p SpanRefType) String() string + type Tag struct + Key string + VBinary []byte + VBool *bool + VDouble *float64 + VLong *int64 + VStr *string + VType TagType + func NewTag() *Tag + func (p *Tag) GetKey() string + func (p *Tag) GetVBinary() []byte + func (p *Tag) GetVBool() bool + func (p *Tag) GetVDouble() float64 + func (p *Tag) GetVLong() int64 + func (p *Tag) GetVStr() string + func (p *Tag) GetVType() TagType + func (p *Tag) IsSetVBinary() bool + func (p *Tag) IsSetVBool() bool + func (p *Tag) IsSetVDouble() bool + func (p *Tag) IsSetVLong() bool + func (p *Tag) IsSetVStr() bool + func (p *Tag) Read(iprot thrift.TProtocol) error + func (p *Tag) ReadField1(iprot thrift.TProtocol) error + func (p *Tag) ReadField2(iprot thrift.TProtocol) error + func (p *Tag) ReadField3(iprot thrift.TProtocol) error + func (p *Tag) ReadField4(iprot thrift.TProtocol) error + func (p *Tag) ReadField5(iprot thrift.TProtocol) error + func (p *Tag) ReadField6(iprot thrift.TProtocol) error + func (p *Tag) ReadField7(iprot thrift.TProtocol) error + func (p *Tag) String() string + func (p *Tag) Write(oprot thrift.TProtocol) error + type TagType int64 + const TagType_BINARY + const TagType_BOOL + const TagType_DOUBLE + const TagType_LONG + const TagType_STRING + func TagTypeFromString(s string) (TagType, error) + func TagTypePtr(v TagType) *TagType + func (p *TagType) Scan(value interface{}) error + func (p *TagType) UnmarshalText(text []byte) error + func (p *TagType) Value() (driver.Value, error) + func (p TagType) MarshalText() ([]byte, error) + func (p TagType) String() string