runtimeprofile

package
v0.16.1 Latest Latest
Warning

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

 Go to latest Published: Sep 22, 2022 License: Apache-2.0 Imports: 10 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int
View Source 
var TAggregatedRuntimeProfileNode_Counters_DEFAULT []*TAggCounter
View Source 
var TAggregatedRuntimeProfileNode_EventSequences_DEFAULT []*TAggEventSequence
View Source 
var TAggregatedRuntimeProfileNode_InfoStrings_DEFAULT map[string]map[string][]int32
View Source 
var TAggregatedRuntimeProfileNode_InputProfiles_DEFAULT []string
View Source 
var TAggregatedRuntimeProfileNode_NumInstances_DEFAULT int32
View Source 
var TAggregatedRuntimeProfileNode_SummaryStatsCounters_DEFAULT []*TAggSummaryStatsCounter
View Source 
var TAggregatedRuntimeProfileNode_TimeSeriesCounters_DEFAULT []*TAggTimeSeriesCounter
View Source 
var TRuntimeProfileNodeMetadata_DataSinkID_DEFAULT types.TDataSinkId
View Source 
var TRuntimeProfileNodeMetadata_PlanNodeID_DEFAULT types.TPlanNodeId
View Source 
var TRuntimeProfileNode_EventSequences_DEFAULT []*TEventSequence
View Source 
var TRuntimeProfileNode_SummaryStatsCounters_DEFAULT []*TSummaryStatsCounter
View Source 
var TRuntimeProfileNode_TimeSeriesCounters_DEFAULT []*TTimeSeriesCounter
View Source 
var TRuntimeProfileTree_ExecSummary_DEFAULT *execstats.TExecSummary
View Source 
var TRuntimeProfileTree_ProfileVersion_DEFAULT int32
View Source 
var TTimeSeriesCounter_StartIndex_DEFAULT int64

Functions

This section is empty.

Types

type TAggCounter 

type TAggCounter struct {
	Name     string        `thrift:"name,1,required" db:"name" json:"name"`
	Unit     metrics.TUnit `thrift:"unit,2,required" db:"unit" json:"unit"`
	HasValue []bool        `thrift:"has_value,3,required" db:"has_value" json:"has_value"`
	Values   []int64       `thrift:"values,4,required" db:"values" json:"values"`
}

Attributes:

  • Name
  • Unit
  • HasValue
  • Values

func NewTAggCounter 

func NewTAggCounter() *TAggCounter

func (*TAggCounter) Equals 

func (p *TAggCounter) Equals(other *TAggCounter) bool

func (*TAggCounter) GetHasValue 

func (p *TAggCounter) GetHasValue() []bool

func (*TAggCounter) GetName 

func (p *TAggCounter) GetName() string

func (*TAggCounter) GetUnit 

func (p *TAggCounter) GetUnit() metrics.TUnit

func (*TAggCounter) GetValues 

func (p *TAggCounter) GetValues() []int64

func (*TAggCounter) Read 

func (p *TAggCounter) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggCounter) ReadField1 

func (p *TAggCounter) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggCounter) ReadField2 

func (p *TAggCounter) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggCounter) ReadField3 

func (p *TAggCounter) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggCounter) ReadField4 

func (p *TAggCounter) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggCounter) String 

func (p *TAggCounter) String() string

func (*TAggCounter) Write 

func (p *TAggCounter) Write(ctx context.Context, oprot thrift.TProtocol) error

type TAggEventSequence 

type TAggEventSequence struct {
	Name       string    `thrift:"name,1,required" db:"name" json:"name"`
	LabelDict  []string  `thrift:"label_dict,2,required" db:"label_dict" json:"label_dict"`
	LabelIdxs  [][]int32 `thrift:"label_idxs,3,required" db:"label_idxs" json:"label_idxs"`
	Timestamps [][]int64 `thrift:"timestamps,4,required" db:"timestamps" json:"timestamps"`
}

Attributes:

  • Name
  • LabelDict
  • LabelIdxs
  • Timestamps

func NewTAggEventSequence 

func NewTAggEventSequence() *TAggEventSequence

func (*TAggEventSequence) Equals 

func (p *TAggEventSequence) Equals(other *TAggEventSequence) bool

func (*TAggEventSequence) GetLabelDict 

func (p *TAggEventSequence) GetLabelDict() []string

func (*TAggEventSequence) GetLabelIdxs 

func (p *TAggEventSequence) GetLabelIdxs() [][]int32

func (*TAggEventSequence) GetName 

func (p *TAggEventSequence) GetName() string

func (*TAggEventSequence) GetTimestamps 

func (p *TAggEventSequence) GetTimestamps() [][]int64

func (*TAggEventSequence) Read 

