zipkinquery

package
v0.0.0-...-1bace3b Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 24, 2015 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GetDataTimeToLiveResult_Success_DEFAULT int32
View Source 
var GetDependenciesResult_Success_DEFAULT *zipkindependencies.Dependencies
View Source 
var GetServiceNamesResult_Success_DEFAULT map[string]bool
View Source 
var GetServiceNamesToTraceIdsResult_Success_DEFAULT map[string][]int64
View Source 
var GetSpanDurationsResult_Success_DEFAULT map[string][]int64
View Source 
var GetSpanNamesResult_Success_DEFAULT map[string]bool
View Source 
var GetTopAnnotationsResult_Success_DEFAULT []string
View Source 
var GetTopKeyValueAnnotationsResult_Success_DEFAULT []string
View Source 
var GetTraceCombosByIdsResult_Success_DEFAULT []*TraceCombo
View Source 
var GetTraceIdsByAnnotationResult_Success_DEFAULT []int64
View Source 
var GetTraceIdsByServiceNameResult_Success_DEFAULT []int64
View Source 
var GetTraceIdsBySpanNameResult_Success_DEFAULT []int64
View Source 
var GetTraceSummariesByIdsResult_Success_DEFAULT []*TraceSummary
View Source 
var GetTraceTimeToLiveResult_Success_DEFAULT int32
View Source 
var GetTraceTimelinesByIdsResult_Success_DEFAULT []*TraceTimeline
View Source 
var GetTracesByIdsResult_Success_DEFAULT []*Trace
View Source 
var GoUnusedProtection__ int
View Source 
var QueryRequest_Annotations_DEFAULT []string
View Source 
var QueryRequest_BinaryAnnotations_DEFAULT []*zipkincore.BinaryAnnotation
View Source 
var QueryRequest_SpanName_DEFAULT string
View Source 
var TimelineAnnotation_Host_DEFAULT *zipkincore.Endpoint
View Source 
var TimelineAnnotation_ParentId_DEFAULT int64
View Source 
var TraceCombo_SpanDepths_DEFAULT map[int64]int32
View Source 
var TracesExistResult_Success_DEFAULT map[int64]bool

Functions

This section is empty.

Types

type Adjust 

type Adjust int64

The raw data in our storage might have various problems. How should we adjust it before returning it to the user?

Time skew adjuster tries to make sure that even though servers might have slightly different clocks the annotations in the returned data are adjusted so that they are in the correct order. 

const (
	Adjust_NOTHING   Adjust = 0
	Adjust_TIME_SKEW Adjust = 1
)

func AdjustFromString 

func AdjustFromString(s string) (Adjust, error)

func AdjustPtr 

func AdjustPtr(v Adjust) *Adjust

func (Adjust) String 

func (p Adjust) String() string

type GetDataTimeToLiveArgs 

type GetDataTimeToLiveArgs struct {
}

func NewGetDataTimeToLiveArgs 

func NewGetDataTimeToLiveArgs() *GetDataTimeToLiveArgs

func (*GetDataTimeToLiveArgs) Read 

func (p *GetDataTimeToLiveArgs) Read(iprot thrift.TProtocol) error

func (*GetDataTimeToLiveArgs) String 

func (p *GetDataTimeToLiveArgs) String() string

func (*GetDataTimeToLiveArgs) Write 

func (p *GetDataTimeToLiveArgs) Write(oprot thrift.TProtocol) error

type GetDataTimeToLiveResult 

type GetDataTimeToLiveResult struct {
	Success *int32          `thrift:"success,0" json:"success"`
	Qe      *QueryException `thrift:"qe,1" json:"qe"`
}

func NewGetDataTimeToLiveResult 

func NewGetDataTimeToLiveResult() *GetDataTimeToLiveResult

func (*GetDataTimeToLiveResult) GetQe 

func (p *GetDataTimeToLiveResult) GetQe() *QueryException

func (*GetDataTimeToLiveResult) GetSuccess 

func (p *GetDataTimeToLiveResult) GetSuccess() int32

func (*GetDataTimeToLiveResult) IsSetQe 

func (p *GetDataTimeToLiveResult) IsSetQe() bool

func (*GetDataTimeToLiveResult) IsSetSuccess 

func (p *GetDataTimeToLiveResult) IsSetSuccess() bool

func (*GetDataTimeToLiveResult) Read 

func (p *GetDataTimeToLiveResult) Read(iprot thrift.TProtocol) error

func (*GetDataTimeToLiveResult) ReadField0 

func (p *GetDataTimeToLiveResult) ReadField0(iprot thrift.TProtocol) error

func (*GetDataTimeToLiveResult) ReadField1 

func (p *GetDataTimeToLiveResult) ReadField1(iprot thrift.TProtocol) error

func (*GetDataTimeToLiveResult) String 

func (p *GetDataTimeToLiveResult) String() string

func (*GetDataTimeToLiveResult) Write 

func (p *GetDataTimeToLiveResult) Write(oprot thrift.TProtocol) error

type GetDependenciesArgs 

type GetDependenciesArgs struct {
	StartTime int64 `thrift:"start_time,1" json:"start_time"`
	EndTime   int64 `thrift:"end_time,2" json:"end_time"`
}

func NewGetDependenciesArgs 

func NewGetDependenciesArgs() *GetDependenciesArgs

func (*GetDependenciesArgs) GetEndTime 

func (p *GetDependenciesArgs) GetEndTime() int64

func (*GetDependenciesArgs) GetStartTime 

func (p *GetDependenciesArgs) GetStartTime() int64

func (*GetDependenciesArgs) Read 

func (p *GetDependenciesArgs) Read(iprot thrift.TProtocol) error

func (*GetDependenciesArgs) ReadField1 

func (p *GetDependenciesArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetDependenciesArgs) ReadField2 

func (p *GetDependenciesArgs) ReadField2(iprot thrift.TProtocol) error

func (*GetDependenciesArgs) String 

func (p *GetDependenciesArgs) String() string

func (*GetDependenciesArgs) Write 

func (p *GetDependenciesArgs) Write(oprot thrift.TProtocol) error

type GetDependenciesResult 

type GetDependenciesResult struct {
	Success *zipkindependencies.Dependencies `thrift:"success,0" json:"success"`
	Qe      *QueryException                  `thrift:"qe,1" json:"qe"`
}

func NewGetDependenciesResult 

func NewGetDependenciesResult() *GetDependenciesResult

func (*GetDependenciesResult) GetQe 

func (p *GetDependenciesResult) GetQe() *QueryException

func (*GetDependenciesResult) GetSuccess 

func (p *GetDependenciesResult) GetSuccess() *zipkindependencies.Dependencies

func (*GetDependenciesResult) IsSetQe 

func (p *GetDependenciesResult) IsSetQe() bool

func (*GetDependenciesResult) IsSetSuccess 

func (p *GetDependenciesResult) IsSetSuccess() bool

func (*GetDependenciesResult) Read 

func (p *GetDependenciesResult) Read(iprot thrift.TProtocol) error

func (*GetDependenciesResult) ReadField0 

func (p *GetDependenciesResult) ReadField0(iprot thrift.TProtocol) error

func (*GetDependenciesResult) ReadField1 

func (p *GetDependenciesResult) ReadField1(iprot thrift.TProtocol) error

func (*GetDependenciesResult) String 

func (p *GetDependenciesResult) String() string

func (*GetDependenciesResult) Write 

func (p *GetDependenciesResult) Write(oprot thrift.TProtocol) error

type GetServiceNamesArgs 

type GetServiceNamesArgs struct {
}

func NewGetServiceNamesArgs 

func NewGetServiceNamesArgs() *GetServiceNamesArgs

func (*GetServiceNamesArgs) Read 

func (p *GetServiceNamesArgs) Read(iprot thrift.TProtocol) error

func (*GetServiceNamesArgs) String 

func (p *GetServiceNamesArgs) String() string

func (*GetServiceNamesArgs) Write 

func (p *GetServiceNamesArgs) Write(oprot thrift.TProtocol) error

type GetServiceNamesResult 

type GetServiceNamesResult struct {
	Success map[string]bool `thrift:"success,0" json:"success"`
	Qe      *QueryException `thrift:"qe,1" json:"qe"`
}

func NewGetServiceNamesResult 

func NewGetServiceNamesResult() *GetServiceNamesResult

func (*GetServiceNamesResult) GetQe 

func (p *GetServiceNamesResult) GetQe() *QueryException

func (*GetServiceNamesResult) GetSuccess 

func (p *GetServiceNamesResult) GetSuccess() map[string]bool

func (*GetServiceNamesResult) IsSetQe 

func (p *GetServiceNamesResult) IsSetQe() bool

func (*GetServiceNamesResult) IsSetSuccess 

func (p *GetServiceNamesResult) IsSetSuccess() bool

func (*GetServiceNamesResult) Read 

func (p *GetServiceNamesResult) Read(iprot thrift.TProtocol) error

func (*GetServiceNamesResult) ReadField0 

func (p *GetServiceNamesResult) ReadField0(iprot thrift.TProtocol) error

func (*GetServiceNamesResult) ReadField1 

func (p *GetServiceNamesResult) ReadField1(iprot thrift.TProtocol) error

func (*GetServiceNamesResult) String 

func (p *GetServiceNamesResult) String() string

func (*GetServiceNamesResult) Write 

func (p *GetServiceNamesResult) Write(oprot thrift.TProtocol) error

type GetServiceNamesToTraceIdsArgs 

type GetServiceNamesToTraceIdsArgs struct {
	TimeStamp   int64  `thrift:"time_stamp,1" json:"time_stamp"`
	ServiceName string `thrift:"service_name,2" json:"service_name"`
	RpcName     string `thrift:"rpc_name,3" json:"rpc_name"`
}

func NewGetServiceNamesToTraceIdsArgs 

func NewGetServiceNamesToTraceIdsArgs() *GetServiceNamesToTraceIdsArgs

func (*GetServiceNamesToTraceIdsArgs) GetRpcName 

func (p *GetServiceNamesToTraceIdsArgs) GetRpcName() string

func (*GetServiceNamesToTraceIdsArgs) GetServiceName 

func (p *GetServiceNamesToTraceIdsArgs) GetServiceName() string

func (*GetServiceNamesToTraceIdsArgs) GetTimeStamp 

func (p *GetServiceNamesToTraceIdsArgs) GetTimeStamp() int64

func (*GetServiceNamesToTraceIdsArgs) Read 

func (p *GetServiceNamesToTraceIdsArgs) Read(iprot thrift.TProtocol) error

func (*GetServiceNamesToTraceIdsArgs) ReadField1 

func (p *GetServiceNamesToTraceIdsArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetServiceNamesToTraceIdsArgs) ReadField2 

func (p *GetServiceNamesToTraceIdsArgs) ReadField2(iprot thrift.TProtocol) error

func (*GetServiceNamesToTraceIdsArgs) ReadField3 

func (p *GetServiceNamesToTraceIdsArgs) ReadField3(iprot thrift.TProtocol) error

func (*GetServiceNamesToTraceIdsArgs) String 

func (p *GetServiceNamesToTraceIdsArgs) String() string

func (*GetServiceNamesToTraceIdsArgs) Write 

