Versions in this module Expand all Collapse all v0 v0.5.1 Jul 4, 2017 v0.5.0 Jul 1, 2017 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 + func NewTChanCollectorInheritedClient(thriftService string, client thrift.TChanClient) *tchanCollectorClient + func NewTChanCollectorServer(handler TChanCollector) thrift.TChanServer + type Agent interface + EmitBatch func(batch *Batch) (err error) + type AgentClient struct + InputProtocol thrift.TProtocol + OutputProtocol thrift.TProtocol + ProtocolFactory thrift.TProtocolFactory + SeqId int32 + Transport thrift.TTransport + func NewAgentClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *AgentClient + func NewAgentClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *AgentClient + func (p *AgentClient) EmitBatch(batch *Batch) (err error) + type AgentEmitBatchArgs struct + Batch *Batch + func NewAgentEmitBatchArgs() *AgentEmitBatchArgs + func (p *AgentEmitBatchArgs) GetBatch() *Batch + func (p *AgentEmitBatchArgs) IsSetBatch() bool + func (p *AgentEmitBatchArgs) Read(iprot thrift.TProtocol) error + func (p *AgentEmitBatchArgs) String() string + func (p *AgentEmitBatchArgs) Write(oprot thrift.TProtocol) error + type AgentProcessor struct + func NewAgentProcessor(handler Agent) *AgentProcessor + func (p *AgentProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *AgentProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *AgentProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *AgentProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type Batch struct + Process *Process + Spans []*Span + var AgentEmitBatchArgs_Batch_DEFAULT *Batch + 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) 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) String() string + func (p *BatchSubmitResponse) Write(oprot thrift.TProtocol) error + type Collector interface + SubmitBatches func(batches []*Batch) (r []*BatchSubmitResponse, err error) + type CollectorClient struct + InputProtocol thrift.TProtocol + OutputProtocol thrift.TProtocol + ProtocolFactory thrift.TProtocolFactory + SeqId int32 + Transport thrift.TTransport + 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(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(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) 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) 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) 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) 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) 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) 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) UnmarshalText(text []byte) error + func (p SpanRefType) MarshalText() ([]byte, error) + func (p SpanRefType) String() string + type TChanCollector interface + SubmitBatches func(ctx thrift.Context, batches []*Batch) ([]*BatchSubmitResponse, error) + func NewTChanCollectorClient(client thrift.TChanClient) TChanCollector + 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) 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) UnmarshalText(text []byte) error + func (p TagType) MarshalText() ([]byte, error) + func (p TagType) String() string
Go to main page