func (p *TAggEventSequence) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggEventSequence) ReadField1 

func (p *TAggEventSequence) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggEventSequence) ReadField2 

func (p *TAggEventSequence) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggEventSequence) ReadField3 

func (p *TAggEventSequence) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggEventSequence) ReadField4 

func (p *TAggEventSequence) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggEventSequence) String 

func (p *TAggEventSequence) String() string

func (*TAggEventSequence) Write 

func (p *TAggEventSequence) Write(ctx context.Context, oprot thrift.TProtocol) error

type TAggSummaryStatsCounter 

type TAggSummaryStatsCounter struct {
	Name           string        `thrift:"name,1,required" db:"name" json:"name"`
	Unit           metrics.TUnit `thrift:"unit,2,required" db:"unit" json:"unit"`
	HasValue       []bool        `thrift:"has_value,3,required" db:"has_value" json:"has_value"`
	Sum            []int64       `thrift:"sum,4,required" db:"sum" json:"sum"`
	TotalNumValues []int64       `thrift:"total_num_values,5,required" db:"total_num_values" json:"total_num_values"`
	MinValue       []int64       `thrift:"min_value,6,required" db:"min_value" json:"min_value"`
	MaxValue       []int64       `thrift:"max_value,7,required" db:"max_value" json:"max_value"`
}

Attributes:

  • Name
  • Unit
  • HasValue
  • Sum
  • TotalNumValues
  • MinValue
  • MaxValue

func NewTAggSummaryStatsCounter 

func NewTAggSummaryStatsCounter() *TAggSummaryStatsCounter

func (*TAggSummaryStatsCounter) Equals 

func (p *TAggSummaryStatsCounter) Equals(other *TAggSummaryStatsCounter) bool

func (*TAggSummaryStatsCounter) GetHasValue 

func (p *TAggSummaryStatsCounter) GetHasValue() []bool

func (*TAggSummaryStatsCounter) GetMaxValue 

func (p *TAggSummaryStatsCounter) GetMaxValue() []int64

func (*TAggSummaryStatsCounter) GetMinValue 

func (p *TAggSummaryStatsCounter) GetMinValue() []int64

func (*TAggSummaryStatsCounter) GetName 

func (p *TAggSummaryStatsCounter) GetName() string

func (*TAggSummaryStatsCounter) GetSum 

func (p *TAggSummaryStatsCounter) GetSum() []int64

func (*TAggSummaryStatsCounter) GetTotalNumValues 

func (p *TAggSummaryStatsCounter) GetTotalNumValues() []int64

func (*TAggSummaryStatsCounter) GetUnit 

func (p *TAggSummaryStatsCounter) GetUnit() metrics.TUnit

func (*TAggSummaryStatsCounter) Read 

func (p *TAggSummaryStatsCounter) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggSummaryStatsCounter) ReadField1 

func (p *TAggSummaryStatsCounter) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggSummaryStatsCounter) ReadField2 

func (p *TAggSummaryStatsCounter) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggSummaryStatsCounter) ReadField3 

func (p *TAggSummaryStatsCounter) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggSummaryStatsCounter) ReadField4 

func (p *TAggSummaryStatsCounter) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggSummaryStatsCounter) ReadField5 

func (p *TAggSummaryStatsCounter) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggSummaryStatsCounter) ReadField6 

func (p *TAggSummaryStatsCounter) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggSummaryStatsCounter) ReadField7 

func (p *TAggSummaryStatsCounter) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggSummaryStatsCounter) String 

func (p *TAggSummaryStatsCounter) String() string

func (*TAggSummaryStatsCounter) Write 

func (p *TAggSummaryStatsCounter) Write(ctx context.Context, oprot thrift.TProtocol) error

type TAggTimeSeriesCounter 

type TAggTimeSeriesCounter struct {
	Name       string        `thrift:"name,1,required" db:"name" json:"name"`
	Unit       metrics.TUnit `thrift:"unit,2,required" db:"unit" json:"unit"`
	PeriodMs   []int32       `thrift:"period_ms,3,required" db:"period_ms" json:"period_ms"`
	Values     [][]int64     `thrift:"values,4,required" db:"values" json:"values"`
	StartIndex []int64       `thrift:"start_index,5,required" db:"start_index" json:"start_index"`
}

Attributes:

  • Name
  • Unit
  • PeriodMs
  • Values
  • StartIndex

func NewTAggTimeSeriesCounter 

func NewTAggTimeSeriesCounter() *TAggTimeSeriesCounter

func (*TAggTimeSeriesCounter) Equals 

func (p *TAggTimeSeriesCounter) Equals(other *TAggTimeSeriesCounter) bool