func (p *GetServiceNamesToTraceIdsArgs) Write(oprot thrift.TProtocol) error

type GetServiceNamesToTraceIdsResult 

type GetServiceNamesToTraceIdsResult struct {
	Success map[string][]int64 `thrift:"success,0" json:"success"`
}

func NewGetServiceNamesToTraceIdsResult 

func NewGetServiceNamesToTraceIdsResult() *GetServiceNamesToTraceIdsResult

func (*GetServiceNamesToTraceIdsResult) GetSuccess 

func (p *GetServiceNamesToTraceIdsResult) GetSuccess() map[string][]int64

func (*GetServiceNamesToTraceIdsResult) IsSetSuccess 

func (p *GetServiceNamesToTraceIdsResult) IsSetSuccess() bool

func (*GetServiceNamesToTraceIdsResult) Read 

func (p *GetServiceNamesToTraceIdsResult) Read(iprot thrift.TProtocol) error

func (*GetServiceNamesToTraceIdsResult) ReadField0 

func (p *GetServiceNamesToTraceIdsResult) ReadField0(iprot thrift.TProtocol) error

func (*GetServiceNamesToTraceIdsResult) String 

func (p *GetServiceNamesToTraceIdsResult) String() string

func (*GetServiceNamesToTraceIdsResult) Write 

func (p *GetServiceNamesToTraceIdsResult) Write(oprot thrift.TProtocol) error

type GetSpanDurationsArgs 

type GetSpanDurationsArgs struct {
	TimeStamp   int64  `thrift:"time_stamp,1" json:"time_stamp"`
	ServiceName string `thrift:"service_name,2" json:"service_name"`
	RpcName     string `thrift:"rpc_name,3" json:"rpc_name"`
}

func NewGetSpanDurationsArgs 

func NewGetSpanDurationsArgs() *GetSpanDurationsArgs

func (*GetSpanDurationsArgs) GetRpcName 

func (p *GetSpanDurationsArgs) GetRpcName() string

func (*GetSpanDurationsArgs) GetServiceName 

func (p *GetSpanDurationsArgs) GetServiceName() string

func (*GetSpanDurationsArgs) GetTimeStamp 

func (p *GetSpanDurationsArgs) GetTimeStamp() int64

func (*GetSpanDurationsArgs) Read 

func (p *GetSpanDurationsArgs) Read(iprot thrift.TProtocol) error

func (*GetSpanDurationsArgs) ReadField1 

func (p *GetSpanDurationsArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetSpanDurationsArgs) ReadField2 

func (p *GetSpanDurationsArgs) ReadField2(iprot thrift.TProtocol) error

func (*GetSpanDurationsArgs) ReadField3 

func (p *GetSpanDurationsArgs) ReadField3(iprot thrift.TProtocol) error

func (*GetSpanDurationsArgs) String 

func (p *GetSpanDurationsArgs) String() string

func (*GetSpanDurationsArgs) Write 

func (p *GetSpanDurationsArgs) Write(oprot thrift.TProtocol) error

type GetSpanDurationsResult 

type GetSpanDurationsResult struct {
	Success map[string][]int64 `thrift:"success,0" json:"success"`
}

func NewGetSpanDurationsResult 

func NewGetSpanDurationsResult() *GetSpanDurationsResult

func (*GetSpanDurationsResult) GetSuccess 

func (p *GetSpanDurationsResult) GetSuccess() map[string][]int64

func (*GetSpanDurationsResult) IsSetSuccess 

func (p *GetSpanDurationsResult) IsSetSuccess() bool

func (*GetSpanDurationsResult) Read 

func (p *GetSpanDurationsResult) Read(iprot thrift.TProtocol) error

func (*GetSpanDurationsResult) ReadField0 

func (p *GetSpanDurationsResult) ReadField0(iprot thrift.TProtocol) error

func (*GetSpanDurationsResult) String 

func (p *GetSpanDurationsResult) String() string

func (*GetSpanDurationsResult) Write 

func (p *GetSpanDurationsResult) Write(oprot thrift.TProtocol) error

type GetSpanNamesArgs 

type GetSpanNamesArgs struct {
	ServiceName string `thrift:"service_name,1" json:"service_name"`
}

func NewGetSpanNamesArgs 

func NewGetSpanNamesArgs() *GetSpanNamesArgs

func (*GetSpanNamesArgs) GetServiceName 

func (p *GetSpanNamesArgs) GetServiceName() string

func (*GetSpanNamesArgs) Read 

func (p *GetSpanNamesArgs) Read(iprot thrift.TProtocol) error

func (*GetSpanNamesArgs) ReadField1 

func (p *GetSpanNamesArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetSpanNamesArgs) String 

func (p *GetSpanNamesArgs) String() string

func (*GetSpanNamesArgs) Write 

func (p *GetSpanNamesArgs) Write(oprot thrift.TProtocol) error

type GetSpanNamesResult 

type GetSpanNamesResult struct {
	Success map[string]bool `thrift:"success,0" json:"success"`
	Qe      *QueryException `thrift:"qe,1" json:"qe"`
}

func NewGetSpanNamesResult 

func NewGetSpanNamesResult() *GetSpanNamesResult

func (*GetSpanNamesResult) GetQe 

func (p *GetSpanNamesResult) GetQe() *QueryException

func (*GetSpanNamesResult) GetSuccess 

func (p *GetSpanNamesResult) GetSuccess() map[string]bool

func (*GetSpanNamesResult) IsSetQe 

func (p *GetSpanNamesResult) IsSetQe() bool

func (*GetSpanNamesResult) IsSetSuccess 

func (p *GetSpanNamesResult) IsSetSuccess() bool

func (*GetSpanNamesResult) Read 

func (p *GetSpanNamesResult) Read(iprot thrift.TProtocol) error

func (*GetSpanNamesResult) ReadField0 

func (p *GetSpanNamesResult) ReadField0(iprot thrift.TProtocol) error

func (*GetSpanNamesResult) ReadField1 

func (p *GetSpanNamesResult) ReadField1(iprot thrift.TProtocol) error

func (*GetSpanNamesResult) String 

func (p *GetSpanNamesResult) String() string

func (*GetSpanNamesResult) Write 

func (p *GetSpanNamesResult) Write(oprot thrift.TProtocol) error

type GetTopAnnotationsArgs 

type GetTopAnnotationsArgs struct {
	ServiceName string `thrift:"service_name,1" json:"service_name"`
}

func NewGetTopAnnotationsArgs 

func NewGetTopAnnotationsArgs() *GetTopAnnotationsArgs

func (*GetTopAnnotationsArgs) GetServiceName 

func (p *GetTopAnnotationsArgs) GetServiceName() string

func (*GetTopAnnotationsArgs) Read 

func (p *GetTopAnnotationsArgs) Read(iprot thrift.TProtocol) error

func (*GetTopAnnotationsArgs) ReadField1 

func (p *GetTopAnnotationsArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetTopAnnotationsArgs) String 

func (p *GetTopAnnotationsArgs) String() string

func (*GetTopAnnotationsArgs) Write 

func (p *GetTopAnnotationsArgs) Write(oprot thrift.TProtocol) error

type GetTopAnnotationsResult 

type GetTopAnnotationsResult struct {
	Success []string        `thrift:"success,0" json:"success"`
	Qe      *QueryException `thrift:"qe,1" json:"qe"`
}

func NewGetTopAnnotationsResult 

func NewGetTopAnnotationsResult() *GetTopAnnotationsResult

func (*GetTopAnnotationsResult) GetQe 

func (p *GetTopAnnotationsResult) GetQe() *QueryException

func (*GetTopAnnotationsResult) GetSuccess 

func (p *GetTopAnnotationsResult) GetSuccess() []string

func (*GetTopAnnotationsResult) IsSetQe 

func (p *GetTopAnnotationsResult) IsSetQe() bool

func (*GetTopAnnotationsResult) IsSetSuccess 

func (p *GetTopAnnotationsResult) IsSetSuccess() bool

func (*GetTopAnnotationsResult) Read 

func (p *GetTopAnnotationsResult) Read(iprot thrift.TProtocol) error

func (*GetTopAnnotationsResult) ReadField0 

func (p *GetTopAnnotationsResult) ReadField0(iprot thrift.TProtocol) error

func (*GetTopAnnotationsResult) ReadField1 

func (p *GetTopAnnotationsResult) ReadField1(iprot thrift.TProtocol) error

func (*GetTopAnnotationsResult) String 

func (p *GetTopAnnotationsResult) String() string

func (*GetTopAnnotationsResult) Write 

func (p *GetTopAnnotationsResult) Write(oprot thrift.TProtocol) error

type GetTopKeyValueAnnotationsArgs 

type GetTopKeyValueAnnotationsArgs struct {
	ServiceName string `thrift:"service_name,1" json:"service_name"`
}

func NewGetTopKeyValueAnnotationsArgs 

func NewGetTopKeyValueAnnotationsArgs() *GetTopKeyValueAnnotationsArgs

func (*GetTopKeyValueAnnotationsArgs) GetServiceName 

func (p *GetTopKeyValueAnnotationsArgs) GetServiceName() string

func (*GetTopKeyValueAnnotationsArgs) Read 

func (p *GetTopKeyValueAnnotationsArgs) Read(iprot thrift.TProtocol) error

func (*GetTopKeyValueAnnotationsArgs) ReadField1 

func (p *GetTopKeyValueAnnotationsArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetTopKeyValueAnnotationsArgs) String 

func (p *GetTopKeyValueAnnotationsArgs) String() string

func (*GetTopKeyValueAnnotationsArgs) Write 

func (p *GetTopKeyValueAnnotationsArgs) Write(oprot thrift.TProtocol) error

type GetTopKeyValueAnnotationsResult 

type GetTopKeyValueAnnotationsResult struct {
	Success []string        `thrift:"success,0" json:"success"`
	Qe      *QueryException `thrift:"qe,1" json:"qe"`
}

func NewGetTopKeyValueAnnotationsResult 

func NewGetTopKeyValueAnnotationsResult() *GetTopKeyValueAnnotationsResult

func (*GetTopKeyValueAnnotationsResult) GetQe 

func (p *GetTopKeyValueAnnotationsResult) GetQe() *QueryException

func (*GetTopKeyValueAnnotationsResult) GetSuccess 

func (p *GetTopKeyValueAnnotationsResult) GetSuccess() []string

func (*GetTopKeyValueAnnotationsResult) IsSetQe 

func (p *GetTopKeyValueAnnotationsResult) IsSetQe() bool

func (*GetTopKeyValueAnnotationsResult) IsSetSuccess 

func (p *GetTopKeyValueAnnotationsResult) IsSetSuccess() bool

func (*GetTopKeyValueAnnotationsResult) Read 

func (p *GetTopKeyValueAnnotationsResult) Read(iprot thrift.TProtocol) error

func (*GetTopKeyValueAnnotationsResult) ReadField0 

func (p *GetTopKeyValueAnnotationsResult) ReadField0(iprot thrift.TProtocol) error

func (*GetTopKeyValueAnnotationsResult) ReadField1 

func (p *GetTopKeyValueAnnotationsResult) ReadField1(iprot thrift.TProtocol) error

func (*GetTopKeyValueAnnotationsResult) String 

func (p *GetTopKeyValueAnnotationsResult) String() string

