Versions in this module Expand all Collapse all v0 v0.16.1 Sep 22, 2022 Changes in this version + var GoUnusedProtection__ int + var TAggregatedRuntimeProfileNode_Counters_DEFAULT []*TAggCounter + var TAggregatedRuntimeProfileNode_EventSequences_DEFAULT []*TAggEventSequence + var TAggregatedRuntimeProfileNode_InfoStrings_DEFAULT map[string]map[string][]int32 + var TAggregatedRuntimeProfileNode_InputProfiles_DEFAULT []string + var TAggregatedRuntimeProfileNode_NumInstances_DEFAULT int32 + var TAggregatedRuntimeProfileNode_SummaryStatsCounters_DEFAULT []*TAggSummaryStatsCounter + var TAggregatedRuntimeProfileNode_TimeSeriesCounters_DEFAULT []*TAggTimeSeriesCounter + var TRuntimeProfileNodeMetadata_DataSinkID_DEFAULT types.TDataSinkId + var TRuntimeProfileNodeMetadata_PlanNodeID_DEFAULT types.TPlanNodeId + var TRuntimeProfileNode_EventSequences_DEFAULT []*TEventSequence + var TRuntimeProfileNode_SummaryStatsCounters_DEFAULT []*TSummaryStatsCounter + var TRuntimeProfileNode_TimeSeriesCounters_DEFAULT []*TTimeSeriesCounter + var TRuntimeProfileTree_ExecSummary_DEFAULT *execstats.TExecSummary + var TRuntimeProfileTree_ProfileVersion_DEFAULT int32 + var TTimeSeriesCounter_StartIndex_DEFAULT int64 + type TAggCounter struct + HasValue []bool + Name string + Unit metrics.TUnit + Values []int64 + func NewTAggCounter() *TAggCounter + func (p *TAggCounter) Equals(other *TAggCounter) bool + func (p *TAggCounter) GetHasValue() []bool + func (p *TAggCounter) GetName() string + func (p *TAggCounter) GetUnit() metrics.TUnit + func (p *TAggCounter) GetValues() []int64 + func (p *TAggCounter) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggCounter) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggCounter) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggCounter) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggCounter) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggCounter) String() string + func (p *TAggCounter) Write(ctx context.Context, oprot thrift.TProtocol) error + type TAggEventSequence struct + LabelDict []string + LabelIdxs [][]int32 + Name string + Timestamps [][]int64 + func NewTAggEventSequence() *TAggEventSequence + func (p *TAggEventSequence) Equals(other *TAggEventSequence) bool + func (p *TAggEventSequence) GetLabelDict() []string + func (p *TAggEventSequence) GetLabelIdxs() [][]int32 + func (p *TAggEventSequence) GetName() string + func (p *TAggEventSequence) GetTimestamps() [][]int64 + func (p *TAggEventSequence) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggEventSequence) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggEventSequence) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggEventSequence) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggEventSequence) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggEventSequence) String() string + func (p *TAggEventSequence) Write(ctx context.Context, oprot thrift.TProtocol) error + type TAggSummaryStatsCounter struct + HasValue []bool + MaxValue []int64 + MinValue []int64 + Name string + Sum []int64 + TotalNumValues []int64 + Unit metrics.TUnit + func NewTAggSummaryStatsCounter() *TAggSummaryStatsCounter + func (p *TAggSummaryStatsCounter) Equals(other *TAggSummaryStatsCounter) bool + func (p *TAggSummaryStatsCounter) GetHasValue() []bool + func (p *TAggSummaryStatsCounter) GetMaxValue() []int64 + func (p *TAggSummaryStatsCounter) GetMinValue() []int64 + func (p *TAggSummaryStatsCounter) GetName() string + func (p *TAggSummaryStatsCounter) GetSum() []int64 + func (p *TAggSummaryStatsCounter) GetTotalNumValues() []int64 + func (p *TAggSummaryStatsCounter) GetUnit() metrics.TUnit + func (p *TAggSummaryStatsCounter) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggSummaryStatsCounter) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggSummaryStatsCounter) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggSummaryStatsCounter) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggSummaryStatsCounter) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggSummaryStatsCounter) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggSummaryStatsCounter) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggSummaryStatsCounter) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggSummaryStatsCounter) String() string + func (p *TAggSummaryStatsCounter) Write(ctx context.Context, oprot thrift.TProtocol) error + type TAggTimeSeriesCounter struct + Name string + PeriodMs []int32 + StartIndex []int64 + Unit metrics.TUnit + Values [][]int64 + func NewTAggTimeSeriesCounter() *TAggTimeSeriesCounter + func (p *TAggTimeSeriesCounter) Equals(other *TAggTimeSeriesCounter) bool + func (p *TAggTimeSeriesCounter) GetName() string + func (p *TAggTimeSeriesCounter) GetPeriodMs() []int32 + func (p *TAggTimeSeriesCounter) GetStartIndex() []int64 + func (p *TAggTimeSeriesCounter) GetUnit() metrics.TUnit + func (p *TAggTimeSeriesCounter) GetValues() [][]int64 + func (p *TAggTimeSeriesCounter) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggTimeSeriesCounter) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggTimeSeriesCounter) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggTimeSeriesCounter) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggTimeSeriesCounter) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggTimeSeriesCounter) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggTimeSeriesCounter) String() string + func (p *TAggTimeSeriesCounter) Write(ctx context.Context, oprot thrift.TProtocol) error + type TAggregatedRuntimeProfileNode struct + Counters []*TAggCounter + EventSequences []*TAggEventSequence + InfoStrings map[string]map[string][]int32 + InputProfiles []string + NumInstances *int32 + SummaryStatsCounters []*TAggSummaryStatsCounter + TimeSeriesCounters []*TAggTimeSeriesCounter + var TRuntimeProfileNode_Aggregated_DEFAULT *TAggregatedRuntimeProfileNode + func NewTAggregatedRuntimeProfileNode() *TAggregatedRuntimeProfileNode + func (p *TAggregatedRuntimeProfileNode) Equals(other *TAggregatedRuntimeProfileNode) bool + func (p *TAggregatedRuntimeProfileNode) GetCounters() []*TAggCounter + func (p *TAggregatedRuntimeProfileNode) GetEventSequences() []*TAggEventSequence + func (p *TAggregatedRuntimeProfileNode) GetInfoStrings() map[string]map[string][]int32 + func (p *TAggregatedRuntimeProfileNode) GetInputProfiles() []string + func (p *TAggregatedRuntimeProfileNode) GetNumInstances() int32 + func (p *TAggregatedRuntimeProfileNode) GetSummaryStatsCounters() []*TAggSummaryStatsCounter + func (p *TAggregatedRuntimeProfileNode) GetTimeSeriesCounters() []*TAggTimeSeriesCounter + func (p *TAggregatedRuntimeProfileNode) IsSetCounters() bool + func (p *TAggregatedRuntimeProfileNode) IsSetEventSequences() bool + func (p *TAggregatedRuntimeProfileNode) IsSetInfoStrings() bool + func (p *TAggregatedRuntimeProfileNode) IsSetInputProfiles() bool + func (p *TAggregatedRuntimeProfileNode) IsSetNumInstances() bool + func (p *TAggregatedRuntimeProfileNode) IsSetSummaryStatsCounters() bool + func (p *TAggregatedRuntimeProfileNode) IsSetTimeSeriesCounters() bool + func (p *TAggregatedRuntimeProfileNode) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggregatedRuntimeProfileNode) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggregatedRuntimeProfileNode) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggregatedRuntimeProfileNode) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggregatedRuntimeProfileNode) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggregatedRuntimeProfileNode) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggregatedRuntimeProfileNode) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggregatedRuntimeProfileNode) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAggregatedRuntimeProfileNode) String() string + func (p *TAggregatedRuntimeProfileNode) Write(ctx context.Context, oprot thrift.TProtocol) error + type TCounter struct + Name string + Unit metrics.TUnit + Value int64 + func NewTCounter() *TCounter + func (p *TCounter) Equals(other *TCounter) bool + func (p *TCounter) GetName() string + func (p *TCounter) GetUnit() metrics.TUnit + func (p *TCounter) GetValue() int64 + func (p *TCounter) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TCounter) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TCounter) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TCounter) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TCounter) String() string + func (p *TCounter) Write(ctx context.Context, oprot thrift.TProtocol) error + type TEventSequence struct + Labels []string + Name string + Timestamps []int64 + func NewTEventSequence() *TEventSequence + func (p *TEventSequence) Equals(other *TEventSequence) bool + func (p *TEventSequence) GetLabels() []string + func (p *TEventSequence) GetName() string + func (p *TEventSequence) GetTimestamps() []int64 + func (p *TEventSequence) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TEventSequence) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TEventSequence) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TEventSequence) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TEventSequence) String() string + func (p *TEventSequence) Write(ctx context.Context, oprot thrift.TProtocol) error + type TRuntimeProfileForest struct + HostProfile *TRuntimeProfileTree + ProfileTrees []*TRuntimeProfileTree + func NewTRuntimeProfileForest() *TRuntimeProfileForest + func (p *TRuntimeProfileForest) Equals(other *TRuntimeProfileForest) bool + func (p *TRuntimeProfileForest) GetHostProfile() *TRuntimeProfileTree + func (p *TRuntimeProfileForest) GetProfileTrees() []*TRuntimeProfileTree + func (p *TRuntimeProfileForest) IsSetHostProfile() bool + func (p *TRuntimeProfileForest) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileForest) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileForest) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileForest) String() string + func (p *TRuntimeProfileForest) Write(ctx context.Context, oprot thrift.TProtocol) error + type TRuntimeProfileFormat int64 + const TRuntimeProfileFormat_BASE64 + const TRuntimeProfileFormat_JSON + const TRuntimeProfileFormat_STRING + const TRuntimeProfileFormat_THRIFT + func TRuntimeProfileFormatFromString(s string) (TRuntimeProfileFormat, error) + func TRuntimeProfileFormatPtr(v TRuntimeProfileFormat) *TRuntimeProfileFormat + func (p *TRuntimeProfileFormat) Scan(value interface{}) error + func (p *TRuntimeProfileFormat) UnmarshalText(text []byte) error + func (p *TRuntimeProfileFormat) Value() (driver.Value, error) + func (p TRuntimeProfileFormat) MarshalText() ([]byte, error) + func (p TRuntimeProfileFormat) String() string + type TRuntimeProfileNode struct + Aggregated *TAggregatedRuntimeProfileNode + ChildCountersMap map[string][]string + Counters []*TCounter + EventSequences []*TEventSequence + Indent bool + InfoStrings map[string]string + InfoStringsDisplayOrder []string + Metadata int64 + Name string + NodeMetadata *TRuntimeProfileNodeMetadata + NumChildren int32 + SummaryStatsCounters []*TSummaryStatsCounter + TimeSeriesCounters []*TTimeSeriesCounter + func NewTRuntimeProfileNode() *TRuntimeProfileNode + func (p *TRuntimeProfileNode) Equals(other *TRuntimeProfileNode) bool + func (p *TRuntimeProfileNode) GetAggregated() *TAggregatedRuntimeProfileNode + func (p *TRuntimeProfileNode) GetChildCountersMap() map[string][]string + func (p *TRuntimeProfileNode) GetCounters() []*TCounter + func (p *TRuntimeProfileNode) GetEventSequences() []*TEventSequence + func (p *TRuntimeProfileNode) GetIndent() bool + func (p *TRuntimeProfileNode) GetInfoStrings() map[string]string + func (p *TRuntimeProfileNode) GetInfoStringsDisplayOrder() []string + func (p *TRuntimeProfileNode) GetMetadata() int64 + func (p *TRuntimeProfileNode) GetName() string + func (p *TRuntimeProfileNode) GetNodeMetadata() *TRuntimeProfileNodeMetadata + func (p *TRuntimeProfileNode) GetNumChildren() int32 + func (p *TRuntimeProfileNode) GetSummaryStatsCounters() []*TSummaryStatsCounter + func (p *TRuntimeProfileNode) GetTimeSeriesCounters() []*TTimeSeriesCounter + func (p *TRuntimeProfileNode) IsSetAggregated() bool + func (p *TRuntimeProfileNode) IsSetEventSequences() bool + func (p *TRuntimeProfileNode) IsSetNodeMetadata() bool + func (p *TRuntimeProfileNode) IsSetSummaryStatsCounters() bool + func (p *TRuntimeProfileNode) IsSetTimeSeriesCounters() bool + func (p *TRuntimeProfileNode) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileNode) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileNode) ReadField10(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileNode) ReadField11(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileNode) ReadField12(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileNode) ReadField13(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileNode) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileNode) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileNode) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileNode) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileNode) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileNode) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileNode) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileNode) ReadField9(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileNode) String() string + func (p *TRuntimeProfileNode) Write(ctx context.Context, oprot thrift.TProtocol) error + type TRuntimeProfileNodeMetadata struct + DataSinkID *types.TDataSinkId + PlanNodeID *types.TPlanNodeId + var TRuntimeProfileNode_NodeMetadata_DEFAULT *TRuntimeProfileNodeMetadata + func NewTRuntimeProfileNodeMetadata() *TRuntimeProfileNodeMetadata + func (p *TRuntimeProfileNodeMetadata) CountSetFieldsTRuntimeProfileNodeMetadata() int + func (p *TRuntimeProfileNodeMetadata) Equals(other *TRuntimeProfileNodeMetadata) bool + func (p *TRuntimeProfileNodeMetadata) GetDataSinkID() types.TDataSinkId + func (p *TRuntimeProfileNodeMetadata) GetPlanNodeID() types.TPlanNodeId + func (p *TRuntimeProfileNodeMetadata) IsSetDataSinkID() bool + func (p *TRuntimeProfileNodeMetadata) IsSetPlanNodeID() bool + func (p *TRuntimeProfileNodeMetadata) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileNodeMetadata) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileNodeMetadata) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileNodeMetadata) String() string + func (p *TRuntimeProfileNodeMetadata) Write(ctx context.Context, oprot thrift.TProtocol) error + type TRuntimeProfileTree struct + ExecSummary *execstats.TExecSummary + Nodes []*TRuntimeProfileNode + ProfileVersion *int32 + var TRuntimeProfileForest_HostProfile_DEFAULT *TRuntimeProfileTree + func NewTRuntimeProfileTree() *TRuntimeProfileTree + func (p *TRuntimeProfileTree) Equals(other *TRuntimeProfileTree) bool + func (p *TRuntimeProfileTree) GetExecSummary() *execstats.TExecSummary + func (p *TRuntimeProfileTree) GetNodes() []*TRuntimeProfileNode + func (p *TRuntimeProfileTree) GetProfileVersion() int32 + func (p *TRuntimeProfileTree) IsSetExecSummary() bool + func (p *TRuntimeProfileTree) IsSetProfileVersion() bool + func (p *TRuntimeProfileTree) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileTree) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileTree) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileTree) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRuntimeProfileTree) String() string + func (p *TRuntimeProfileTree) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSummaryStatsCounter struct + MaxValue int64 + MinValue int64 + Name string + Sum int64 + TotalNumValues int64 + Unit metrics.TUnit + func NewTSummaryStatsCounter() *TSummaryStatsCounter + func (p *TSummaryStatsCounter) Equals(other *TSummaryStatsCounter) bool + func (p *TSummaryStatsCounter) GetMaxValue() int64 + func (p *TSummaryStatsCounter) GetMinValue() int64 + func (p *TSummaryStatsCounter) GetName() string + func (p *TSummaryStatsCounter) GetSum() int64 + func (p *TSummaryStatsCounter) GetTotalNumValues() int64 + func (p *TSummaryStatsCounter) GetUnit() metrics.TUnit + func (p *TSummaryStatsCounter) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSummaryStatsCounter) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSummaryStatsCounter) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSummaryStatsCounter) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSummaryStatsCounter) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSummaryStatsCounter) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSummaryStatsCounter) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSummaryStatsCounter) String() string + func (p *TSummaryStatsCounter) Write(ctx context.Context, oprot thrift.TProtocol) error + type TTimeSeriesCounter struct + Name string + PeriodMs int32 + StartIndex *int64 + Unit metrics.TUnit + Values []int64 + func NewTTimeSeriesCounter() *TTimeSeriesCounter + func (p *TTimeSeriesCounter) Equals(other *TTimeSeriesCounter) bool + func (p *TTimeSeriesCounter) GetName() string + func (p *TTimeSeriesCounter) GetPeriodMs() int32 + func (p *TTimeSeriesCounter) GetStartIndex() int64 + func (p *TTimeSeriesCounter) GetUnit() metrics.TUnit + func (p *TTimeSeriesCounter) GetValues() []int64 + func (p *TTimeSeriesCounter) IsSetStartIndex() bool + func (p *TTimeSeriesCounter) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTimeSeriesCounter) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTimeSeriesCounter) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTimeSeriesCounter) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTimeSeriesCounter) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTimeSeriesCounter) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTimeSeriesCounter) String() string + func (p *TTimeSeriesCounter) Write(ctx context.Context, oprot thrift.TProtocol) error