func (*TAggTimeSeriesCounter) GetName 

func (p *TAggTimeSeriesCounter) GetName() string

func (*TAggTimeSeriesCounter) GetPeriodMs 

func (p *TAggTimeSeriesCounter) GetPeriodMs() []int32

func (*TAggTimeSeriesCounter) GetStartIndex 

func (p *TAggTimeSeriesCounter) GetStartIndex() []int64

func (*TAggTimeSeriesCounter) GetUnit 

func (p *TAggTimeSeriesCounter) GetUnit() metrics.TUnit

func (*TAggTimeSeriesCounter) GetValues 

func (p *TAggTimeSeriesCounter) GetValues() [][]int64

func (*TAggTimeSeriesCounter) Read 

func (p *TAggTimeSeriesCounter) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggTimeSeriesCounter) ReadField1 

func (p *TAggTimeSeriesCounter) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggTimeSeriesCounter) ReadField2 

func (p *TAggTimeSeriesCounter) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggTimeSeriesCounter) ReadField3 

func (p *TAggTimeSeriesCounter) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggTimeSeriesCounter) ReadField4 

func (p *TAggTimeSeriesCounter) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggTimeSeriesCounter) ReadField5 

func (p *TAggTimeSeriesCounter) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggTimeSeriesCounter) String 

func (p *TAggTimeSeriesCounter) String() string

func (*TAggTimeSeriesCounter) Write 

func (p *TAggTimeSeriesCounter) Write(ctx context.Context, oprot thrift.TProtocol) error

type TAggregatedRuntimeProfileNode 

type TAggregatedRuntimeProfileNode struct {
	NumInstances         *int32                        `thrift:"num_instances,1" db:"num_instances" json:"num_instances,omitempty"`
	InputProfiles        []string                      `thrift:"input_profiles,2" db:"input_profiles" json:"input_profiles,omitempty"`
	Counters             []*TAggCounter                `thrift:"counters,3" db:"counters" json:"counters,omitempty"`
	InfoStrings          map[string]map[string][]int32 `thrift:"info_strings,4" db:"info_strings" json:"info_strings,omitempty"`
	SummaryStatsCounters []*TAggSummaryStatsCounter    `thrift:"summary_stats_counters,5" db:"summary_stats_counters" json:"summary_stats_counters,omitempty"`
	EventSequences       []*TAggEventSequence          `thrift:"event_sequences,6" db:"event_sequences" json:"event_sequences,omitempty"`
	TimeSeriesCounters   []*TAggTimeSeriesCounter      `thrift:"time_series_counters,7" db:"time_series_counters" json:"time_series_counters,omitempty"`
}

Attributes:

  • NumInstances
  • InputProfiles
  • Counters
  • InfoStrings
  • SummaryStatsCounters
  • EventSequences
  • TimeSeriesCounters
var TRuntimeProfileNode_Aggregated_DEFAULT *TAggregatedRuntimeProfileNode

func NewTAggregatedRuntimeProfileNode 

func NewTAggregatedRuntimeProfileNode() *TAggregatedRuntimeProfileNode

func (*TAggregatedRuntimeProfileNode) Equals 

func (p *TAggregatedRuntimeProfileNode) Equals(other *TAggregatedRuntimeProfileNode) bool

func (*TAggregatedRuntimeProfileNode) GetCounters 

func (p *TAggregatedRuntimeProfileNode) GetCounters() []*TAggCounter

func (*TAggregatedRuntimeProfileNode) GetEventSequences 

func (p *TAggregatedRuntimeProfileNode) GetEventSequences() []*TAggEventSequence

func (*TAggregatedRuntimeProfileNode) GetInfoStrings 

func (p *TAggregatedRuntimeProfileNode) GetInfoStrings() map[string]map[string][]int32

func (*TAggregatedRuntimeProfileNode) GetInputProfiles 

func (p *TAggregatedRuntimeProfileNode) GetInputProfiles() []string

func (*TAggregatedRuntimeProfileNode) GetNumInstances 

func (p *TAggregatedRuntimeProfileNode) GetNumInstances() int32

func (*TAggregatedRuntimeProfileNode) GetSummaryStatsCounters 

func (p *TAggregatedRuntimeProfileNode) GetSummaryStatsCounters() []*TAggSummaryStatsCounter

func (*TAggregatedRuntimeProfileNode) GetTimeSeriesCounters 

func (p *TAggregatedRuntimeProfileNode) GetTimeSeriesCounters() []*TAggTimeSeriesCounter

func (*TAggregatedRuntimeProfileNode) IsSetCounters 

func (p *TAggregatedRuntimeProfileNode) IsSetCounters() bool

func (*TAggregatedRuntimeProfileNode) IsSetEventSequences 