func (*GetTopKeyValueAnnotationsResult) Write 

func (p *GetTopKeyValueAnnotationsResult) Write(oprot thrift.TProtocol) error

type GetTraceCombosByIdsArgs 

type GetTraceCombosByIdsArgs struct {
	TraceIds []int64  `thrift:"trace_ids,1" json:"trace_ids"`
	Adjust   []Adjust `thrift:"adjust,2" json:"adjust"`
}

func NewGetTraceCombosByIdsArgs 

func NewGetTraceCombosByIdsArgs() *GetTraceCombosByIdsArgs

func (*GetTraceCombosByIdsArgs) GetAdjust 

func (p *GetTraceCombosByIdsArgs) GetAdjust() []Adjust

func (*GetTraceCombosByIdsArgs) GetTraceIds 

func (p *GetTraceCombosByIdsArgs) GetTraceIds() []int64

func (*GetTraceCombosByIdsArgs) Read 

func (p *GetTraceCombosByIdsArgs) Read(iprot thrift.TProtocol) error

func (*GetTraceCombosByIdsArgs) ReadField1 

func (p *GetTraceCombosByIdsArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetTraceCombosByIdsArgs) ReadField2 

func (p *GetTraceCombosByIdsArgs) ReadField2(iprot thrift.TProtocol) error

func (*GetTraceCombosByIdsArgs) String 

func (p *GetTraceCombosByIdsArgs) String() string

func (*GetTraceCombosByIdsArgs) Write 

func (p *GetTraceCombosByIdsArgs) Write(oprot thrift.TProtocol) error

type GetTraceCombosByIdsResult 

type GetTraceCombosByIdsResult struct {
	Success []*TraceCombo   `thrift:"success,0" json:"success"`
	Qe      *QueryException `thrift:"qe,1" json:"qe"`
}

func NewGetTraceCombosByIdsResult 

func NewGetTraceCombosByIdsResult() *GetTraceCombosByIdsResult

func (*GetTraceCombosByIdsResult) GetQe 

func (p *GetTraceCombosByIdsResult) GetQe() *QueryException

func (*GetTraceCombosByIdsResult) GetSuccess 

func (p *GetTraceCombosByIdsResult) GetSuccess() []*TraceCombo

func (*GetTraceCombosByIdsResult) IsSetQe 

func (p *GetTraceCombosByIdsResult) IsSetQe() bool

func (*GetTraceCombosByIdsResult) IsSetSuccess 

func (p *GetTraceCombosByIdsResult) IsSetSuccess() bool

func (*GetTraceCombosByIdsResult) Read 

func (p *GetTraceCombosByIdsResult) Read(iprot thrift.TProtocol) error

func (*GetTraceCombosByIdsResult) ReadField0 

func (p *GetTraceCombosByIdsResult) ReadField0(iprot thrift.TProtocol) error

func (*GetTraceCombosByIdsResult) ReadField1 

func (p *GetTraceCombosByIdsResult) ReadField1(iprot thrift.TProtocol) error

func (*GetTraceCombosByIdsResult) String 

func (p *GetTraceCombosByIdsResult) String() string

func (*GetTraceCombosByIdsResult) Write 

func (p *GetTraceCombosByIdsResult) Write(oprot thrift.TProtocol) error

type GetTraceIdsArgs 

type GetTraceIdsArgs struct {
	Request *QueryRequest `thrift:"request,1" json:"request"`
}

func NewGetTraceIdsArgs 

func NewGetTraceIdsArgs() *GetTraceIdsArgs

func (*GetTraceIdsArgs) GetRequest 

func (p *GetTraceIdsArgs) GetRequest() *QueryRequest

func (*GetTraceIdsArgs) IsSetRequest 

func (p *GetTraceIdsArgs) IsSetRequest() bool

func (*GetTraceIdsArgs) Read 

func (p *GetTraceIdsArgs) Read(iprot thrift.TProtocol) error

func (*GetTraceIdsArgs) ReadField1 

func (p *GetTraceIdsArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetTraceIdsArgs) String 

func (p *GetTraceIdsArgs) String() string

func (*GetTraceIdsArgs) Write 

func (p *GetTraceIdsArgs) Write(oprot thrift.TProtocol) error

type GetTraceIdsByAnnotationArgs 

type GetTraceIdsByAnnotationArgs struct {
	ServiceName string `thrift:"service_name,1" json:"service_name"`
	Annotation  string `thrift:"annotation,2" json:"annotation"`
	Value       []byte `thrift:"value,3" json:"value"`
	// unused field # 4
	EndTs int64 `thrift:"end_ts,5" json:"end_ts"`
	Limit int32 `thrift:"limit,6" json:"limit"`
	Order Order `thrift:"order,7" json:"order"`
}

func NewGetTraceIdsByAnnotationArgs 

func NewGetTraceIdsByAnnotationArgs() *GetTraceIdsByAnnotationArgs

func (*GetTraceIdsByAnnotationArgs) GetAnnotation 

func (p *GetTraceIdsByAnnotationArgs) GetAnnotation() string

func (*GetTraceIdsByAnnotationArgs) GetEndTs 

func (p *GetTraceIdsByAnnotationArgs) GetEndTs() int64

func (*GetTraceIdsByAnnotationArgs) GetLimit 

func (p *GetTraceIdsByAnnotationArgs) GetLimit() int32

func (*GetTraceIdsByAnnotationArgs) GetOrder 

func (p *GetTraceIdsByAnnotationArgs) GetOrder() Order

func (*GetTraceIdsByAnnotationArgs) GetServiceName 

func (p *GetTraceIdsByAnnotationArgs) GetServiceName() string

func (*GetTraceIdsByAnnotationArgs) GetValue 

func (p *GetTraceIdsByAnnotationArgs) GetValue() []byte

func (*GetTraceIdsByAnnotationArgs) Read 

func (p *GetTraceIdsByAnnotationArgs) Read(iprot thrift.TProtocol) error

func (*GetTraceIdsByAnnotationArgs) ReadField1 

func (p *GetTraceIdsByAnnotationArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetTraceIdsByAnnotationArgs) ReadField2 

func (p *GetTraceIdsByAnnotationArgs) ReadField2(iprot thrift.TProtocol) error

func (*GetTraceIdsByAnnotationArgs) ReadField3 

func (p *GetTraceIdsByAnnotationArgs) ReadField3(iprot thrift.TProtocol) error

func (*GetTraceIdsByAnnotationArgs) ReadField5 

func (p *GetTraceIdsByAnnotationArgs) ReadField5(iprot thrift.TProtocol) error

func (*GetTraceIdsByAnnotationArgs) ReadField6 

func (p *GetTraceIdsByAnnotationArgs) ReadField6(iprot thrift.TProtocol) error

func (*GetTraceIdsByAnnotationArgs) ReadField7 

func (p *GetTraceIdsByAnnotationArgs) ReadField7(iprot thrift.TProtocol) error

func (*GetTraceIdsByAnnotationArgs) String 

func (p *GetTraceIdsByAnnotationArgs) String() string

func (*GetTraceIdsByAnnotationArgs) Write 

func (p *GetTraceIdsByAnnotationArgs) Write(oprot thrift.TProtocol) error

type GetTraceIdsByAnnotationResult 

type GetTraceIdsByAnnotationResult struct {
	Success []int64         `thrift:"success,0" json:"success"`
	Qe      *QueryException `thrift:"qe,1" json:"qe"`
}

func NewGetTraceIdsByAnnotationResult 

func NewGetTraceIdsByAnnotationResult() *GetTraceIdsByAnnotationResult

func (*GetTraceIdsByAnnotationResult) GetQe 

func (p *GetTraceIdsByAnnotationResult) GetQe() *QueryException

func (*GetTraceIdsByAnnotationResult) GetSuccess 

func (p *GetTraceIdsByAnnotationResult) GetSuccess() []int64

func (*GetTraceIdsByAnnotationResult) IsSetQe 

func (p *GetTraceIdsByAnnotationResult) IsSetQe() bool

func (*GetTraceIdsByAnnotationResult) IsSetSuccess 

func (p *GetTraceIdsByAnnotationResult) IsSetSuccess() bool

func (*GetTraceIdsByAnnotationResult) Read 

func (p *GetTraceIdsByAnnotationResult) Read(iprot thrift.TProtocol) error

func (*GetTraceIdsByAnnotationResult) ReadField0 

func (p *GetTraceIdsByAnnotationResult) ReadField0(iprot thrift.TProtocol) error

func (*GetTraceIdsByAnnotationResult) ReadField1 

func (p *GetTraceIdsByAnnotationResult) ReadField1(iprot thrift.TProtocol) error

func (*GetTraceIdsByAnnotationResult) String 

func (p *GetTraceIdsByAnnotationResult) String() string

func (*GetTraceIdsByAnnotationResult) Write 

func (p *GetTraceIdsByAnnotationResult) Write(oprot thrift.TProtocol) error

type GetTraceIdsByServiceNameArgs 

type GetTraceIdsByServiceNameArgs struct {
	ServiceName string `thrift:"service_name,1" json:"service_name"`
	// unused field # 2
	EndTs int64 `thrift:"end_ts,3" json:"end_ts"`
	Limit int32 `thrift:"limit,4" json:"limit"`
	Order Order `thrift:"order,5" json:"order"`
}

func NewGetTraceIdsByServiceNameArgs 

func NewGetTraceIdsByServiceNameArgs() *GetTraceIdsByServiceNameArgs

func (*GetTraceIdsByServiceNameArgs) GetEndTs 

func (p *GetTraceIdsByServiceNameArgs) GetEndTs() int64

func (*GetTraceIdsByServiceNameArgs) GetLimit 

func (p *GetTraceIdsByServiceNameArgs) GetLimit() int32

func (*GetTraceIdsByServiceNameArgs) GetOrder 

func (p *GetTraceIdsByServiceNameArgs) GetOrder() Order

func (*GetTraceIdsByServiceNameArgs) GetServiceName 

func (p *GetTraceIdsByServiceNameArgs) GetServiceName() string

func (*GetTraceIdsByServiceNameArgs) Read 

func (p *GetTraceIdsByServiceNameArgs) Read(iprot thrift.TProtocol) error

func (*GetTraceIdsByServiceNameArgs) ReadField1 

func (p *GetTraceIdsByServiceNameArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetTraceIdsByServiceNameArgs) ReadField3 

func (p *GetTraceIdsByServiceNameArgs) ReadField3(iprot thrift.TProtocol) error

func (*GetTraceIdsByServiceNameArgs) ReadField4 

func (p *GetTraceIdsByServiceNameArgs) ReadField4(iprot thrift.TProtocol) error

func (*GetTraceIdsByServiceNameArgs) ReadField5 

func (p *GetTraceIdsByServiceNameArgs) ReadField5(iprot thrift.TProtocol) error

func (*GetTraceIdsByServiceNameArgs) String 

func (p *GetTraceIdsByServiceNameArgs) String() string

func (*GetTraceIdsByServiceNameArgs) Write 

func (p *GetTraceIdsByServiceNameArgs) Write(oprot thrift.TProtocol) error

type GetTraceIdsByServiceNameResult 