func (p *TAggregatedRuntimeProfileNode) IsSetEventSequences() bool

func (*TAggregatedRuntimeProfileNode) IsSetInfoStrings 

func (p *TAggregatedRuntimeProfileNode) IsSetInfoStrings() bool

func (*TAggregatedRuntimeProfileNode) IsSetInputProfiles 

func (p *TAggregatedRuntimeProfileNode) IsSetInputProfiles() bool

func (*TAggregatedRuntimeProfileNode) IsSetNumInstances 

func (p *TAggregatedRuntimeProfileNode) IsSetNumInstances() bool

func (*TAggregatedRuntimeProfileNode) IsSetSummaryStatsCounters 

func (p *TAggregatedRuntimeProfileNode) IsSetSummaryStatsCounters() bool

func (*TAggregatedRuntimeProfileNode) IsSetTimeSeriesCounters 

func (p *TAggregatedRuntimeProfileNode) IsSetTimeSeriesCounters() bool

func (*TAggregatedRuntimeProfileNode) Read 

func (p *TAggregatedRuntimeProfileNode) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggregatedRuntimeProfileNode) ReadField1 

func (p *TAggregatedRuntimeProfileNode) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggregatedRuntimeProfileNode) ReadField2 

func (p *TAggregatedRuntimeProfileNode) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggregatedRuntimeProfileNode) ReadField3 

func (p *TAggregatedRuntimeProfileNode) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggregatedRuntimeProfileNode) ReadField4 

func (p *TAggregatedRuntimeProfileNode) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggregatedRuntimeProfileNode) ReadField5 

func (p *TAggregatedRuntimeProfileNode) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggregatedRuntimeProfileNode) ReadField6 

func (p *TAggregatedRuntimeProfileNode) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggregatedRuntimeProfileNode) ReadField7 

func (p *TAggregatedRuntimeProfileNode) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggregatedRuntimeProfileNode) String 

func (p *TAggregatedRuntimeProfileNode) String() string

func (*TAggregatedRuntimeProfileNode) Write 

func (p *TAggregatedRuntimeProfileNode) Write(ctx context.Context, oprot thrift.TProtocol) error

type TCounter 

type TCounter struct {
	Name  string        `thrift:"name,1,required" db:"name" json:"name"`
	Unit  metrics.TUnit `thrift:"unit,2,required" db:"unit" json:"unit"`
	Value int64         `thrift:"value,3,required" db:"value" json:"value"`
}

Attributes:

  • Name
  • Unit
  • Value

func NewTCounter 

func NewTCounter() *TCounter

func (*TCounter) Equals 

func (p *TCounter) Equals(other *TCounter) bool

func (*TCounter) GetName 

func (p *TCounter) GetName() string

func (*TCounter) GetUnit 

func (p *TCounter) GetUnit() metrics.TUnit

func (*TCounter) GetValue 

func (p *TCounter) GetValue() int64

func (*TCounter) Read 

func (p *TCounter) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TCounter) ReadField1 

func (p *TCounter) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TCounter) ReadField2 

func (p *TCounter) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TCounter) ReadField3 

func (p *TCounter) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TCounter) String 

func (p *TCounter) String() string

func (*TCounter) Write 

func (p *TCounter) Write(ctx context.Context, oprot thrift.TProtocol) error

type TEventSequence 

type TEventSequence struct {
	Name       string   `thrift:"name,1,required" db:"name" json:"name"`
	Timestamps []int64  `thrift:"timestamps,2,required" db:"timestamps" json:"timestamps"`
	Labels     []string `thrift:"labels,3,required" db:"labels" json:"labels"`
}

Attributes:

  • Name
  • Timestamps
  • Labels

func NewTEventSequence 

func NewTEventSequence() *TEventSequence

func (*TEventSequence) Equals 

func (p *TEventSequence) Equals(other *TEventSequence) bool

func (*TEventSequence) GetLabels 

func (p *TEventSequence) GetLabels() []string

func (*TEventSequence) GetName 

func (p *TEventSequence) GetName() string

func (*TEventSequence) GetTimestamps 

func (p *TEventSequence) GetTimestamps() []int64

func (*TEventSequence) Read 

func (p *TEventSequence) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TEventSequence) ReadField1 

func (p *TEventSequence) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TEventSequence) ReadField2 

func (p *TEventSequence) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TEventSequence) ReadField3 

func (p *TEventSequence) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TEventSequence) String 

func (p *TEventSequence) String() string

func (*TEventSequence) Write 

func (p *TEventSequence) Write(ctx context.Context, oprot thrift.TProtocol) error

type TRuntimeProfileForest 

type TRuntimeProfileForest struct {
	ProfileTrees []*TRuntimeProfileTree `thrift:"profile_trees,1,required" db:"profile_trees" json:"profile_trees"`
	HostProfile  *TRuntimeProfileTree   `thrift:"host_profile,2" db:"host_profile" json:"host_profile,omitempty"`
}

Attributes:

  • ProfileTrees
  • HostProfile

func NewTRuntimeProfileForest 

func NewTRuntimeProfileForest() *TRuntimeProfileForest

func (*TRuntimeProfileForest) Equals 

func (p *TRuntimeProfileForest) Equals(other *TRuntimeProfileForest) bool

func (*TRuntimeProfileForest) GetHostProfile 

func (p *TRuntimeProfileForest) GetHostProfile() *TRuntimeProfileTree

func (*TRuntimeProfileForest) GetProfileTrees 

func (p *TRuntimeProfileForest) GetProfileTrees() []*TRuntimeProfileTree

func (*TRuntimeProfileForest) IsSetHostProfile 

func (p *TRuntimeProfileForest) IsSetHostProfile() bool

func (*TRuntimeProfileForest) Read 

func (p *TRuntimeProfileForest) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileForest) ReadField1 

func (p *TRuntimeProfileForest) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileForest) ReadField2 

func (p *TRuntimeProfileForest) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileForest) String 

func (p *TRuntimeProfileForest) String() string

func (*TRuntimeProfileForest) Write 

func (p *TRuntimeProfileForest) Write(ctx context.Context, oprot thrift.TProtocol) error

type TRuntimeProfileFormat 

type TRuntimeProfileFormat int64
const (
	TRuntimeProfileFormat_STRING TRuntimeProfileFormat = 0
	TRuntimeProfileFormat_BASE64 TRuntimeProfileFormat = 1
	TRuntimeProfileFormat_THRIFT TRuntimeProfileFormat = 2
	TRuntimeProfileFormat_JSON   TRuntimeProfileFormat = 3
)

func TRuntimeProfileFormatFromString 

func TRuntimeProfileFormatFromString(s string) (TRuntimeProfileFormat, error)

func TRuntimeProfileFormatPtr 

func TRuntimeProfileFormatPtr(v TRuntimeProfileFormat) *TRuntimeProfileFormat

func (TRuntimeProfileFormat) MarshalText 

func (p TRuntimeProfileFormat) MarshalText() ([]byte, error)

func (*TRuntimeProfileFormat) Scan 

func (p *TRuntimeProfileFormat) Scan(value interface{}) error

func (TRuntimeProfileFormat) String 

func (p TRuntimeProfileFormat) String() string

func (*TRuntimeProfileFormat) UnmarshalText 

func (p *TRuntimeProfileFormat) UnmarshalText(text []byte) error

func (*TRuntimeProfileFormat) Value 

func (p *TRuntimeProfileFormat) Value() (driver.Value, error)

type TRuntimeProfileNode 

type TRuntimeProfileNode struct {
	Name                    string                         `thrift:"name,1,required" db:"name" json:"name"`
	NumChildren             int32                          `thrift:"num_children,2,required" db:"num_children" json:"num_children"`
	Counters                []*TCounter                    `thrift:"counters,3,required" db:"counters" json:"counters"`
	Metadata                int64                          `thrift:"metadata,4,required" db:"metadata" json:"metadata"`
	Indent                  bool                           `thrift:"indent,5,required" db:"indent" json:"indent"`
	InfoStrings             map[string]string              `thrift:"info_strings,6,required" db:"info_strings" json:"info_strings"`
	InfoStringsDisplayOrder []string                       `thrift:"info_strings_display_order,7,required" db:"info_strings_display_order" json:"info_strings_display_order"`
	ChildCountersMap        map[string][]string            `thrift:"child_counters_map,8,required" db:"child_counters_map" json:"child_counters_map"`
	EventSequences          []*TEventSequence              `thrift:"event_sequences,9" db:"event_sequences" json:"event_sequences,omitempty"`
	TimeSeriesCounters      []*TTimeSeriesCounter          `thrift:"time_series_counters,10" db:"time_series_counters" json:"time_series_counters,omitempty"`
	SummaryStatsCounters    []*TSummaryStatsCounter        `thrift:"summary_stats_counters,11" db:"summary_stats_counters" json:"summary_stats_counters,omitempty"`
	NodeMetadata            *TRuntimeProfileNodeMetadata   `thrift:"node_metadata,12" db:"node_metadata" json:"node_metadata,omitempty"`
	Aggregated              *TAggregatedRuntimeProfileNode `thrift:"aggregated,13" db:"aggregated" json:"aggregated,omitempty"`
}