type GetTraceIdsByServiceNameResult struct {
	Success []int64         `thrift:"success,0" json:"success"`
	Qe      *QueryException `thrift:"qe,1" json:"qe"`
}

func NewGetTraceIdsByServiceNameResult 

func NewGetTraceIdsByServiceNameResult() *GetTraceIdsByServiceNameResult

func (*GetTraceIdsByServiceNameResult) GetQe 

func (p *GetTraceIdsByServiceNameResult) GetQe() *QueryException

func (*GetTraceIdsByServiceNameResult) GetSuccess 

func (p *GetTraceIdsByServiceNameResult) GetSuccess() []int64

func (*GetTraceIdsByServiceNameResult) IsSetQe 

func (p *GetTraceIdsByServiceNameResult) IsSetQe() bool

func (*GetTraceIdsByServiceNameResult) IsSetSuccess 

func (p *GetTraceIdsByServiceNameResult) IsSetSuccess() bool

func (*GetTraceIdsByServiceNameResult) Read 

func (p *GetTraceIdsByServiceNameResult) Read(iprot thrift.TProtocol) error

func (*GetTraceIdsByServiceNameResult) ReadField0 

func (p *GetTraceIdsByServiceNameResult) ReadField0(iprot thrift.TProtocol) error

func (*GetTraceIdsByServiceNameResult) ReadField1 

func (p *GetTraceIdsByServiceNameResult) ReadField1(iprot thrift.TProtocol) error

func (*GetTraceIdsByServiceNameResult) String 

func (p *GetTraceIdsByServiceNameResult) String() string

func (*GetTraceIdsByServiceNameResult) Write 

func (p *GetTraceIdsByServiceNameResult) Write(oprot thrift.TProtocol) error

type GetTraceIdsBySpanNameArgs 

type GetTraceIdsBySpanNameArgs struct {
	ServiceName string `thrift:"service_name,1" json:"service_name"`
	SpanName    string `thrift:"span_name,2" json:"span_name"`
	// unused field # 3
	EndTs int64 `thrift:"end_ts,4" json:"end_ts"`
	Limit int32 `thrift:"limit,5" json:"limit"`
	Order Order `thrift:"order,6" json:"order"`
}

func NewGetTraceIdsBySpanNameArgs 

func NewGetTraceIdsBySpanNameArgs() *GetTraceIdsBySpanNameArgs

func (*GetTraceIdsBySpanNameArgs) GetEndTs 

func (p *GetTraceIdsBySpanNameArgs) GetEndTs() int64

func (*GetTraceIdsBySpanNameArgs) GetLimit 

func (p *GetTraceIdsBySpanNameArgs) GetLimit() int32

func (*GetTraceIdsBySpanNameArgs) GetOrder 

func (p *GetTraceIdsBySpanNameArgs) GetOrder() Order

func (*GetTraceIdsBySpanNameArgs) GetServiceName 

func (p *GetTraceIdsBySpanNameArgs) GetServiceName() string

func (*GetTraceIdsBySpanNameArgs) GetSpanName 

func (p *GetTraceIdsBySpanNameArgs) GetSpanName() string

func (*GetTraceIdsBySpanNameArgs) Read 

func (p *GetTraceIdsBySpanNameArgs) Read(iprot thrift.TProtocol) error

func (*GetTraceIdsBySpanNameArgs) ReadField1 

func (p *GetTraceIdsBySpanNameArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetTraceIdsBySpanNameArgs) ReadField2 

func (p *GetTraceIdsBySpanNameArgs) ReadField2(iprot thrift.TProtocol) error

func (*GetTraceIdsBySpanNameArgs) ReadField4 

func (p *GetTraceIdsBySpanNameArgs) ReadField4(iprot thrift.TProtocol) error

func (*GetTraceIdsBySpanNameArgs) ReadField5 

func (p *GetTraceIdsBySpanNameArgs) ReadField5(iprot thrift.TProtocol) error

func (*GetTraceIdsBySpanNameArgs) ReadField6 

func (p *GetTraceIdsBySpanNameArgs) ReadField6(iprot thrift.TProtocol) error

func (*GetTraceIdsBySpanNameArgs) String 

func (p *GetTraceIdsBySpanNameArgs) String() string

func (*GetTraceIdsBySpanNameArgs) Write 

func (p *GetTraceIdsBySpanNameArgs) Write(oprot thrift.TProtocol) error

type GetTraceIdsBySpanNameResult 

type GetTraceIdsBySpanNameResult struct {
	Success []int64         `thrift:"success,0" json:"success"`
	Qe      *QueryException `thrift:"qe,1" json:"qe"`
}

func NewGetTraceIdsBySpanNameResult 

func NewGetTraceIdsBySpanNameResult() *GetTraceIdsBySpanNameResult

func (*GetTraceIdsBySpanNameResult) GetQe 

func (p *GetTraceIdsBySpanNameResult) GetQe() *QueryException

func (*GetTraceIdsBySpanNameResult) GetSuccess 

func (p *GetTraceIdsBySpanNameResult) GetSuccess() []int64

func (*GetTraceIdsBySpanNameResult) IsSetQe 

func (p *GetTraceIdsBySpanNameResult) IsSetQe() bool

func (*GetTraceIdsBySpanNameResult) IsSetSuccess 

func (p *GetTraceIdsBySpanNameResult) IsSetSuccess() bool

func (*GetTraceIdsBySpanNameResult) Read 

func (p *GetTraceIdsBySpanNameResult) Read(iprot thrift.TProtocol) error

func (*GetTraceIdsBySpanNameResult) ReadField0 

func (p *GetTraceIdsBySpanNameResult) ReadField0(iprot thrift.TProtocol) error

func (*GetTraceIdsBySpanNameResult) ReadField1 

func (p *GetTraceIdsBySpanNameResult) ReadField1(iprot thrift.TProtocol) error

func (*GetTraceIdsBySpanNameResult) String 

func (p *GetTraceIdsBySpanNameResult) String() string

func (*GetTraceIdsBySpanNameResult) Write 

func (p *GetTraceIdsBySpanNameResult) Write(oprot thrift.TProtocol) error

type GetTraceIdsResult 

type GetTraceIdsResult struct {
	Success *QueryResponse  `thrift:"success,0" json:"success"`
	Qe      *QueryException `thrift:"qe,1" json:"qe"`
}

func NewGetTraceIdsResult 

func NewGetTraceIdsResult() *GetTraceIdsResult

func (*GetTraceIdsResult) GetQe 

func (p *GetTraceIdsResult) GetQe() *QueryException

func (*GetTraceIdsResult) GetSuccess 

func (p *GetTraceIdsResult) GetSuccess() *QueryResponse

func (*GetTraceIdsResult) IsSetQe 

func (p *GetTraceIdsResult) IsSetQe() bool

func (*GetTraceIdsResult) IsSetSuccess 

func (p *GetTraceIdsResult) IsSetSuccess() bool

func (*GetTraceIdsResult) Read 

func (p *GetTraceIdsResult) Read(iprot thrift.TProtocol) error

func (*GetTraceIdsResult) ReadField0 

func (p *GetTraceIdsResult) ReadField0(iprot thrift.TProtocol) error

func (*GetTraceIdsResult) ReadField1 

func (p *GetTraceIdsResult) ReadField1(iprot thrift.TProtocol) error

func (*GetTraceIdsResult) String 

func (p *GetTraceIdsResult) String() string

func (*GetTraceIdsResult) Write 

func (p *GetTraceIdsResult) Write(oprot thrift.TProtocol) error

type GetTraceSummariesByIdsArgs 

type GetTraceSummariesByIdsArgs struct {
	TraceIds []int64  `thrift:"trace_ids,1" json:"trace_ids"`
	Adjust   []Adjust `thrift:"adjust,2" json:"adjust"`
}

func NewGetTraceSummariesByIdsArgs 

func NewGetTraceSummariesByIdsArgs() *GetTraceSummariesByIdsArgs

func (*GetTraceSummariesByIdsArgs) GetAdjust 

func (p *GetTraceSummariesByIdsArgs) GetAdjust() []Adjust

func (*GetTraceSummariesByIdsArgs) GetTraceIds 

func (p *GetTraceSummariesByIdsArgs) GetTraceIds() []int64

func (*GetTraceSummariesByIdsArgs) Read 

func (p *GetTraceSummariesByIdsArgs) Read(iprot thrift.TProtocol) error

func (*GetTraceSummariesByIdsArgs) ReadField1 

func (p *GetTraceSummariesByIdsArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetTraceSummariesByIdsArgs) ReadField2 

func (p *GetTraceSummariesByIdsArgs) ReadField2(iprot thrift.TProtocol) error

func (*GetTraceSummariesByIdsArgs) String 

func (p *GetTraceSummariesByIdsArgs) String() string

func (*GetTraceSummariesByIdsArgs) Write 

func (p *GetTraceSummariesByIdsArgs) Write(oprot thrift.TProtocol) error

type GetTraceSummariesByIdsResult 

type GetTraceSummariesByIdsResult struct {
	Success []*TraceSummary `thrift:"success,0" json:"success"`
	Qe      *QueryException `thrift:"qe,1" json:"qe"`
}

func NewGetTraceSummariesByIdsResult 

func NewGetTraceSummariesByIdsResult() *GetTraceSummariesByIdsResult

func (*GetTraceSummariesByIdsResult) GetQe 

func (p *GetTraceSummariesByIdsResult) GetQe() *QueryException

func (*GetTraceSummariesByIdsResult) GetSuccess 

func (p *GetTraceSummariesByIdsResult) GetSuccess() []*TraceSummary

func (*GetTraceSummariesByIdsResult) IsSetQe 

func (p *GetTraceSummariesByIdsResult) IsSetQe() bool

func (*GetTraceSummariesByIdsResult) IsSetSuccess 

func (p *GetTraceSummariesByIdsResult) IsSetSuccess() bool

func (*GetTraceSummariesByIdsResult) Read 

func (p *GetTraceSummariesByIdsResult) Read(iprot thrift.TProtocol) error

func (*GetTraceSummariesByIdsResult) ReadField0 

func (p *GetTraceSummariesByIdsResult) ReadField0(iprot thrift.TProtocol) error

func (*GetTraceSummariesByIdsResult) ReadField1 

func (p *GetTraceSummariesByIdsResult) ReadField1(iprot thrift.TProtocol) error

func (*GetTraceSummariesByIdsResult) String 

func (p *GetTraceSummariesByIdsResult) String() string

func (*GetTraceSummariesByIdsResult) Write 

func (p *GetTraceSummariesByIdsResult) Write(oprot thrift.TProtocol) error

type GetTraceTimeToLiveArgs 

type GetTraceTimeToLiveArgs struct {
	TraceId int64 `thrift:"trace_id,1" json:"trace_id"`
}

func NewGetTraceTimeToLiveArgs 

func NewGetTraceTimeToLiveArgs() *GetTraceTimeToLiveArgs

func (*GetTraceTimeToLiveArgs) GetTraceId 

func (p *GetTraceTimeToLiveArgs) GetTraceId() int64

func (*GetTraceTimeToLiveArgs) Read 

func (p *GetTraceTimeToLiveArgs) Read(iprot thrift.TProtocol) error

func (*GetTraceTimeToLiveArgs) ReadField1 

func (p *GetTraceTimeToLiveArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetTraceTimeToLiveArgs) String 

func (p *GetTraceTimeToLiveArgs) String() string

func (*GetTraceTimeToLiveArgs) Write 

func (p *GetTraceTimeToLiveArgs) Write(oprot thrift.TProtocol) error

type GetTraceTimeToLiveResult 

type GetTraceTimeToLiveResult struct {
	Success *int32          `thrift:"success,0" json:"success"`
	Qe      *QueryException `thrift:"qe,1" json:"qe"`
}

func NewGetTraceTimeToLiveResult 

func NewGetTraceTimeToLiveResult() *GetTraceTimeToLiveResult

func (*GetTraceTimeToLiveResult) GetQe 

func (p *GetTraceTimeToLiveResult) GetQe() *QueryException

func (*GetTraceTimeToLiveResult) GetSuccess 

func (p *GetTraceTimeToLiveResult) GetSuccess() int32

func (*GetTraceTimeToLiveResult) IsSetQe 

func (p *GetTraceTimeToLiveResult) IsSetQe() bool

func (*GetTraceTimeToLiveResult) IsSetSuccess 

func (p *GetTraceTimeToLiveResult) IsSetSuccess() bool

func (*GetTraceTimeToLiveResult) Read 

func (p *GetTraceTimeToLiveResult) Read(iprot thrift.TProtocol) error

func (*GetTraceTimeToLiveResult) ReadField0 

func (p *GetTraceTimeToLiveResult) ReadField0(iprot thrift.TProtocol) error

func (*GetTraceTimeToLiveResult) ReadField1 

func (p *GetTraceTimeToLiveResult) ReadField1(iprot thrift.TProtocol) error

func (*GetTraceTimeToLiveResult) String 

func (p *GetTraceTimeToLiveResult) String() string

func (*GetTraceTimeToLiveResult) Write 

func (p *GetTraceTimeToLiveResult) Write(oprot thrift.TProtocol) error

type GetTraceTimelinesByIdsArgs 

type GetTraceTimelinesByIdsArgs struct {
	TraceIds []int64  `thrift:"trace_ids,1" json:"trace_ids"`
	Adjust   []Adjust `thrift:"adjust,2" json:"adjust"`
}

func NewGetTraceTimelinesByIdsArgs 

func NewGetTraceTimelinesByIdsArgs() *GetTraceTimelinesByIdsArgs

func (*GetTraceTimelinesByIdsArgs) GetAdjust 

func (p *GetTraceTimelinesByIdsArgs) GetAdjust() []Adjust

func (*GetTraceTimelinesByIdsArgs) GetTraceIds 

func (p *GetTraceTimelinesByIdsArgs) GetTraceIds() []int64

func (*GetTraceTimelinesByIdsArgs) Read 

func (p *GetTraceTimelinesByIdsArgs) Read(iprot thrift.TProtocol) error

func (*GetTraceTimelinesByIdsArgs) ReadField1 

func (p *GetTraceTimelinesByIdsArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetTraceTimelinesByIdsArgs) ReadField2 

func (p *GetTraceTimelinesByIdsArgs) ReadField2(iprot thrift.TProtocol) error

func (*GetTraceTimelinesByIdsArgs) String 

func (p *GetTraceTimelinesByIdsArgs) String() string

func (*GetTraceTimelinesByIdsArgs) Write 

func (p *GetTraceTimelinesByIdsArgs) Write(oprot thrift.TProtocol) error

type GetTraceTimelinesByIdsResult 

type GetTraceTimelinesByIdsResult struct {
	Success []*TraceTimeline `thrift:"success,0" json:"success"`
	Qe      *QueryException  `thrift:"qe,1" json:"qe"`
}

func NewGetTraceTimelinesByIdsResult 

func NewGetTraceTimelinesByIdsResult() *GetTraceTimelinesByIdsResult

func (*GetTraceTimelinesByIdsResult) GetQe 

func (p *GetTraceTimelinesByIdsResult) GetQe() *QueryException

func (*GetTraceTimelinesByIdsResult) GetSuccess 

func (p *GetTraceTimelinesByIdsResult) GetSuccess() []*TraceTimeline

func (*GetTraceTimelinesByIdsResult) IsSetQe 

func (p *GetTraceTimelinesByIdsResult) IsSetQe() bool

func (*GetTraceTimelinesByIdsResult) IsSetSuccess 

func (p *GetTraceTimelinesByIdsResult) IsSetSuccess() bool

func (*GetTraceTimelinesByIdsResult) Read 

func (p *GetTraceTimelinesByIdsResult) Read(iprot thrift.TProtocol) error

func (*GetTraceTimelinesByIdsResult) ReadField0 

func (p *GetTraceTimelinesByIdsResult) ReadField0(iprot thrift.TProtocol) error

func (*GetTraceTimelinesByIdsResult) ReadField1 

func (p *GetTraceTimelinesByIdsResult) ReadField1(iprot thrift.TProtocol) error

func (*GetTraceTimelinesByIdsResult) String 

func (p *GetTraceTimelinesByIdsResult) String() string

func (*GetTraceTimelinesByIdsResult) Write 

func (p *GetTraceTimelinesByIdsResult) Write(oprot thrift.TProtocol) error

type GetTracesByIdsArgs 

type GetTracesByIdsArgs struct {
	TraceIds []int64  `thrift:"trace_ids,1" json:"trace_ids"`
	Adjust   []Adjust `thrift:"adjust,2" json:"adjust"`
}

func NewGetTracesByIdsArgs 

func NewGetTracesByIdsArgs() *GetTracesByIdsArgs

func (*GetTracesByIdsArgs) GetAdjust 

func (p *GetTracesByIdsArgs) GetAdjust() []Adjust

func (*GetTracesByIdsArgs) GetTraceIds 

func (p *GetTracesByIdsArgs) GetTraceIds() []int64

func (*GetTracesByIdsArgs) Read 

func (p *GetTracesByIdsArgs) Read(iprot thrift.TProtocol) error

func (*GetTracesByIdsArgs) ReadField1 

func (p *GetTracesByIdsArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetTracesByIdsArgs) ReadField2 

func (p *GetTracesByIdsArgs) ReadField2(iprot thrift.TProtocol) error

func (*GetTracesByIdsArgs) String 

func (p *GetTracesByIdsArgs) String() string

func (*GetTracesByIdsArgs) Write 

func (p *GetTracesByIdsArgs) Write(oprot thrift.TProtocol) error

type GetTracesByIdsResult 

type GetTracesByIdsResult struct {
	Success []*Trace        `thrift:"success,0" json:"success"`
	Qe      *QueryException `thrift:"qe,1" json:"qe"`
}

func NewGetTracesByIdsResult 

func NewGetTracesByIdsResult() *GetTracesByIdsResult

func (*GetTracesByIdsResult) GetQe 

func (p *GetTracesByIdsResult) GetQe() *QueryException

func (*GetTracesByIdsResult) GetSuccess 

func (p *GetTracesByIdsResult) GetSuccess() []*Trace

func (*GetTracesByIdsResult) IsSetQe 

func (p *GetTracesByIdsResult) IsSetQe() bool

func (*GetTracesByIdsResult) IsSetSuccess 

func (p *GetTracesByIdsResult) IsSetSuccess() bool

func (*GetTracesByIdsResult) Read 

func (p *GetTracesByIdsResult) Read(iprot thrift.TProtocol) error

func (*GetTracesByIdsResult) ReadField0 

func (p *GetTracesByIdsResult) ReadField0(iprot thrift.TProtocol) error

func (*GetTracesByIdsResult) ReadField1 

func (p *GetTracesByIdsResult) ReadField1(iprot thrift.TProtocol) error

func (*GetTracesByIdsResult) String 

func (p *GetTracesByIdsResult) String() string

func (*GetTracesByIdsResult) Write 

func (p *GetTracesByIdsResult) Write(oprot thrift.TProtocol) error

type Order 

type Order int64
const (
	Order_TIMESTAMP_DESC Order = 0
	Order_TIMESTAMP_ASC  Order = 1
	Order_DURATION_ASC   Order = 2
	Order_DURATION_DESC  Order = 3
	Order_NONE           Order = 4
)

func OrderFromString 

func OrderFromString(s string) (Order, error)

func OrderPtr 

func OrderPtr(v Order) *Order

func (Order) String 

func (p Order) String() string

type QueryException 

type QueryException struct {
	Msg string `thrift:"msg,1" json:"msg"`
}
var GetDataTimeToLiveResult_Qe_DEFAULT *QueryException
var GetDependenciesResult_Qe_DEFAULT *QueryException
var GetServiceNamesResult_Qe_DEFAULT *QueryException
var GetSpanNamesResult_Qe_DEFAULT *QueryException
var GetTopAnnotationsResult_Qe_DEFAULT *QueryException
var GetTopKeyValueAnnotationsResult_Qe_DEFAULT *QueryException
var GetTraceCombosByIdsResult_Qe_DEFAULT *QueryException
var GetTraceIdsByAnnotationResult_Qe_DEFAULT *QueryException
var GetTraceIdsByServiceNameResult_Qe_DEFAULT *QueryException
var GetTraceIdsBySpanNameResult_Qe_DEFAULT *QueryException
var GetTraceIdsResult_Qe_DEFAULT *QueryException
var GetTraceSummariesByIdsResult_Qe_DEFAULT *QueryException
var GetTraceTimeToLiveResult_Qe_DEFAULT *QueryException
var GetTraceTimelinesByIdsResult_Qe_DEFAULT *QueryException
var GetTracesByIdsResult_Qe_DEFAULT *QueryException
var SetTraceTimeToLiveResult_Qe_DEFAULT *QueryException
var TracesExistResult_Qe_DEFAULT *QueryException

func NewQueryException 

func NewQueryException() *QueryException

func (*QueryException) Error 

func (p *QueryException) Error() string

func (*QueryException) GetMsg 

func (p *QueryException) GetMsg() string

func (*QueryException) Read 

func (p *QueryException) Read(iprot thrift.TProtocol) error

func (*QueryException) ReadField1 

func (p *QueryException) ReadField1(iprot thrift.TProtocol) error

func (*QueryException) String 

func (p *QueryException) String() string

func (*QueryException) Write 

func (p *QueryException) Write(oprot thrift.TProtocol) error

type QueryRequest 

type QueryRequest struct {
	ServiceName       string                         `thrift:"service_name,1" json:"service_name"`
	SpanName          *string                        `thrift:"span_name,2" json:"span_name"`
	Annotations       []string                       `thrift:"annotations,3" json:"annotations"`
	BinaryAnnotations []*zipkincore.BinaryAnnotation `thrift:"binary_annotations,4" json:"binary_annotations"`
	EndTs             int64                          `thrift:"end_ts,5" json:"end_ts"`
	Limit             int32                          `thrift:"limit,6" json:"limit"`
	Order             Order                          `thrift:"order,7" json:"order"`
}
var GetTraceIdsArgs_Request_DEFAULT *QueryRequest

func NewQueryRequest 

func NewQueryRequest() *QueryRequest

func (*QueryRequest) GetAnnotations 

func (p *QueryRequest) GetAnnotations() []string

func (*QueryRequest) GetBinaryAnnotations 