Attributes:

  • Name
  • NumChildren
  • Counters
  • Metadata
  • Indent
  • InfoStrings
  • InfoStringsDisplayOrder
  • ChildCountersMap
  • EventSequences
  • TimeSeriesCounters
  • SummaryStatsCounters
  • NodeMetadata
  • Aggregated

func NewTRuntimeProfileNode 

func NewTRuntimeProfileNode() *TRuntimeProfileNode

func (*TRuntimeProfileNode) Equals 

func (p *TRuntimeProfileNode) Equals(other *TRuntimeProfileNode) bool

func (*TRuntimeProfileNode) GetAggregated 

func (p *TRuntimeProfileNode) GetAggregated() *TAggregatedRuntimeProfileNode

func (*TRuntimeProfileNode) GetChildCountersMap 

func (p *TRuntimeProfileNode) GetChildCountersMap() map[string][]string

func (*TRuntimeProfileNode) GetCounters 

func (p *TRuntimeProfileNode) GetCounters() []*TCounter

func (*TRuntimeProfileNode) GetEventSequences 

func (p *TRuntimeProfileNode) GetEventSequences() []*TEventSequence

func (*TRuntimeProfileNode) GetIndent 

func (p *TRuntimeProfileNode) GetIndent() bool

func (*TRuntimeProfileNode) GetInfoStrings 

func (p *TRuntimeProfileNode) GetInfoStrings() map[string]string

func (*TRuntimeProfileNode) GetInfoStringsDisplayOrder 

func (p *TRuntimeProfileNode) GetInfoStringsDisplayOrder() []string

func (*TRuntimeProfileNode) GetMetadata 

func (p *TRuntimeProfileNode) GetMetadata() int64

func (*TRuntimeProfileNode) GetName 

func (p *TRuntimeProfileNode) GetName() string

func (*TRuntimeProfileNode) GetNodeMetadata 

func (p *TRuntimeProfileNode) GetNodeMetadata() *TRuntimeProfileNodeMetadata

func (*TRuntimeProfileNode) GetNumChildren 

func (p *TRuntimeProfileNode) GetNumChildren() int32

func (*TRuntimeProfileNode) GetSummaryStatsCounters 

func (p *TRuntimeProfileNode) GetSummaryStatsCounters() []*TSummaryStatsCounter

func (*TRuntimeProfileNode) GetTimeSeriesCounters 

func (p *TRuntimeProfileNode) GetTimeSeriesCounters() []*TTimeSeriesCounter

func (*TRuntimeProfileNode) IsSetAggregated 

func (p *TRuntimeProfileNode) IsSetAggregated() bool

func (*TRuntimeProfileNode) IsSetEventSequences 

func (p *TRuntimeProfileNode) IsSetEventSequences() bool

func (*TRuntimeProfileNode) IsSetNodeMetadata 

func (p *TRuntimeProfileNode) IsSetNodeMetadata() bool

func (*TRuntimeProfileNode) IsSetSummaryStatsCounters 

func (p *TRuntimeProfileNode) IsSetSummaryStatsCounters() bool

func (*TRuntimeProfileNode) IsSetTimeSeriesCounters 

func (p *TRuntimeProfileNode) IsSetTimeSeriesCounters() bool

func (*TRuntimeProfileNode) Read 

func (p *TRuntimeProfileNode) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileNode) ReadField1 

func (p *TRuntimeProfileNode) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileNode) ReadField10 

func (p *TRuntimeProfileNode) ReadField10(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileNode) ReadField11 

func (p *TRuntimeProfileNode) ReadField11(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileNode) ReadField12 

func (p *TRuntimeProfileNode) ReadField12(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileNode) ReadField13 

func (p *TRuntimeProfileNode) ReadField13(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileNode) ReadField2 

func (p *TRuntimeProfileNode) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileNode) ReadField3 

func (p *TRuntimeProfileNode) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileNode) ReadField4 

func (p *TRuntimeProfileNode) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileNode) ReadField5 

func (p *TRuntimeProfileNode) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileNode) ReadField6 

func (p *TRuntimeProfileNode) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileNode) ReadField7 

func (p *TRuntimeProfileNode) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileNode) ReadField8 

func (p *TRuntimeProfileNode) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileNode) ReadField9 

func (p *TRuntimeProfileNode) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileNode) String 

func (p *TRuntimeProfileNode) String() string

func (*TRuntimeProfileNode) Write 

func (p *TRuntimeProfileNode) Write(ctx context.Context, oprot thrift.TProtocol) error

type TRuntimeProfileNodeMetadata 

type TRuntimeProfileNodeMetadata struct {
	PlanNodeID *types.TPlanNodeId `thrift:"plan_node_id,1" db:"plan_node_id" json:"plan_node_id,omitempty"`
	DataSinkID *types.TDataSinkId `thrift:"data_sink_id,2" db:"data_sink_id" json:"data_sink_id,omitempty"`
}