func (p *QueryRequest) GetBinaryAnnotations() []*zipkincore.BinaryAnnotation

func (*QueryRequest) GetEndTs 

func (p *QueryRequest) GetEndTs() int64

func (*QueryRequest) GetLimit 

func (p *QueryRequest) GetLimit() int32

func (*QueryRequest) GetOrder 

func (p *QueryRequest) GetOrder() Order

func (*QueryRequest) GetServiceName 

func (p *QueryRequest) GetServiceName() string

func (*QueryRequest) GetSpanName 

func (p *QueryRequest) GetSpanName() string

func (*QueryRequest) IsSetAnnotations 

func (p *QueryRequest) IsSetAnnotations() bool

func (*QueryRequest) IsSetBinaryAnnotations 

func (p *QueryRequest) IsSetBinaryAnnotations() bool

func (*QueryRequest) IsSetSpanName 

func (p *QueryRequest) IsSetSpanName() bool

func (*QueryRequest) Read 

func (p *QueryRequest) Read(iprot thrift.TProtocol) error

func (*QueryRequest) ReadField1 

func (p *QueryRequest) ReadField1(iprot thrift.TProtocol) error

func (*QueryRequest) ReadField2 

func (p *QueryRequest) ReadField2(iprot thrift.TProtocol) error

func (*QueryRequest) ReadField3 

func (p *QueryRequest) ReadField3(iprot thrift.TProtocol) error

func (*QueryRequest) ReadField4 

func (p *QueryRequest) ReadField4(iprot thrift.TProtocol) error

func (*QueryRequest) ReadField5 

func (p *QueryRequest) ReadField5(iprot thrift.TProtocol) error

func (*QueryRequest) ReadField6 

func (p *QueryRequest) ReadField6(iprot thrift.TProtocol) error

func (*QueryRequest) ReadField7 

func (p *QueryRequest) ReadField7(iprot thrift.TProtocol) error

func (*QueryRequest) String 

func (p *QueryRequest) String() string

func (*QueryRequest) Write 

func (p *QueryRequest) Write(oprot thrift.TProtocol) error

type QueryResponse 

type QueryResponse struct {
	TraceIds []int64 `thrift:"trace_ids,1" json:"trace_ids"`
	StartTs  int64   `thrift:"start_ts,2" json:"start_ts"`
	EndTs    int64   `thrift:"end_ts,3" json:"end_ts"`
}
var GetTraceIdsResult_Success_DEFAULT *QueryResponse

func NewQueryResponse 

func NewQueryResponse() *QueryResponse

func (*QueryResponse) GetEndTs 

func (p *QueryResponse) GetEndTs() int64

func (*QueryResponse) GetStartTs 

func (p *QueryResponse) GetStartTs() int64

func (*QueryResponse) GetTraceIds 

func (p *QueryResponse) GetTraceIds() []int64

func (*QueryResponse) Read 

func (p *QueryResponse) Read(iprot thrift.TProtocol) error

func (*QueryResponse) ReadField1 

func (p *QueryResponse) ReadField1(iprot thrift.TProtocol) error

func (*QueryResponse) ReadField2 

func (p *QueryResponse) ReadField2(iprot thrift.TProtocol) error

func (*QueryResponse) ReadField3 

func (p *QueryResponse) ReadField3(iprot thrift.TProtocol) error

func (*QueryResponse) String 

func (p *QueryResponse) String() string

func (*QueryResponse) Write 

func (p *QueryResponse) Write(oprot thrift.TProtocol) error

type SetTraceTimeToLiveArgs 

type SetTraceTimeToLiveArgs struct {
	TraceId    int64 `thrift:"trace_id,1" json:"trace_id"`
	TtlSeconds int32 `thrift:"ttl_seconds,2" json:"ttl_seconds"`
}

func NewSetTraceTimeToLiveArgs 

func NewSetTraceTimeToLiveArgs() *SetTraceTimeToLiveArgs

func (*SetTraceTimeToLiveArgs) GetTraceId 

func (p *SetTraceTimeToLiveArgs) GetTraceId() int64

func (*SetTraceTimeToLiveArgs) GetTtlSeconds 

func (p *SetTraceTimeToLiveArgs) GetTtlSeconds() int32

func (*SetTraceTimeToLiveArgs) Read 

func (p *SetTraceTimeToLiveArgs) Read(iprot thrift.TProtocol) error

func (*SetTraceTimeToLiveArgs) ReadField1 

func (p *SetTraceTimeToLiveArgs) ReadField1(iprot thrift.TProtocol) error

func (*SetTraceTimeToLiveArgs) ReadField2 

func (p *SetTraceTimeToLiveArgs) ReadField2(iprot thrift.TProtocol) error

func (*SetTraceTimeToLiveArgs) String 

func (p *SetTraceTimeToLiveArgs) String() string

func (*SetTraceTimeToLiveArgs) Write 

func (p *SetTraceTimeToLiveArgs) Write(oprot thrift.TProtocol) error

type SetTraceTimeToLiveResult 

type SetTraceTimeToLiveResult struct {
	Qe *QueryException `thrift:"qe,1" json:"qe"`
}

func NewSetTraceTimeToLiveResult 

func NewSetTraceTimeToLiveResult() *SetTraceTimeToLiveResult

func (*SetTraceTimeToLiveResult) GetQe 

func (p *SetTraceTimeToLiveResult) GetQe() *QueryException

func (*SetTraceTimeToLiveResult) IsSetQe 

func (p *SetTraceTimeToLiveResult) IsSetQe() bool

func (*SetTraceTimeToLiveResult) Read 

func (p *SetTraceTimeToLiveResult) Read(iprot thrift.TProtocol) error

func (*SetTraceTimeToLiveResult) ReadField1 

func (p *SetTraceTimeToLiveResult) ReadField1(iprot thrift.TProtocol) error

func (*SetTraceTimeToLiveResult) String 

func (p *SetTraceTimeToLiveResult) String() string

func (*SetTraceTimeToLiveResult) Write 

func (p *SetTraceTimeToLiveResult) Write(oprot thrift.TProtocol) error

type SpanTimestamp 

type SpanTimestamp struct {
	Name           string `thrift:"name,1" json:"name"`
	StartTimestamp int64  `thrift:"start_timestamp,2" json:"start_timestamp"`
	EndTimestamp   int64  `thrift:"end_timestamp,3" json:"end_timestamp"`
}

func NewSpanTimestamp 

func NewSpanTimestamp() *SpanTimestamp

func (*SpanTimestamp) GetEndTimestamp 

func (p *SpanTimestamp) GetEndTimestamp() int64

func (*SpanTimestamp) GetName 

func (p *SpanTimestamp) GetName() string

func (*SpanTimestamp) GetStartTimestamp 

func (p *SpanTimestamp) GetStartTimestamp() int64

func (*SpanTimestamp) Read 

func (p *SpanTimestamp) Read(iprot thrift.TProtocol) error

func (*SpanTimestamp) ReadField1 

func (p *SpanTimestamp) ReadField1(iprot thrift.TProtocol) error

func (*SpanTimestamp) ReadField2 

func (p *SpanTimestamp) ReadField2(iprot thrift.TProtocol) error

func (*SpanTimestamp) ReadField3 

func (p *SpanTimestamp) ReadField3(iprot thrift.TProtocol) error

func (*SpanTimestamp) String 

func (p *SpanTimestamp) String() string

func (*SpanTimestamp) Write 

func (p *SpanTimestamp) Write(oprot thrift.TProtocol) error

type TimelineAnnotation 

type TimelineAnnotation struct {
	Timestamp   int64                `thrift:"timestamp,1" json:"timestamp"`
	Value       string               `thrift:"value,2" json:"value"`
	Host        *zipkincore.Endpoint `thrift:"host,3" json:"host"`
	SpanId      int64                `thrift:"span_id,4" json:"span_id"`
	ParentId    *int64               `thrift:"parent_id,5" json:"parent_id"`
	ServiceName string               `thrift:"service_name,6" json:"service_name"`
	SpanName    string               `thrift:"span_name,7" json:"span_name"`
}

func NewTimelineAnnotation 

func NewTimelineAnnotation() *TimelineAnnotation

func (*TimelineAnnotation) GetHost 

func (p *TimelineAnnotation) GetHost() *zipkincore.Endpoint

func (*TimelineAnnotation) GetParentId 

func (p *TimelineAnnotation) GetParentId() int64

func (*TimelineAnnotation) GetServiceName 

func (p *TimelineAnnotation) GetServiceName() string

func (*TimelineAnnotation) GetSpanId 

func (p *TimelineAnnotation) GetSpanId() int64

func (*TimelineAnnotation) GetSpanName 

func (p *TimelineAnnotation) GetSpanName() string

func (*TimelineAnnotation) GetTimestamp 

func (p *TimelineAnnotation) GetTimestamp() int64

func (*TimelineAnnotation) GetValue 

func (p *TimelineAnnotation) GetValue() string

func (*TimelineAnnotation) IsSetHost 

func (p *TimelineAnnotation) IsSetHost() bool

func (*TimelineAnnotation) IsSetParentId 

func (p *TimelineAnnotation) IsSetParentId() bool

func (*TimelineAnnotation) Read 

func (p *TimelineAnnotation) Read(iprot thrift.TProtocol) error

func (*TimelineAnnotation) ReadField1 

func (p *TimelineAnnotation) ReadField1(iprot thrift.TProtocol) error

func (*TimelineAnnotation) ReadField2 

func (p *TimelineAnnotation) ReadField2(iprot thrift.TProtocol) error

func (*TimelineAnnotation) ReadField3 

func (p *TimelineAnnotation) ReadField3(iprot thrift.TProtocol) error

func (*TimelineAnnotation) ReadField4 

func (p *TimelineAnnotation) ReadField4(iprot thrift.TProtocol) error

func (*TimelineAnnotation) ReadField5 

func (p *TimelineAnnotation) ReadField5(iprot thrift.TProtocol) error

func (*TimelineAnnotation) ReadField6 

func (p *TimelineAnnotation) ReadField6(iprot thrift.TProtocol) error

func (*TimelineAnnotation) ReadField7 

func (p *TimelineAnnotation) ReadField7(iprot thrift.TProtocol) error

func (*TimelineAnnotation) String 

func (p *TimelineAnnotation) String() string

func (*TimelineAnnotation) Write 

func (p *TimelineAnnotation) Write(oprot thrift.TProtocol) error

type Trace 

type Trace struct {
	Spans []*zipkincore.Span `thrift:"spans,1" json:"spans"`
}
var TraceCombo_Trace_DEFAULT *Trace

func NewTrace 

func NewTrace() *Trace

func (*Trace) GetSpans 

func (p *Trace) GetSpans() []*zipkincore.Span

func (*Trace) Read 

func (p *Trace) Read(iprot thrift.TProtocol) error

func (*Trace) ReadField1 

func (p *Trace) ReadField1(iprot thrift.TProtocol) error

func (*Trace) String 

func (p *Trace) String() string

func (*Trace) Write 

func (p *Trace) Write(oprot thrift.TProtocol) error

type TraceCombo 