Attributes:

  • PlanNodeID
  • DataSinkID
var TRuntimeProfileNode_NodeMetadata_DEFAULT *TRuntimeProfileNodeMetadata

func NewTRuntimeProfileNodeMetadata 

func NewTRuntimeProfileNodeMetadata() *TRuntimeProfileNodeMetadata

func (*TRuntimeProfileNodeMetadata) CountSetFieldsTRuntimeProfileNodeMetadata 

func (p *TRuntimeProfileNodeMetadata) CountSetFieldsTRuntimeProfileNodeMetadata() int

func (*TRuntimeProfileNodeMetadata) Equals 

func (p *TRuntimeProfileNodeMetadata) Equals(other *TRuntimeProfileNodeMetadata) bool

func (*TRuntimeProfileNodeMetadata) GetDataSinkID 

func (p *TRuntimeProfileNodeMetadata) GetDataSinkID() types.TDataSinkId

func (*TRuntimeProfileNodeMetadata) GetPlanNodeID 

func (p *TRuntimeProfileNodeMetadata) GetPlanNodeID() types.TPlanNodeId

func (*TRuntimeProfileNodeMetadata) IsSetDataSinkID 

func (p *TRuntimeProfileNodeMetadata) IsSetDataSinkID() bool

func (*TRuntimeProfileNodeMetadata) IsSetPlanNodeID 

func (p *TRuntimeProfileNodeMetadata) IsSetPlanNodeID() bool

func (*TRuntimeProfileNodeMetadata) Read 

func (p *TRuntimeProfileNodeMetadata) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileNodeMetadata) ReadField1 

func (p *TRuntimeProfileNodeMetadata) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileNodeMetadata) ReadField2 

func (p *TRuntimeProfileNodeMetadata) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileNodeMetadata) String 

func (p *TRuntimeProfileNodeMetadata) String() string

func (*TRuntimeProfileNodeMetadata) Write 

func (p *TRuntimeProfileNodeMetadata) Write(ctx context.Context, oprot thrift.TProtocol) error

type TRuntimeProfileTree 

type TRuntimeProfileTree struct {
	Nodes          []*TRuntimeProfileNode  `thrift:"nodes,1,required" db:"nodes" json:"nodes"`
	ExecSummary    *execstats.TExecSummary `thrift:"exec_summary,2" db:"exec_summary" json:"exec_summary,omitempty"`
	ProfileVersion *int32                  `thrift:"profile_version,3" db:"profile_version" json:"profile_version,omitempty"`
}

Attributes:

  • Nodes
  • ExecSummary
  • ProfileVersion
var TRuntimeProfileForest_HostProfile_DEFAULT *TRuntimeProfileTree

func NewTRuntimeProfileTree 

func NewTRuntimeProfileTree() *TRuntimeProfileTree

func (*TRuntimeProfileTree) Equals 

func (p *TRuntimeProfileTree) Equals(other *TRuntimeProfileTree) bool

func (*TRuntimeProfileTree) GetExecSummary 

func (p *TRuntimeProfileTree) GetExecSummary() *execstats.TExecSummary

func (*TRuntimeProfileTree) GetNodes 

func (p *TRuntimeProfileTree) GetNodes() []*TRuntimeProfileNode

func (*TRuntimeProfileTree) GetProfileVersion 

func (p *TRuntimeProfileTree) GetProfileVersion() int32

func (*TRuntimeProfileTree) IsSetExecSummary 

func (p *TRuntimeProfileTree) IsSetExecSummary() bool

func (*TRuntimeProfileTree) IsSetProfileVersion 

func (p *TRuntimeProfileTree) IsSetProfileVersion() bool

func (*TRuntimeProfileTree) Read 

func (p *TRuntimeProfileTree) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileTree) ReadField1 

func (p *TRuntimeProfileTree) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileTree) ReadField2 

func (p *TRuntimeProfileTree) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileTree) ReadField3 

func (p *TRuntimeProfileTree) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TRuntimeProfileTree) String 

func (p *TRuntimeProfileTree) String() string

func (*TRuntimeProfileTree) Write 

func (p *TRuntimeProfileTree) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSummaryStatsCounter 

type TSummaryStatsCounter struct {
	Name           string        `thrift:"name,1,required" db:"name" json:"name"`
	Unit           metrics.TUnit `thrift:"unit,2,required" db:"unit" json:"unit"`
	Sum            int64         `thrift:"sum,3,required" db:"sum" json:"sum"`
	TotalNumValues int64         `thrift:"total_num_values,4,required" db:"total_num_values" json:"total_num_values"`
	MinValue       int64         `thrift:"min_value,5,required" db:"min_value" json:"min_value"`
	MaxValue       int64         `thrift:"max_value,6,required" db:"max_value" json:"max_value"`
}

Attributes:

  • Name
  • Unit
  • Sum
  • TotalNumValues
  • MinValue
  • MaxValue

func NewTSummaryStatsCounter 

func NewTSummaryStatsCounter() *TSummaryStatsCounter

func (*TSummaryStatsCounter) Equals 

func (p *TSummaryStatsCounter) Equals(other *TSummaryStatsCounter) bool

func (*TSummaryStatsCounter) GetMaxValue 

func (p *TSummaryStatsCounter) GetMaxValue() int64

func (*TSummaryStatsCounter) GetMinValue 

func (p *TSummaryStatsCounter) GetMinValue() int64

func (*TSummaryStatsCounter) GetName 

func (p *TSummaryStatsCounter) GetName() string

func (*TSummaryStatsCounter) GetSum 

func (p *TSummaryStatsCounter) GetSum() int64

func (*TSummaryStatsCounter) GetTotalNumValues 

func (p *TSummaryStatsCounter) GetTotalNumValues() int64

func (*TSummaryStatsCounter) GetUnit 

func (p *TSummaryStatsCounter) GetUnit() metrics.TUnit

func (*TSummaryStatsCounter) Read 

func (p *TSummaryStatsCounter) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSummaryStatsCounter) ReadField1 

func (p *TSummaryStatsCounter) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSummaryStatsCounter) ReadField2 

func (p *TSummaryStatsCounter) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSummaryStatsCounter) ReadField3 

func (p *TSummaryStatsCounter) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSummaryStatsCounter) ReadField4 

func (p *TSummaryStatsCounter) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSummaryStatsCounter) ReadField5 

func (p *TSummaryStatsCounter) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSummaryStatsCounter) ReadField6 

func (p *TSummaryStatsCounter) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TSummaryStatsCounter) String 

func (p *TSummaryStatsCounter) String() string

func (*TSummaryStatsCounter) Write 

func (p *TSummaryStatsCounter) Write(ctx context.Context, oprot thrift.TProtocol) error

type TTimeSeriesCounter 

type TTimeSeriesCounter struct {
	Name       string        `thrift:"name,1,required" db:"name" json:"name"`
	Unit       metrics.TUnit `thrift:"unit,2,required" db:"unit" json:"unit"`
	PeriodMs   int32         `thrift:"period_ms,3,required" db:"period_ms" json:"period_ms"`
	Values     []int64       `thrift:"values,4,required" db:"values" json:"values"`
	StartIndex *int64        `thrift:"start_index,5" db:"start_index" json:"start_index,omitempty"`
}

Attributes:

  • Name
  • Unit
  • PeriodMs
  • Values
  • StartIndex

func NewTTimeSeriesCounter 

func NewTTimeSeriesCounter() *TTimeSeriesCounter

func (*TTimeSeriesCounter) Equals 

func (p *TTimeSeriesCounter) Equals(other *TTimeSeriesCounter) bool

func (*TTimeSeriesCounter) GetName 

func (p *TTimeSeriesCounter) GetName() string

func (*TTimeSeriesCounter) GetPeriodMs 

func (p *TTimeSeriesCounter) GetPeriodMs() int32

func (*TTimeSeriesCounter) GetStartIndex 

func (p *TTimeSeriesCounter) GetStartIndex() int64

func (*TTimeSeriesCounter) GetUnit 

func (p *TTimeSeriesCounter) GetUnit() metrics.TUnit

func (*TTimeSeriesCounter) GetValues 

func (p *TTimeSeriesCounter) GetValues() []int64

func (*TTimeSeriesCounter) IsSetStartIndex 

func (p *TTimeSeriesCounter) IsSetStartIndex() bool

func (*TTimeSeriesCounter) Read 

func (p *TTimeSeriesCounter) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TTimeSeriesCounter) ReadField1 

func (p *TTimeSeriesCounter) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TTimeSeriesCounter) ReadField2 

func (p *TTimeSeriesCounter) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TTimeSeriesCounter) ReadField3 

func (p *TTimeSeriesCounter) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TTimeSeriesCounter) ReadField4 

func (p *TTimeSeriesCounter) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TTimeSeriesCounter) ReadField5 

func (p *TTimeSeriesCounter) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TTimeSeriesCounter) String 

func (p *TTimeSeriesCounter) String() string

func (*TTimeSeriesCounter) Write 

func (p *TTimeSeriesCounter) Write(ctx context.Context, oprot thrift.TProtocol) error

Source Files

View all Source files

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.