type TraceCombo struct {
	Trace      *Trace          `thrift:"trace,1" json:"trace"`
	Summary    *TraceSummary   `thrift:"summary,2" json:"summary"`
	Timeline   *TraceTimeline  `thrift:"timeline,3" json:"timeline"`
	SpanDepths map[int64]int32 `thrift:"span_depths,4" json:"span_depths"`
}

func NewTraceCombo 

func NewTraceCombo() *TraceCombo

func (*TraceCombo) GetSpanDepths 

func (p *TraceCombo) GetSpanDepths() map[int64]int32

func (*TraceCombo) GetSummary 

func (p *TraceCombo) GetSummary() *TraceSummary

func (*TraceCombo) GetTimeline 

func (p *TraceCombo) GetTimeline() *TraceTimeline

func (*TraceCombo) GetTrace 

func (p *TraceCombo) GetTrace() *Trace

func (*TraceCombo) IsSetSpanDepths 

func (p *TraceCombo) IsSetSpanDepths() bool

func (*TraceCombo) IsSetSummary 

func (p *TraceCombo) IsSetSummary() bool

func (*TraceCombo) IsSetTimeline 

func (p *TraceCombo) IsSetTimeline() bool

func (*TraceCombo) IsSetTrace 

func (p *TraceCombo) IsSetTrace() bool

func (*TraceCombo) Read 

func (p *TraceCombo) Read(iprot thrift.TProtocol) error

func (*TraceCombo) ReadField1 

func (p *TraceCombo) ReadField1(iprot thrift.TProtocol) error

func (*TraceCombo) ReadField2 

func (p *TraceCombo) ReadField2(iprot thrift.TProtocol) error

func (*TraceCombo) ReadField3 

func (p *TraceCombo) ReadField3(iprot thrift.TProtocol) error

func (*TraceCombo) ReadField4 

func (p *TraceCombo) ReadField4(iprot thrift.TProtocol) error

func (*TraceCombo) String 

func (p *TraceCombo) String() string

func (*TraceCombo) Write 

func (p *TraceCombo) Write(oprot thrift.TProtocol) error

type TraceSummary 

type TraceSummary struct {
	TraceId        int64 `thrift:"trace_id,1" json:"trace_id"`
	StartTimestamp int64 `thrift:"start_timestamp,2" json:"start_timestamp"`
	EndTimestamp   int64 `thrift:"end_timestamp,3" json:"end_timestamp"`
	DurationMicro  int32 `thrift:"duration_micro,4" json:"duration_micro"`
	// unused field # 5
	Endpoints      []*zipkincore.Endpoint `thrift:"endpoints,6" json:"endpoints"`
	SpanTimestamps []*SpanTimestamp       `thrift:"span_timestamps,7" json:"span_timestamps"`
}
var TraceCombo_Summary_DEFAULT *TraceSummary

func NewTraceSummary 

func NewTraceSummary() *TraceSummary

func (*TraceSummary) GetDurationMicro 

func (p *TraceSummary) GetDurationMicro() int32

func (*TraceSummary) GetEndTimestamp 

func (p *TraceSummary) GetEndTimestamp() int64

func (*TraceSummary) GetEndpoints 

func (p *TraceSummary) GetEndpoints() []*zipkincore.Endpoint

func (*TraceSummary) GetSpanTimestamps 

func (p *TraceSummary) GetSpanTimestamps() []*SpanTimestamp

func (*TraceSummary) GetStartTimestamp 

func (p *TraceSummary) GetStartTimestamp() int64

func (*TraceSummary) GetTraceId 

func (p *TraceSummary) GetTraceId() int64

func (*TraceSummary) Read 

func (p *TraceSummary) Read(iprot thrift.TProtocol) error

func (*TraceSummary) ReadField1 

func (p *TraceSummary) ReadField1(iprot thrift.TProtocol) error

func (*TraceSummary) ReadField2 

func (p *TraceSummary) ReadField2(iprot thrift.TProtocol) error

func (*TraceSummary) ReadField3 

func (p *TraceSummary) ReadField3(iprot thrift.TProtocol) error

func (*TraceSummary) ReadField4 

func (p *TraceSummary) ReadField4(iprot thrift.TProtocol) error

func (*TraceSummary) ReadField6 

func (p *TraceSummary) ReadField6(iprot thrift.TProtocol) error

func (*TraceSummary) ReadField7 

func (p *TraceSummary) ReadField7(iprot thrift.TProtocol) error

func (*TraceSummary) String 

func (p *TraceSummary) String() string

func (*TraceSummary) Write 

func (p *TraceSummary) Write(oprot thrift.TProtocol) error

type TraceTimeline 

type TraceTimeline struct {
	TraceId        int64 `thrift:"trace_id,1" json:"trace_id"`
	RootMostSpanId int64 `thrift:"root_most_span_id,2" json:"root_most_span_id"`
	// unused fields # 3 to 5
	Annotations       []*TimelineAnnotation          `thrift:"annotations,6" json:"annotations"`
	BinaryAnnotations []*zipkincore.BinaryAnnotation `thrift:"binary_annotations,7" json:"binary_annotations"`
}
var TraceCombo_Timeline_DEFAULT *TraceTimeline

func NewTraceTimeline 

func NewTraceTimeline() *TraceTimeline

func (*TraceTimeline) GetAnnotations 

func (p *TraceTimeline) GetAnnotations() []*TimelineAnnotation

func (*TraceTimeline) GetBinaryAnnotations 

func (p *TraceTimeline) GetBinaryAnnotations() []*zipkincore.BinaryAnnotation

func (*TraceTimeline) GetRootMostSpanId 

func (p *TraceTimeline) GetRootMostSpanId() int64

func (*TraceTimeline) GetTraceId 

func (p *TraceTimeline) GetTraceId() int64

func (*TraceTimeline) Read 

func (p *TraceTimeline) Read(iprot thrift.TProtocol) error

func (*TraceTimeline) ReadField1 

func (p *TraceTimeline) ReadField1(iprot thrift.TProtocol) error

func (*TraceTimeline) ReadField2 

func (p *TraceTimeline) ReadField2(iprot thrift.TProtocol) error

func (*TraceTimeline) ReadField6 

func (p *TraceTimeline) ReadField6(iprot thrift.TProtocol) error

func (*TraceTimeline) ReadField7 

func (p *TraceTimeline) ReadField7(iprot thrift.TProtocol) error

func (*TraceTimeline) String 

func (p *TraceTimeline) String() string

func (*TraceTimeline) Write 

func (p *TraceTimeline) Write(oprot thrift.TProtocol) error

type TracesExistArgs 

type TracesExistArgs struct {
	TraceIds []int64 `thrift:"trace_ids,1" json:"trace_ids"`
}

func NewTracesExistArgs 

func NewTracesExistArgs() *TracesExistArgs

func (*TracesExistArgs) GetTraceIds 

func (p *TracesExistArgs) GetTraceIds() []int64

func (*TracesExistArgs) Read 

func (p *TracesExistArgs) Read(iprot thrift.TProtocol) error

func (*TracesExistArgs) ReadField1 

func (p *TracesExistArgs) ReadField1(iprot thrift.TProtocol) error

func (*TracesExistArgs) String 

func (p *TracesExistArgs) String() string

func (*TracesExistArgs) Write 

func (p *TracesExistArgs) Write(oprot thrift.TProtocol) error

type TracesExistResult 

type TracesExistResult struct {
	Success map[int64]bool  `thrift:"success,0" json:"success"`
	Qe      *QueryException `thrift:"qe,1" json:"qe"`
}

func NewTracesExistResult 

func NewTracesExistResult() *TracesExistResult

func (*TracesExistResult) GetQe 

func (p *TracesExistResult) GetQe() *QueryException

func (*TracesExistResult) GetSuccess 

func (p *TracesExistResult) GetSuccess() map[int64]bool

func (*TracesExistResult) IsSetQe 

func (p *TracesExistResult) IsSetQe() bool

func (*TracesExistResult) IsSetSuccess 

func (p *TracesExistResult) IsSetSuccess() bool

func (*TracesExistResult) Read 

func (p *TracesExistResult) Read(iprot thrift.TProtocol) error

func (*TracesExistResult) ReadField0 

func (p *TracesExistResult) ReadField0(iprot thrift.TProtocol) error

func (*TracesExistResult) ReadField1 

func (p *TracesExistResult) ReadField1(iprot thrift.TProtocol) error

func (*TracesExistResult) String 

func (p *TracesExistResult) String() string

func (*TracesExistResult) Write 

func (p *TracesExistResult) Write(oprot thrift.TProtocol) error

type ZipkinQuery 

type ZipkinQuery interface {
	// Parameters:
	//  - Request
	GetTraceIds(request *QueryRequest) (r *QueryResponse, err error)
	// Fetch trace ids by service and span name.
	// Gets "limit" number of entries from before the "end_ts".
	//
	// Span name is optional.
	// Timestamps are in microseconds.
	//
	// Parameters:
	//  - ServiceName
	//  - SpanName
	//  - EndTs
	//  - Limit
	//  - Order
	GetTraceIdsBySpanName(service_name string, span_name string, end_ts int64, limit int32, order Order) (r []int64, err error)
	// Fetch trace ids by service name.
	// Gets "limit" number of entries from before the "end_ts".
	//
	// Timestamps are in microseconds.
	//
	// Parameters:
	//  - ServiceName
	//  - EndTs
	//  - Limit
	//  - Order
	GetTraceIdsByServiceName(service_name string, end_ts int64, limit int32, order Order) (r []int64, err error)
	// Fetch trace ids with a particular annotation.
	// Gets "limit" number of entries from before the "end_ts".
	//
	// When requesting based on time based annotations only pass in the first parameter, "annotation" and leave out
	// the second "value". If looking for a key-value binary annotation provide both, "annotation" is then the
	// key in the key-value.
	//
	// Timestamps are in microseconds.
	//
	// Parameters:
	//  - ServiceName
	//  - Annotation
	//  - Value
	//  - EndTs
	//  - Limit
	//  - Order
	GetTraceIdsByAnnotation(service_name string, annotation string, value []byte, end_ts int64, limit int32, order Order) (r []int64, err error)
	// Get the traces that are in the database from the given list of trace ids.
	//
	// Parameters:
	//  - TraceIds
	TracesExist(trace_ids []int64) (r map[int64]bool, err error)
	// Get the full traces associated with the given trace ids.
	//
	// Second argument is a list of methods of adjusting the trace
	// data before returning it. Can be empty.
	//
	// Parameters:
	//  - TraceIds
	//  - Adjust
	GetTracesByIds(trace_ids []int64, adjust []Adjust) (r []*Trace, err error)
	// Get the trace timelines associated with the given trace ids.
	// This is a convenience method for users that just want to know
	// the annotations and the (assumed) order they happened in.
	//
	// Second argument is a list of methods of adjusting the trace
	// data before returning it. Can be empty.
	//
	// Note that if one of the trace ids does not have any data associated with it, it will not be
	// represented in the output list.
	//
	// Parameters:
	//  - TraceIds
	//  - Adjust
	GetTraceTimelinesByIds(trace_ids []int64, adjust []Adjust) (r []*TraceTimeline, err error)
	// Fetch trace summaries for the given trace ids.
	//
	// Second argument is a list of methods of adjusting the trace
	// data before returning it. Can be empty.
	//
	// Note that if one of the trace ids does not have any data associated with it, it will not be
	// represented in the output list.
	//
	// Parameters:
	//  - TraceIds
	//  - Adjust
	GetTraceSummariesByIds(trace_ids []int64, adjust []Adjust) (r []*TraceSummary, err error)
	// Not content with just one of traces, summaries or timelines? Want it all? This is the method for you.
	//
	// Parameters:
	//  - TraceIds
	//  - Adjust
	GetTraceCombosByIds(trace_ids []int64, adjust []Adjust) (r []*TraceCombo, err error)
	// Fetch all the service names we have seen from now all the way back to the set ttl.
	GetServiceNames() (r map[string]bool, err error)
	// Get all the seen span names for a particular service, from now back until the set ttl.
	//
	// Parameters:
	//  - ServiceName
	GetSpanNames(service_name string) (r map[string]bool, err error)
	// Change the TTL of a trace. If we find an interesting trace we want to keep around for further
	// investigation.
	//
	// Parameters:
	//  - TraceId
	//  - TtlSeconds
	SetTraceTimeToLive(trace_id int64, ttl_seconds int32) (err error)
	// Get the TTL in seconds of a specific trace.
	//
	// Parameters:
	//  - TraceId
	GetTraceTimeToLive(trace_id int64) (r int32, err error)
	// Get the data ttl. This is the number of seconds we keep the data around before deleting it.
	GetDataTimeToLive() (r int32, err error)
	// Get an aggregate representation of all services paired with every service they call in to.
	// This includes information on call counts and mean/stdDev/etc of call durations.  The two arguments
	// specify epoch time in microseconds. The end time is optional and defaults to one day after the
	// start time.
	//
	// Parameters:
	//  - StartTime
	//  - EndTime
	GetDependencies(start_time int64, end_time int64) (r *zipkindependencies.Dependencies, err error)
	// Parameters:
	//  - ServiceName
	GetTopAnnotations(service_name string) (r []string, err error)
	// Parameters:
	//  - ServiceName
	GetTopKeyValueAnnotations(service_name string) (r []string, err error)
	// Given a time stamp, server service name, and rpc name, fetch all of the client services calling in paired
	// with the lists of every span duration (list<i64>) from the server to client. The lists of span durations
	// include information on call counts and mean/stdDev/etc of call durations.
	//
	// The three arguments specify epoch time in microseconds, server side service name and rpc name. The return maps
	// contains the key - client_service_name and value - list<span_durations>.
	//
	// Parameters:
	//  - TimeStamp
	//  - ServiceName
	//  - RpcName
	GetSpanDurations(time_stamp int64, service_name string, rpc_name string) (r map[string][]int64, err error)
	// Given a time stamp, server service name, and rpc name, fetch all of the client services calling in paired
	// with the lists of every trace Ids (list<i64>) from the server to client.
	//
	// The three arguments specify epoch time in microseconds, server side service name and rpc name. The return maps
	// contains the key - client_service_name and value - list<trace_id>.
	//
	// Parameters:
	//  - TimeStamp
	//  - ServiceName
	//  - RpcName
	GetServiceNamesToTraceIds(time_stamp int64, service_name string, rpc_name string) (r map[string][]int64, err error)
}

type ZipkinQueryClient 

type ZipkinQueryClient struct {
	Transport       thrift.TTransport
	ProtocolFactory thrift.TProtocolFactory
	InputProtocol   thrift.TProtocol
	OutputProtocol  thrift.TProtocol
	SeqId           int32
}

func NewZipkinQueryClientFactory 

func NewZipkinQueryClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ZipkinQueryClient

func NewZipkinQueryClientProtocol 

func NewZipkinQueryClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *ZipkinQueryClient

func (*ZipkinQueryClient) GetDataTimeToLive 

func (p *ZipkinQueryClient) GetDataTimeToLive() (r int32, err error)

Get the data ttl. This is the number of seconds we keep the data around before deleting it.

func (*ZipkinQueryClient) GetDependencies 

func (p *ZipkinQueryClient) GetDependencies(start_time int64, end_time int64) (r *zipkindependencies.Dependencies, err error)

Get an aggregate representation of all services paired with every service they call in to. This includes information on call counts and mean/stdDev/etc of call durations. The two arguments specify epoch time in microseconds. The end time is optional and defaults to one day after the start time.

Parameters:

  • StartTime
  • EndTime

func (*ZipkinQueryClient) GetServiceNames 

func (p *ZipkinQueryClient) GetServiceNames() (r map[string]bool, err error)

Fetch all the service names we have seen from now all the way back to the set ttl.

func (*ZipkinQueryClient) GetServiceNamesToTraceIds 

func (p *ZipkinQueryClient) GetServiceNamesToTraceIds(time_stamp int64, service_name string, rpc_name string) (r map[string][]int64, err error)

Given a time stamp, server service name, and rpc name, fetch all of the client services calling in paired with the lists of every trace Ids (list<i64>) from the server to client.

The three arguments specify epoch time in microseconds, server side service name and rpc name. The return maps contains the key - client_service_name and value - list<trace_id>.

Parameters:

  • TimeStamp
  • ServiceName
  • RpcName

func (*ZipkinQueryClient) GetSpanDurations 

func (p *ZipkinQueryClient) GetSpanDurations(time_stamp int64, service_name string, rpc_name string) (r map[string][]int64, err error)

Given a time stamp, server service name, and rpc name, fetch all of the client services calling in paired with the lists of every span duration (list<i64>) from the server to client. The lists of span durations include information on call counts and mean/stdDev/etc of call durations.

The three arguments specify epoch time in microseconds, server side service name and rpc name. The return maps contains the key - client_service_name and value - list<span_durations>.

Parameters:

  • TimeStamp
  • ServiceName
  • RpcName

func (*ZipkinQueryClient) GetSpanNames 

func (p *ZipkinQueryClient) GetSpanNames(service_name string) (r map[string]bool, err error)

Get all the seen span names for a particular service, from now back until the set ttl.

Parameters:

  • ServiceName

func (*ZipkinQueryClient) GetTopAnnotations 

func (p *ZipkinQueryClient) GetTopAnnotations(service_name string) (r []string, err error)

Parameters:

  • ServiceName

func (*ZipkinQueryClient) GetTopKeyValueAnnotations 

func (p *ZipkinQueryClient) GetTopKeyValueAnnotations(service_name string) (r []string, err error)

Parameters:

  • ServiceName

func (*ZipkinQueryClient) GetTraceCombosByIds 

func (p *ZipkinQueryClient) GetTraceCombosByIds(trace_ids []int64, adjust []Adjust) (r []*TraceCombo, err error)

Not content with just one of traces, summaries or timelines? Want it all? This is the method for you.

Parameters:

  • TraceIds
  • Adjust

func (*ZipkinQueryClient) GetTraceIds 

func (p *ZipkinQueryClient) GetTraceIds(request *QueryRequest) (r *QueryResponse, err error)

Parameters:

  • Request

func (*ZipkinQueryClient) GetTraceIdsByAnnotation 

func (p *ZipkinQueryClient) GetTraceIdsByAnnotation(service_name string, annotation string, value []byte, end_ts int64, limit int32, order Order) (r []int64, err error)

Fetch trace ids with a particular annotation. Gets "limit" number of entries from before the "end_ts".

When requesting based on time based annotations only pass in the first parameter, "annotation" and leave out the second "value". If looking for a key-value binary annotation provide both, "annotation" is then the key in the key-value.

Timestamps are in microseconds.

Parameters:

  • ServiceName
  • Annotation
  • Value
  • EndTs
  • Limit
  • Order

func (*ZipkinQueryClient) GetTraceIdsByServiceName 

func (p *ZipkinQueryClient) GetTraceIdsByServiceName(service_name string, end_ts int64, limit int32, order Order) (r []int64, err error)

Fetch trace ids by service name. Gets "limit" number of entries from before the "end_ts".

Timestamps are in microseconds.

Parameters:

  • ServiceName
  • EndTs
  • Limit
  • Order

func (*ZipkinQueryClient) GetTraceIdsBySpanName 

func (p *ZipkinQueryClient) GetTraceIdsBySpanName(service_name string, span_name string, end_ts int64, limit int32, order Order) (r []int64, err error)

Fetch trace ids by service and span name. Gets "limit" number of entries from before the "end_ts".

Span name is optional. Timestamps are in microseconds.

Parameters:

  • ServiceName
  • SpanName
  • EndTs
  • Limit
  • Order

func (*ZipkinQueryClient) GetTraceSummariesByIds 

func (p *ZipkinQueryClient) GetTraceSummariesByIds(trace_ids []int64, adjust []Adjust) (r []*TraceSummary, err error)

Fetch trace summaries for the given trace ids.

Second argument is a list of methods of adjusting the trace data before returning it. Can be empty.

Note that if one of the trace ids does not have any data associated with it, it will not be represented in the output list.

Parameters:

  • TraceIds
  • Adjust

func (*ZipkinQueryClient) GetTraceTimeToLive 

func (p *ZipkinQueryClient) GetTraceTimeToLive(trace_id int64) (r int32, err error)

Get the TTL in seconds of a specific trace.

Parameters:

  • TraceId

func (*ZipkinQueryClient) GetTraceTimelinesByIds 

func (p *ZipkinQueryClient) GetTraceTimelinesByIds(trace_ids []int64, adjust []Adjust) (r []*TraceTimeline, err error)

Get the trace timelines associated with the given trace ids. This is a convenience method for users that just want to know the annotations and the (assumed) order they happened in.

Second argument is a list of methods of adjusting the trace data before returning it. Can be empty.

Note that if one of the trace ids does not have any data associated with it, it will not be represented in the output list.

Parameters:

  • TraceIds
  • Adjust

func (*ZipkinQueryClient) GetTracesByIds 

func (p *ZipkinQueryClient) GetTracesByIds(trace_ids []int64, adjust []Adjust) (r []*Trace, err error)

Get the full traces associated with the given trace ids.

Second argument is a list of methods of adjusting the trace data before returning it. Can be empty.

Parameters:

  • TraceIds
  • Adjust

func (*ZipkinQueryClient) SetTraceTimeToLive 

func (p *ZipkinQueryClient) SetTraceTimeToLive(trace_id int64, ttl_seconds int32) (err error)

Change the TTL of a trace. If we find an interesting trace we want to keep around for further investigation.

Parameters:

  • TraceId
  • TtlSeconds

func (*ZipkinQueryClient) TracesExist 

func (p *ZipkinQueryClient) TracesExist(trace_ids []int64) (r map[int64]bool, err error)

Get the traces that are in the database from the given list of trace ids.

Parameters:

  • TraceIds

type ZipkinQueryProcessor 

type ZipkinQueryProcessor struct {
	// contains filtered or unexported fields
}

func NewZipkinQueryProcessor 

func NewZipkinQueryProcessor(handler ZipkinQuery) *ZipkinQueryProcessor

func (*ZipkinQueryProcessor) AddToProcessorMap 

func (p *ZipkinQueryProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*ZipkinQueryProcessor) GetProcessorFunction 

func (p *ZipkinQueryProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*ZipkinQueryProcessor) Process 

func (p *ZipkinQueryProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*ZipkinQueryProcessor) ProcessorMap 

func (p *ZipkinQueryProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.