statistics

package
v1.4.2 Latest Latest
Warning

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

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

Documentation

Overview

Copyright 2022 Huawei Cloud Computing Technologies Co., Ltd.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2023 Huawei Cloud Computing Technologies Co., Ltd.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2022 Huawei Cloud Computing Technologies Co., Ltd.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. nolint

Index

Constants

View Source 
const (
	UNDERLINE  = "_"
	COUNT_NAME = "count"
	SUM_NAME   = "sum"
	LAST_NAME  = "last"
)
View Source 
const (
	StatDBDatabase       = "database"
	StatNumMeasurements  = "numMeasurements"
	StatNumRecentSeries  = "numRecentSeries"
	StatNumHistorySeries = "numHistorySeries"
)
View Source 
const (
	StatFileCount      = "FileCount"
	StatFileSize       = "FileSize"
	FileStatisticsName = "filestat"
)
View Source 
const (
	TypeMetaStatItem     = "MetaStatItem"
	TypeMetaRaftStatItem = "MetaRaftStatItem"
)
View Source 
const (
	StatSlowQueryDatabase   = "database"
	StatTotalDuration       = "totalDuration"
	StatPrepareDuration     = "prepareDuration"
	StatIteratorDuration    = "sqlIteratorDuration"
	StatChunkReaderCount    = "ChunkReaderCount"
	StatEmitDuration        = "emitDuration"
	StatQuery               = "query"
	StatQueryBatch          = "queryBatch"
	StatRpcDuration         = "rpcDuration"
	StatChunkReaderDuration = "chunkReaderDuration"
)
View Source 
const (
	OOOTimeDistributionMst = "ooo_time_distribution"
)
View Source 
const (
	RuntimeCollectInterval = 60 // second
)

Variables

View Source 
var CpuInterval = 10
View Source 
var CpuStatFile = "/sys/fs/cgroup/cpu,cpuacct/cpuacct.stat"
View Source 
var DatabaseStat = NewDBStatistics()
View Source 
var DatabaseStatisticsName = "database"
View Source 
var DatabaseTagMap map[string]string
View Source 
var (
	EngineStat = &EngineStatus{}
)
View Source 
var ExecutorStat = NewExecutorStatistics()
View Source 
var FileTagMap map[string]string
View Source 
var IOReadKBValue = []uint32{1, 16, 32}
View Source 
var IOStat = NewIOStatistics()
View Source 
var IOStatisticsName = "io"
View Source 
var IOTagMap map[string]string
View Source 
var PerfStat = NewPerfStatistics()
View Source 
var PerfStatisticsName = "performance"
View Source 
var PerfTagMap map[string]string
View Source 
var RuntimeStatisticsName = "runtime"
View Source 
var RuntimeTagMap map[string]string
View Source 
var SlowQueries = make(chan *SQLSlowQueryStatistics, 256)
View Source 
var SlowQueryTagMap map[string]string
View Source 
var SqlSlowQueryStatisticsName = "sql_slow_queries"
View Source 
var StoreSlowQueries = make(chan *StoreSlowQueryStatistics, 256)
View Source 
var StoreSlowQueryStatisticsName = "store_slow_queries"
View Source 
var StoreSlowQueryTagMap map[string]string

Functions

func AddPointToBuffer 

func AddPointToBuffer(statisticsName string, tagMap map[string]string, fieldMap map[string]interface{}, buffer []byte) []byte

func AddTimeToBuffer added in v1.0.0 

func AddTimeToBuffer(statisticsName string, tagMap map[string]string, fieldMap map[string]interface{}, t time.Time, buffer []byte) []byte

func AllocTagMap 

func AllocTagMap(tagMap, globalTag map[string]string)

func AppendSqlQueryDuration 

func AppendSqlQueryDuration(d *SQLSlowQueryStatistics)

func AppendStoreQueryDuration 

func AppendStoreQueryDuration(d *StoreSlowQueryStatistics)

func CollectDatabaseStatistics 

func CollectDatabaseStatistics(buffer []byte) ([]byte, error)

func CollectEngineStatStatistics 

func CollectEngineStatStatistics(buffer []byte) ([]byte, error)

func CollectExecutorStatistics 

func CollectExecutorStatistics(buffer []byte) ([]byte, error)

func CollectExecutorStatisticsOps added in v1.0.0 

func CollectExecutorStatisticsOps() []opsStat.OpsStatistic

func CollectIOStatistics 

func CollectIOStatistics(buffer []byte) ([]byte, error)

func CollectOpsEngineStatStatistics added in v1.0.0 

func CollectOpsEngineStatStatistics() []opsStat.OpsStatistic

func CollectOpsIOStatistics added in v1.0.0 

func CollectOpsIOStatistics() []opsStat.OpsStatistic

func CollectOpsPerfStatistics added in v1.0.0 

func CollectOpsPerfStatistics() []opsStat.OpsStatistic

func CollectOpsRuntimeStatistics added in v1.0.0 

func CollectOpsRuntimeStatistics() []opsStat.OpsStatistic

func CollectOpsSpdyStatistics added in v1.0.0 

func CollectOpsSpdyStatistics() []opsStat.OpsStatistic

func CollectOpsSqlSlowQueryStatistics added in v1.0.0 

func CollectOpsSqlSlowQueryStatistics() []opsStat.OpsStatistic

func CollectOpsStoreSlowQueryStatistics added in v1.0.0 

func CollectOpsStoreSlowQueryStatistics() []opsStat.OpsStatistic

func CollectPerfStatistics 

func CollectPerfStatistics(buffer []byte) ([]byte, error)

func CollectRuntimeStatistics 

func CollectRuntimeStatistics(buffer []byte) ([]byte, error)

func CollectSpdyStatistics 

func CollectSpdyStatistics(buffer []byte) ([]byte, error)

func CollectSqlSlowQueryStatistics 

func CollectSqlSlowQueryStatistics(buffer []byte) ([]byte, error)

func CollectStoreSlowQueryStatistics 

func CollectStoreSlowQueryStatistics(buffer []byte) ([]byte, error)

func CreateExecutorWithShardKey 

func CreateExecutorWithShardKey(buffer []byte) ([]byte, error)

func DBPTStepDuration added in v1.0.0 

func DBPTStepDuration(opId uint64, step string, d int64, status LoadStatus, errMsg string)

func DBPTTaskInit added in v1.0.0 

func DBPTTaskInit(opId uint64, db string, ptId uint32)

func FileStatisticsLimited 

func FileStatisticsLimited(i int64) bool

func GetCpuUsage 

func GetCpuUsage() (int64, int64)

func IndexStepDuration added in v1.0.0 

func IndexStepDuration(indexId uint64, opId uint64, step string, cost int64, isOver bool)

func IndexTaskInit added in v1.0.0 

func IndexTaskInit(indexId uint64, opId uint64, db string, ptId uint32, rp string)

func InitDatabaseStatistics 

func InitDatabaseStatistics(tags map[string]string)

func InitEngineStatistics 

func InitEngineStatistics(tags map[string]string)

func InitExecutorStatistics 

func InitExecutorStatistics(tags map[string]string)

func InitFileStatistics 

func InitFileStatistics(tags map[string]string)

func InitIOStatistics 

func InitIOStatistics(tags map[string]string)

func InitPerfStatistics 

func InitPerfStatistics(tags map[string]string)

func InitRuntimeStatistics 

func InitRuntimeStatistics(tags map[string]string, interval int)

func InitSlowQueryStatistics 

func InitSlowQueryStatistics(tags map[string]string)

func InitSpdyStatistics 

func InitSpdyStatistics(tags map[string]string)

func InitStoreSlowQueryStatistics added in v1.2.0 

func InitStoreSlowQueryStatistics(tags map[string]string)

func MetaDBPTStepDuration added in v1.0.0 

func MetaDBPTStepDuration(event string, opId uint64, step string, src, dst uint64, d int64, status LoadStatus, errMsg string)

func MetaDBPTTaskInit added in v1.0.0 

func MetaDBPTTaskInit(opId uint64, db string, ptId uint32)

func MicroTimeUse added in v1.4.0 

func MicroTimeUse(count, sum *ItemInt64) func()

func MilliTimeUse added in v1.4.0 

func MilliTimeUse(count, sum *ItemInt64) func()

func SetVersion added in v1.3.0 

func SetVersion(v string)

func ShardStepDuration added in v1.0.0 

func ShardStepDuration(sid uint64, opId uint64, step string, cost int64, isOver bool)

func ShardTaskInit added in v1.0.0 

func ShardTaskInit(opId uint64, db string, ptId uint32, rp string, sid uint64)

func UpdateEngineStatS 

func UpdateEngineStatS()

Types

type Accumulator 

type Accumulator interface {
	Push(interface{})
	Increase()
	Decrease()
	Count() interface{}
	Sum() interface{}
	Last() interface{}
}

type BaseCollector added in v1.4.0 

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

func (*BaseCollector) Enabled added in v1.4.0 

func (bc *BaseCollector) Enabled() *bool

type BaseStatistics 

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

func (*BaseStatistics) Init 

func (bs *BaseStatistics) Init(derived Statistics)

type CollectSupported added in v1.4.0 

type CollectSupported interface {
	Enabled() *bool
}

type Collector added in v1.4.0 

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

func NewCollector added in v1.4.0 

func NewCollector() *Collector

func (*Collector) Collect added in v1.4.0 

func (c *Collector) Collect(dst []byte) ([]byte, error)

func (*Collector) CollectOps added in v1.4.1 

func (c *Collector) CollectOps() []opsStat.OpsStatistic

func (*Collector) Register added in v1.4.0 

func (c *Collector) Register(obj CollectSupported)

Register objects that can be collected It should be called during program initialization, such as the init function

func (*Collector) SetGlobalTags added in v1.4.0 

func (c *Collector) SetGlobalTags(tags map[string]string)

type CollectorProxy added in v1.4.0 

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

func (*CollectorProxy) AddItem added in v1.4.0 

func (c *CollectorProxy) AddItem(i Item)

func (*CollectorProxy) Enabled added in v1.4.0 

func (c *CollectorProxy) Enabled() bool

func (*CollectorProxy) GetItems added in v1.4.0 

func (c *CollectorProxy) GetItems() []Item

func (*CollectorProxy) GetMst added in v1.4.0 

func (c *CollectorProxy) GetMst() string

func (*CollectorProxy) GetTags added in v1.4.0 

func (c *CollectorProxy) GetTags() map[string]string

func (*CollectorProxy) SetMst added in v1.4.0 

func (c *CollectorProxy) SetMst(mst string)

func (*CollectorProxy) SetTags added in v1.4.0 

func (c *CollectorProxy) SetTags(tags map[string]string)

type CompactStatItem 

type CompactStatItem struct {
	Level uint16
	Full  bool

	// File information before compact
	OriginalFileCount int64
	OriginalFileSize  int64

	// File information after compact
	CompactedFileCount int64
	CompactedFileSize  int64
	// contains filtered or unexported fields
}

func NewCompactStatItem 

func NewCompactStatItem(mst string, shardID uint64) *CompactStatItem

func (*CompactStatItem) Duration 

func (i *CompactStatItem) Duration() time.Duration

type CompactStatistics 

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

func NewCompactStatistics 

func NewCompactStatistics() *CompactStatistics

func (*CompactStatistics) AddActive 

func (s *CompactStatistics) AddActive(i int64)

func (*CompactStatistics) AddErrors 

func (s *CompactStatistics) AddErrors(i int64)

func (*CompactStatistics) AddMaxMemoryUsed 

func (s *CompactStatistics) AddMaxMemoryUsed(i int64)

func (*CompactStatistics) AddRecordPoolGetTotal 

func (s *CompactStatistics) AddRecordPoolGetTotal(i int64)

func (*CompactStatistics) AddRecordPoolHitTotal 

func (s *CompactStatistics) AddRecordPoolHitTotal(i int64)

func (*CompactStatistics) Collect 

func (s *CompactStatistics) Collect(buffer []byte) ([]byte, error)

func (*CompactStatistics) CollectOps added in v1.0.0 

func (s *CompactStatistics) CollectOps() []opsStat.OpsStatistic

func (*CompactStatistics) Init 

func (s *CompactStatistics) Init(tags map[string]string)

func (*CompactStatistics) PushCompaction 

func (s *CompactStatistics) PushCompaction(item *CompactStatItem)

func (*CompactStatistics) SetActive 

func (s *CompactStatistics) SetActive(i int64)

type DBPTStatistics added in v1.0.0 

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

type DBStatistics 

type DBStatistics struct {
	Mu    sync.RWMutex
	Stats map[string]*DBStats
}

Statistics keeps statistics related to the Database

func NewDBStatistics 

func NewDBStatistics() *DBStatistics

func (*DBStatistics) SetMeasurementsNum 

func (db *DBStatistics) SetMeasurementsNum(database string, num int64)

func (*DBStatistics) SetSeriesNum 

func (db *DBStatistics) SetSeriesNum(database string, recentNum, historyNum int64)

type DBStats 

type DBStats struct {
	NumMeasurements  int64
	NumRecentSeries  int64
	NumHistorySeries int64
}

type DownSampleStatItem added in v1.0.0 

type DownSampleStatItem struct {
	Level               int64
	OriginalFileCount   int64
	OriginalFileSize    int64
	DownSampleFileCount int64
	DownSampleFileSize  int64

	ShardID string
	TaskID  string
	// contains filtered or unexported fields
}

func NewDownSampleStatItem added in v1.0.0 

func NewDownSampleStatItem(shardID uint64, taskID uint64) *DownSampleStatItem

func (*DownSampleStatItem) Duration added in v1.0.0 

func (s *DownSampleStatItem) Duration() int64

func (*DownSampleStatItem) Push added in v1.0.0 

func (s *DownSampleStatItem) Push()

func (*DownSampleStatItem) Tags added in v1.0.0 

func (s *DownSampleStatItem) Tags() map[string]string

func (*DownSampleStatItem) Validate added in v1.0.0 

func (s *DownSampleStatItem) Validate() bool

func (*DownSampleStatItem) Values added in v1.0.0 

func (s *DownSampleStatItem) Values() map[string]interface{}

type DownSampleStatistics added in v1.0.0 

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

func NewDownSampleStatistics added in v1.0.0 

func NewDownSampleStatistics() *DownSampleStatistics

func (*DownSampleStatistics) AddActive added in v1.0.0 

func (s *DownSampleStatistics) AddActive(i int64)

func (*DownSampleStatistics) AddErrors added in v1.0.0 

func (s *DownSampleStatistics) AddErrors(i int64)

func (*DownSampleStatistics) Collect added in v1.0.0 

func (s *DownSampleStatistics) Collect(buffer []byte) ([]byte, error)

func (*DownSampleStatistics) CollectOps added in v1.0.0 

func (s *DownSampleStatistics) CollectOps() []opsStat.OpsStatistic

func (*DownSampleStatistics) Init added in v1.0.0 

func (s *DownSampleStatistics) Init(tags map[string]string)

func (*DownSampleStatistics) Push added in v1.0.0 

func (s *DownSampleStatistics) Push(item *DownSampleStatItem)

type EngineStatus 

type EngineStatus struct {
	OpenErrors     int64
	OpenDurations  int64
	CloseErrors    int64
	CloseDurations int64

	DelShardErr      int64
	DelShardCount    int64
	DelShardDuration int64

	DelIndexErr      int64
	DelIndexCount    int64
	DelIndexDuration int64

	DropDatabaseErrs      int64
	DropDatabaseCount     int64
	DropDatabaseDurations int64

	DropMstErrs      int64
	DropMstCount     int64
	DropMstDurations int64

	DropRPErrs      int64
	DropRPCount     int64
	DropRPDurations int64

	Updated int64
}

type ErrnoStat 

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

func NewErrnoStat 

func NewErrnoStat() *ErrnoStat

func (*ErrnoStat) Add 

func (s *ErrnoStat) Add(code string)

func (*ErrnoStat) Collect 

func (s *ErrnoStat) Collect(buf []byte) ([]byte, error)

func (*ErrnoStat) CollectOps added in v1.0.0 

func (s *ErrnoStat) CollectOps() []opsStat.OpsStatistic

func (*ErrnoStat) Init 

func (s *ErrnoStat) Init(tags map[string]string)

type ExecutorStatistics 

type ExecutorStatistics struct {
	BaseStatistics
	ExecRunTime      Accumulator
	TransWaitTime    Accumulator
	TransRunTime     Accumulator
	DagEdge          Accumulator
	DagVertex        Accumulator
	ExecScheduled    Accumulator
	ExecTimeout      Accumulator
	ExecAbort        Accumulator
	ExecFailed       Accumulator
	TransFailed      Accumulator
	TransAbort       Accumulator
	TransFailedAbort Accumulator
	ColumnLength     Accumulator
	ColumnWidth      Accumulator
	SourceLength     Accumulator
	SourceWidth      Accumulator
	SinkLength       Accumulator
	SinkWidth        Accumulator
	SourceRows       Accumulator
	FilterRows       Accumulator
	AggRows          Accumulator
	MergeRows        Accumulator
	LimitRows        Accumulator
	FillRows         Accumulator
	MaterRows        Accumulator
	SinkRows         Accumulator
	// contains filtered or unexported fields
}

func NewExecutorStatistics 

func NewExecutorStatistics() *ExecutorStatistics

func (*ExecutorStatistics) AssignName 

func (es *ExecutorStatistics) AssignName()

func (*ExecutorStatistics) BuildAccumulator 

func (es *ExecutorStatistics) BuildAccumulator()

func (*ExecutorStatistics) Report 

func (es *ExecutorStatistics) Report() map[string]interface{}

type FileStat 

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

func NewFileStat 

func NewFileStat() *FileStat

func (*FileStat) AddLevel 

func (s *FileStat) AddLevel(level uint16, size int64)

func (*FileStat) AddMst 

func (s *FileStat) AddMst(mst string, count int, size int64)

type FileStatItem 

type FileStatItem struct {
	FileCount int
	FileSize  int64
}

func NewFileStatItem 

func NewFileStatItem(count int, size int64) *FileStatItem

func (*FileStatItem) Add 

func (s *FileStatItem) Add(count int, size int64)

type FileStatistics 

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

func NewFileStatistics 

func NewFileStatistics() *FileStatistics

func (*FileStatistics) Collect 

func (s *FileStatistics) Collect(buffer []byte, originTags map[string]string, fileStat *FileStat) ([]byte, error)

func (*FileStatistics) CollectLevel 

func (s *FileStatistics) CollectLevel(buffer []byte, originTags map[string]string, fileStat map[uint16]*FileStatItem) ([]byte, error)

func (*FileStatistics) CollectMst 

func (s *FileStatistics) CollectMst(buffer []byte, originTags map[string]string, mstFileStat map[string]*FileStatItem) ([]byte, error)

type Handler added in v1.4.1 

type Handler struct {
	BaseCollector

	Requests                     *ItemInt64 `name:"req"`                     // Number of HTTP requests served.
	QueryStmtCount               *ItemInt64 `name:"queryReq"`                // Number of query requests served.
	Query400ErrorStmtCount       *ItemInt64 `name:"queryStmtCount"`          // Number of query stmt served.
	QueryErrorStmtCount          *ItemInt64 `name:"query400ErrorStmtCount"`  // Number of query stmt occur 400(client) error.
	QueryRequests                *ItemInt64 `name:"queryErrorStmtCount"`     // Number of query stmt occur not 400 error.
	WriteRequests                *ItemInt64 `name:"writeReq"`                // Number of write requests serverd.
	Write400ErrRequests          *ItemInt64 `name:"write400ErrReq"`          // Number of write 400 requests occur error.
	Write500ErrRequests          *ItemInt64 `name:"write500ErrReq"`          // Number of write 500 requests occur error.
	PingRequests                 *ItemInt64 `name:"pingReq"`                 // Number of ping requests served.
	StatusRequests               *ItemInt64 `name:"statusReq"`               // Number of status requests served.
	WriteRequestBytesReceived    *ItemInt64 `name:"writeReqBytesIn"`         // Sum of all bytes in write requests.
	WriteRequestBytesIn          *ItemInt64 `name:"writeReqBytes"`           // Sum of all bytes in write requests written success.
	QueryRequestBytesTransmitted *ItemInt64 `name:"queryRespBytes"`          // Sum of all bytes returned in query reponses.
	PointsWrittenOK              *ItemInt64 `name:"pointsWrittenOK"`         // Number of points written OK.
	FieldsWritten                *ItemInt64 `name:"fieldsWritten"`           // Number of fields written.
	PointsWrittenDropped         *ItemInt64 `name:"pointsWrittenDropped"`    // Number of points dropped by the storage engine.
	PointsWrittenFail            *ItemInt64 `name:"pointsWrittenFail"`       // Number of points that failed to be written.
	AuthenticationFailures       *ItemInt64 `name:"authFail"`                // Number of authentication failures.
	RequestDuration              *ItemInt64 `name:"reqDurationNs"`           // Number of (wall-time) nanoseconds spent inside requests.
	WriteRequestParseDuration    *ItemInt64 `name:"writeReqParseDurationNs"` // Number of (wall-time) nanoseconds spent parse write requests.
	QueryRequestDuration         *ItemInt64 `name:"queryReqDurationNs"`      // Number of (wall-time) nanoseconds spent inside query requests.
	WriteRequestDuration         *ItemInt64 `name:"writeReqDurationNs"`      // Number of (wall-time) nanoseconds spent inside write requests.
	ActiveRequests               *ItemInt64 `name:"reqActive"`               // Number of currently active requests.
	ActiveWriteRequests          *ItemInt64 `name:"writeReqActive"`          // Number of currently active write requests.
	ActiveQueryRequests          *ItemInt64 `name:"queryReqActive"`          // Number of currently active query requests.
	ClientErrors                 *ItemInt64 `name:"clientError"`             // Number of HTTP responses due to client error.
	ServerErrors                 *ItemInt64 `name:"serverError"`             // Number of HTTP responses due to server error.
	RecoveredPanics              *ItemInt64 `name:"recoveredPanics"`         // Number of panics recovered by HTTP handler.
	WriteScheduleUnMarshalDns    *ItemInt64 `name:"scheduleUnmarshalDns"`    // Schedule unmarshal durations
	WriteCreateMstDuration       *ItemInt64 `name:"writeCreateMstDurationNs"`
	WriteUpdateSchemaDuration    *ItemInt64 `name:"writeUpdateSchemaDurationNs"`
	WriteCreateSgDuration        *ItemInt64 `name:"writeCreateSgDurationNs"`
	WriteUnmarshalSkDuration     *ItemInt64 `name:"writeUnmarshalSkDurationNs"`
	WriteStoresDuration          *ItemInt64 `name:"writeStoresDurationNs"`
	WriteUpdateIndexDuration     *ItemInt64 `name:"WriteUpdateIndexDurationNs"`
	WriteMapRowsDuration         *ItemInt64 `name:"WriteMapRowsDurationNs"`
	WriteStreamRoutineDuration   *ItemInt64 `name:"WriteStreamRoutineDurationNs"`
	ConnectionNums               *ItemInt64 `name:"connectionNums"` // Number of current connections"storeQueryReq"`
}

func NewHandler added in v1.4.1 

func NewHandler() *Handler

func (*Handler) MeasurementName added in v1.4.1 

func (s *Handler) MeasurementName() string

type HitRatioItem added in v1.4.0 

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

func (*HitRatioItem) GetTotal added in v1.4.0 

func (item *HitRatioItem) GetTotal() int64

func (*HitRatioItem) HitTotal added in v1.4.0 

func (item *HitRatioItem) HitTotal() int64

func (*HitRatioItem) Stat added in v1.4.0 

func (item *HitRatioItem) Stat(hit bool)

type HitRatioStatistics added in v1.1.0 

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

func NewHitRatioStatistics added in v1.1.0 

func NewHitRatioStatistics() *HitRatioStatistics

func (*HitRatioStatistics) AddFileOpenTotal added in v1.1.0 

func (s *HitRatioStatistics) AddFileOpenTotal(i int64)

func (*HitRatioStatistics) AddIndexWriterGetTotal added in v1.1.0 

func (s *HitRatioStatistics) AddIndexWriterGetTotal(i int64)

func (*HitRatioStatistics) AddIndexWriterHitTotal added in v1.1.0 

func (s *HitRatioStatistics) AddIndexWriterHitTotal(i int64)

func (*HitRatioStatistics) AddMergeColValGetTotal added in v1.1.0 

func (s *HitRatioStatistics) AddMergeColValGetTotal(i int64)

func (*HitRatioStatistics) AddMergeColValHitTotal added in v1.1.0 

func (s *HitRatioStatistics) AddMergeColValHitTotal(i int64)

func (*HitRatioStatistics) AddQueryFileUnHitTotal added in v1.1.0 

func (s *HitRatioStatistics) AddQueryFileUnHitTotal(i int64)

func (*HitRatioStatistics) AddSeriesKeyToTSIDCacheGetMissTotal added in v1.3.0 

func (s *HitRatioStatistics) AddSeriesKeyToTSIDCacheGetMissTotal(i int64)

func (*HitRatioStatistics) AddSeriesKeyToTSIDCacheGetNewSeriesTotal added in v1.3.0 

func (s *HitRatioStatistics) AddSeriesKeyToTSIDCacheGetNewSeriesTotal(i int64)

func (*HitRatioStatistics) AddSeriesKeyToTSIDCacheGetTotal added in v1.3.0 

func (s *HitRatioStatistics) AddSeriesKeyToTSIDCacheGetTotal(i int64)

func (*HitRatioStatistics) Collect added in v1.1.0 

func (s *HitRatioStatistics) Collect(buffer []byte) ([]byte, error)

func (*HitRatioStatistics) CollectOps added in v1.1.0 

func (s *HitRatioStatistics) CollectOps() []opsStat.OpsStatistic

func (*HitRatioStatistics) Init added in v1.1.0 

func (s *HitRatioStatistics) Init(tags map[string]string)

func (*HitRatioStatistics) Register added in v1.4.0 

func (s *HitRatioStatistics) Register(name string) *HitRatioItem

type HotMode added in v1.4.0 

type HotMode struct {
	BaseCollector

	TotalMemorySize *ItemInt64
	ReadTotal       *ItemInt64
	ReadBytesTotal  *ItemInt64
}

func NewHotMode added in v1.4.0 

func NewHotMode() *HotMode

type IOStatistics 

type IOStatistics struct {
	IOWriteTotalCount  int64
	IOWriteActiveCount int64
	IOWriteOkCount     int64
	IOWriteTotalBytes  int64
	IOWriteActiveBytes int64
	IOWriteOkBytes     int64
	IOWriteDuration    int64

	IOReadTotalCount     int64
	IOReadActiveCount    int64
	IOReadOkCount        int64
	IOReadTotalBytes     int64
	IOReadActiveBytes    int64
	IOReadOkBytes        int64
	IOReadDuration       int64
	IOReadCacheCount     int64
	IOReadCacheRatio     int64
	IOReadCacheMem       int64
	IOReadCacheCapMem    int64
	IOReadPageCacheCount int64
	IOReadPageCacheRatio int64
	IOReadPageCacheMem   int64
	IOReadMetaPageNum    int64
	IOReadMetaPoolSize   int64

	IOSyncTotalCount  int64
	IOSyncActiveCount int64
	IOSyncOkCount     int64
	IOSyncDuration    int64

	IOSnapshotCount int64
	IOSnapshotBytes int64

	IOFrontReadOkCount  int64
	IOFrontReadOkBytes  int64
	IOFrontReadDuration int64

	IOFrontIndexReadOkCount  int64
	IOFrontIndexReadOkBytes  int64
	IOFrontIndexReadDuration int64

	IOBackReadOkCount  int64
	IOBackReadOkBytes  int64
	IOBackReadDuration int64

	IOReadMetaCounts []int64
	IOReadMetaSizes  []int64
	IOReadDataCounts []int64
	IOReadDataSizes  []int64
}

func NewIOStatistics 

func NewIOStatistics() *IOStatistics

func (*IOStatistics) AddIOSnapshotBytes 

func (s *IOStatistics) AddIOSnapshotBytes(i int64)

func (*IOStatistics) AddReadDataCount added in v1.2.0 

func (s *IOStatistics) AddReadDataCount(size uint32)

func (*IOStatistics) AddReadDataSize added in v1.2.0 

func (s *IOStatistics) AddReadDataSize(size uint32)

func (*IOStatistics) AddReadMetaCount added in v1.2.0 

func (s *IOStatistics) AddReadMetaCount(size uint32)

func (*IOStatistics) AddReadMetaSize added in v1.2.0 

func (s *IOStatistics) AddReadMetaSize(size uint32)

type IndexFileStat added in v1.4.1 

type IndexFileStat struct {
	BaseCollector

	IndexFileTotal *ItemInt64
}

func NewIndexFileStat added in v1.4.1 

func NewIndexFileStat() *IndexFileStat

type IndexStatistics added in v1.0.0 

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

type Int64Accumulator 

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

func (*Int64Accumulator) Count 

func (a *Int64Accumulator) Count() interface{}

func (*Int64Accumulator) Decrease 

func (a *Int64Accumulator) Decrease()

func (*Int64Accumulator) Increase 

func (a *Int64Accumulator) Increase()

func (*Int64Accumulator) Last 

func (a *Int64Accumulator) Last() interface{}

func (*Int64Accumulator) Push 

func (a *Int64Accumulator) Push(data interface{})

func (*Int64Accumulator) Sum 

func (a *Int64Accumulator) Sum() interface{}

type Item added in v1.4.0 

type Item interface {
	SetName(string)
	GetName() string
	GetValue() any
}

type ItemInt64 added in v1.4.0 

type ItemInt64 struct {
	atomic.Int64
	// contains filtered or unexported fields
}

func (*ItemInt64) AddSinceNano added in v1.4.1 

func (i *ItemInt64) AddSinceNano(begin time.Time)

func (*ItemInt64) Decr added in v1.4.0 

func (i *ItemInt64) Decr()

func (*ItemInt64) GetName added in v1.4.0 

func (i *ItemInt64) GetName() string

func (*ItemInt64) GetValue added in v1.4.0 

func (i *ItemInt64) GetValue() any

func (*ItemInt64) Incr added in v1.4.0 

func (i *ItemInt64) Incr()

func (*ItemInt64) SetName added in v1.4.0 

func (i *ItemInt64) SetName(name string)

type LoadStatus added in v1.0.0 

type LoadStatus int
const (
	DBPTLoading LoadStatus = iota
	DBPTLoaded
	DBPTLoadErr
)

type LogKeeperStatItem added in v1.2.0 

type LogKeeperStatItem struct {
	ObsReadDataSize   int64
	ObsStoreDataSize  int64
	QueryRequestCount int64
	WriteRequestSize  int64
	WriteRequestCount int64

	LogStreamId string
	RepoId      string

	Begin time.Time
	// contains filtered or unexported fields
}

func NewLogKeeperStatItem added in v1.2.0 

func NewLogKeeperStatItem(RepoId string, LogStreamId string) *LogKeeperStatItem

func (*LogKeeperStatItem) Duration added in v1.2.0 

func (s *LogKeeperStatItem) Duration() int64

func (*LogKeeperStatItem) Push added in v1.2.0 

func (s *LogKeeperStatItem) Push()

func (*LogKeeperStatItem) Tags added in v1.2.0 

func (s *LogKeeperStatItem) Tags() map[string]string

func (*LogKeeperStatItem) Validate added in v1.2.0 

func (s *LogKeeperStatItem) Validate() bool

func (*LogKeeperStatItem) Values added in v1.2.0 

func (s *LogKeeperStatItem) Values() (map[string]interface{}, map[string]interface{})

type LogKeeperStatistics added in v1.2.0 

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

func NewLogKeeperStatistics added in v1.2.0 

func NewLogKeeperStatistics() *LogKeeperStatistics

func (*LogKeeperStatistics) AddTotalObsReadDataSize added in v1.2.0 

func (s *LogKeeperStatistics) AddTotalObsReadDataSize(i int64)

func (*LogKeeperStatistics) AddTotalQueryRequestCount added in v1.2.0 

func (s *LogKeeperStatistics) AddTotalQueryRequestCount(i int64)

func (*LogKeeperStatistics) AddTotalWriteRequestCount added in v1.2.0 

func (s *LogKeeperStatistics) AddTotalWriteRequestCount(i int64)

func (*LogKeeperStatistics) AddTotalWriteRequestSize added in v1.2.0 

func (s *LogKeeperStatistics) AddTotalWriteRequestSize(i int64)

func (*LogKeeperStatistics) Collect added in v1.2.0 

func (s *LogKeeperStatistics) Collect(buffer []byte) ([]byte, error)

func (*LogKeeperStatistics) CollectOps added in v1.2.0 

func (s *LogKeeperStatistics) CollectOps() []opsStat.OpsStatistic

func (*LogKeeperStatistics) Init added in v1.2.0 

func (s *LogKeeperStatistics) Init(tags map[string]string)

func (*LogKeeperStatistics) Push added in v1.2.0 

func (s *LogKeeperStatistics) Push(item *LogKeeperStatItem)

type MeasurementSupported added in v1.4.1 

type MeasurementSupported interface {
	MeasurementName() string
}

type MergeStatItem 

type MergeStatItem struct {
	OutOfOrderFileCount  int64
	OutOfOrderFileSize   int64
	OrderFileCount       int64
	OrderFileSize        int64
	MergedFileCount      int64
	MergedFileSize       int64
	OrderSeriesCount     int64
	IntersectSeriesCount int64

	Measurement string
	ShardID     string
	// contains filtered or unexported fields
}

func NewMergeStatItem 

func NewMergeStatItem(mst string, shId uint64) *MergeStatItem

func (*MergeStatItem) Duration 

func (s *MergeStatItem) Duration() int64

func (*MergeStatItem) Push 

func (s *MergeStatItem) Push()

func (*MergeStatItem) StatMergedFile 

func (s *MergeStatItem) StatMergedFile(size int64, num int)

func (*MergeStatItem) StatOrderFile 

func (s *MergeStatItem) StatOrderFile(size int64, num int)

func (*MergeStatItem) StatOutOfOrderFile 

func (s *MergeStatItem) StatOutOfOrderFile(size int64, num int)

func (*MergeStatItem) Tags 

func (s *MergeStatItem) Tags() map[string]string

func (*MergeStatItem) Validate 

func (s *MergeStatItem) Validate() bool

func (*MergeStatItem) Values 

func (s *MergeStatItem) Values() map[string]interface{}

type MergeStatistics 

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

func NewMergeStatistics 

func NewMergeStatistics() *MergeStatistics

func (*MergeStatistics) AddActive 

func (s *MergeStatistics) AddActive(i int64)

func (*MergeStatistics) AddCurrentOutOfOrderFile 

func (s *MergeStatistics) AddCurrentOutOfOrderFile(i int64)

func (*MergeStatistics) AddErrors 

func (s *MergeStatistics) AddErrors(i int64)

func (*MergeStatistics) AddMergeSelfTotal added in v1.0.0 

func (s *MergeStatistics) AddMergeSelfTotal(i int64)

func (*MergeStatistics) AddSkipTotal added in v1.0.0 

func (s *MergeStatistics) AddSkipTotal(i int64)

func (*MergeStatistics) Collect 

func (s *MergeStatistics) Collect(buffer []byte) ([]byte, error)

func (*MergeStatistics) CollectOps added in v1.0.0 

func (s *MergeStatistics) CollectOps() []opsStat.OpsStatistic

func (*MergeStatistics) Init 

func (s *MergeStatistics) Init(tags map[string]string)

func (*MergeStatistics) Push 

func (s *MergeStatistics) Push(item *MergeStatItem)

func (*MergeStatistics) SetCurrentOutOfOrderFile 

func (s *MergeStatistics) SetCurrentOutOfOrderFile(i int64)

type MetaRaftStatItem 

type MetaRaftStatItem struct {
	Status int64

	NodeID string
	// contains filtered or unexported fields
}

func (*MetaRaftStatItem) Key 

func (s *MetaRaftStatItem) Key() string

func (*MetaRaftStatItem) Push 

func (s *MetaRaftStatItem) Push()

func (*MetaRaftStatItem) Tags 

func (s *MetaRaftStatItem) Tags() map[string]string

func (*MetaRaftStatItem) Validate 

func (s *MetaRaftStatItem) Validate() bool

func (*MetaRaftStatItem) Values 

func (s *MetaRaftStatItem) Values() map[string]interface{}

type MetaRaftStatistics 

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

func NewMetaRaftStatistics 

func NewMetaRaftStatistics() *MetaRaftStatistics

func (*MetaRaftStatistics) Addfoo 

func (s *MetaRaftStatistics) Addfoo(i int64)

func (*MetaRaftStatistics) Collect 

func (s *MetaRaftStatistics) Collect(buffer []byte) ([]byte, error)

func (*MetaRaftStatistics) CollectOps added in v1.0.0 

func (s *MetaRaftStatistics) CollectOps() []opsStat.OpsStatistic

func (*MetaRaftStatistics) Init 

func (s *MetaRaftStatistics) Init(tags map[string]string)

func (*MetaRaftStatistics) Push 

func (s *MetaRaftStatistics) Push(item *MetaRaftStatItem)

type MetaStatCollector 

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

func NewMetaStatCollector 

func NewMetaStatCollector() *MetaStatCollector

func (*MetaStatCollector) Clear 

func (c *MetaStatCollector) Clear(typ string)

func (*MetaStatCollector) Collect 

func (c *MetaStatCollector) Collect(d time.Duration)

func (*MetaStatCollector) Items 

func (c *MetaStatCollector) Items() map[string]StatItem

func (*MetaStatCollector) Push 

func (c *MetaStatCollector) Push(item StatItem)

func (*MetaStatCollector) Stop 

func (c *MetaStatCollector) Stop()

type MetaStatItem 

type MetaStatItem struct {
	Status int64
	LTime  int64

	NodeID string
	Host   string
	// contains filtered or unexported fields
}

func (*MetaStatItem) Key 

func (s *MetaStatItem) Key() string

func (*MetaStatItem) Push 

func (s *MetaStatItem) Push()

func (*MetaStatItem) Tags 

func (s *MetaStatItem) Tags() map[string]string

func (*MetaStatItem) Validate 

func (s *MetaStatItem) Validate() bool

func (*MetaStatItem) Values 

func (s *MetaStatItem) Values() map[string]interface{}

type MetaStatistics 

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

func NewMetaStatistics 

func NewMetaStatistics() *MetaStatistics

func (*MetaStatistics) AddGetFromDataMarshalLenTotal added in v1.3.0 

func (s *MetaStatistics) AddGetFromDataMarshalLenTotal(i int64)

func (*MetaStatistics) AddGetFromDataMarshalTotal added in v1.3.0 

func (s *MetaStatistics) AddGetFromDataMarshalTotal(i int64)

func (*MetaStatistics) AddGetFromOpsMapLenTotal added in v1.3.0 

func (s *MetaStatistics) AddGetFromOpsMapLenTotal(i int64)

func (*MetaStatistics) AddGetFromOpsMapTotal added in v1.3.0 

func (s *MetaStatistics) AddGetFromOpsMapTotal(i int64)

func (*MetaStatistics) AddLeaderSwitchTotal 

func (s *MetaStatistics) AddLeaderSwitchTotal(i int64)

func (*MetaStatistics) AddSnapshotDataSize 

func (s *MetaStatistics) AddSnapshotDataSize(i int64)

func (*MetaStatistics) AddSnapshotTotal 

func (s *MetaStatistics) AddSnapshotTotal(i int64)

func (*MetaStatistics) AddSnapshotUnmarshalDuration 

func (s *MetaStatistics) AddSnapshotUnmarshalDuration(i int64)

func (*MetaStatistics) AddStoreApplyTotal 

func (s *MetaStatistics) AddStoreApplyTotal(i int64)

func (*MetaStatistics) Collect 

func (s *MetaStatistics) Collect(buffer []byte) ([]byte, error)

func (*MetaStatistics) CollectOps added in v1.0.0 

func (s *MetaStatistics) CollectOps() []opsStat.OpsStatistic

func (*MetaStatistics) Init 

func (s *MetaStatistics) Init(tags map[string]string)

func (*MetaStatistics) Push 

func (s *MetaStatistics) Push(item *MetaStatItem)

type MetaTaskDuration added in v1.0.0 

type MetaTaskDuration struct {
	// contains filtered or unexported fields
}
var MetaTaskInstance *MetaTaskDuration

func NewMetaTaskDuration added in v1.0.0 

func NewMetaTaskDuration(enable bool) *MetaTaskDuration

func (*MetaTaskDuration) Collect added in v1.0.0 

func (s *MetaTaskDuration) Collect(buffer []byte) ([]byte, error)

type MetadataMetrics added in v1.0.0 

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

type MetadataStatistics added in v1.0.0 

type MetadataStatistics struct {
	// contains filtered or unexported fields
}
var MetadataInstance *MetadataStatistics

MetadataInstance save metadata statistics for getdata endpoint

func NewMetadataStatistics added in v1.0.0 

func NewMetadataStatistics(enable bool) *MetadataStatistics

func (*MetadataStatistics) Collect added in v1.0.0 

func (s *MetadataStatistics) Collect(buffer []byte) ([]byte, error)

func (*MetadataStatistics) HaveMetadata added in v1.0.0 

func (s *MetadataStatistics) HaveMetadata() bool

func (*MetadataStatistics) SaveMetadataNodes added in v1.0.0 

func (s *MetadataStatistics) SaveMetadataNodes(category string, hostname string, id uint64, status int64)

func (*MetadataStatistics) SaveMetadataParam added in v1.0.0 

func (s *MetadataStatistics) SaveMetadataParam(category string, takeOverEnabled, balancerEnabled bool, ptNumPerNode int64)

type Metric added in v1.3.0 

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

func (*Metric) Init added in v1.3.0 

func (m *Metric) Init(tags map[string]string)

type NamedAccumulator 

type NamedAccumulator interface {
	NamedCount() (string, interface{})
	NamedSum() (string, interface{})
	NamedLast() (string, interface{})
}

type NamedInt64Accumulator 

type NamedInt64Accumulator struct {
	Int64Accumulator
	// contains filtered or unexported fields
}

func NewNamedInt64Accumulator 

func NewNamedInt64Accumulator(name string) *NamedInt64Accumulator

func (*NamedInt64Accumulator) NamedCount 

func (n *NamedInt64Accumulator) NamedCount() (string, interface{})

func (*NamedInt64Accumulator) NamedLast 

func (n *NamedInt64Accumulator) NamedLast() (string, interface{})

func (*NamedInt64Accumulator) NamedSum 

func (n *NamedInt64Accumulator) NamedSum() (string, interface{})

type OOOTimeDistribution added in v1.3.0 

type OOOTimeDistribution struct {
	Metric
	// contains filtered or unexported fields
}

func NewOOOTimeDistribution added in v1.3.0 

func NewOOOTimeDistribution() *OOOTimeDistribution

func (*OOOTimeDistribution) Add added in v1.3.0 

func (d *OOOTimeDistribution) Add(interval int64, n int64)

func (*OOOTimeDistribution) Collect added in v1.3.0 

func (d *OOOTimeDistribution) Collect(buffer []byte) ([]byte, error)

type PerfStatistics 

type PerfStatistics struct {
	WriteActiveRequests      int64
	WriteUnmarshalNs         int64
	WriteStorageDurationNs   int64
	WriteSortIndexDurationNs int64
	WriteIndexDurationNs     int64
	WriteGetTokenDurationNs  int64
	WriteWalDurationNs       int64
	WriteRowsDurationNs      int64
	WriteFieldsCount         int64
	WriteRowsCount           int64
	WriteRowsBatch           int64
	WriteReqErrors           int64
	FlushRowsCount           int64
	FlushOrderRowsCount      int64
	FlushUnOrderRowsCount    int64
	FlushSnapshotCount       int64
	FlushSnapshotDurationNs  int64
	SnapshotHandleChunksNs   int64
	SnapshotSortChunksNs     int64
	SnapshotFlushChunksNs    int64
	WriteCreateShardNs       int64
	WriteGetMstInfoNs        int64
	WriteMstInfoNs           int64
	WriteShardKeyIdxNs       int64
	WriteAddSidRowCountNs    int64
}

Statistics keeps statistics related to the Performance

func NewPerfStatistics 

func NewPerfStatistics() *PerfStatistics

type RecordStatistics added in v1.0.0 

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

func NewRecordStatistics added in v1.0.0 

func NewRecordStatistics() *RecordStatistics

func (*RecordStatistics) AddAggPoolAbort added in v1.0.0 

func (s *RecordStatistics) AddAggPoolAbort(i int64)

func (*RecordStatistics) AddAggPoolGet added in v1.0.0 

func (s *RecordStatistics) AddAggPoolGet(i int64)

func (*RecordStatistics) AddAggPoolGetReUse added in v1.0.0 

func (s *RecordStatistics) AddAggPoolGetReUse(i int64)

func (*RecordStatistics) AddAggPoolInUse added in v1.0.0 

func (s *RecordStatistics) AddAggPoolInUse(i int64)

func (*RecordStatistics) AddCircularRecordPool added in v1.0.0 

func (s *RecordStatistics) AddCircularRecordPool(i int64)

func (*RecordStatistics) AddFileCursorFilterRecordPoolAbort added in v1.2.0 

func (s *RecordStatistics) AddFileCursorFilterRecordPoolAbort(i int64)

func (*RecordStatistics) AddFileCursorFilterRecordPoolGet added in v1.2.0 

func (s *RecordStatistics) AddFileCursorFilterRecordPoolGet(i int64)

func (*RecordStatistics) AddFileCursorFilterRecordPoolGetReUse added in v1.2.0 

func (s *RecordStatistics) AddFileCursorFilterRecordPoolGetReUse(i int64)

func (*RecordStatistics) AddFileCursorFilterRecordPoolInUse added in v1.2.0 

func (s *RecordStatistics) AddFileCursorFilterRecordPoolInUse(i int64)

func (*RecordStatistics) AddFileCursorPoolAbort added in v1.0.0 

func (s *RecordStatistics) AddFileCursorPoolAbort(i int64)

func (*RecordStatistics) AddFileCursorPoolGet added in v1.0.0 

func (s *RecordStatistics) AddFileCursorPoolGet(i int64)

func (*RecordStatistics) AddFileCursorPoolGetReUse added in v1.0.0 

func (s *RecordStatistics) AddFileCursorPoolGetReUse(i int64)

func (*RecordStatistics) AddFileCursorPoolInUse added in v1.0.0 

func (s *RecordStatistics) AddFileCursorPoolInUse(i int64)

func (*RecordStatistics) AddFileCursorValidRowPoolAbort added in v1.2.0 

func (s *RecordStatistics) AddFileCursorValidRowPoolAbort(i int64)

func (*RecordStatistics) AddFileCursorValidRowPoolGet added in v1.2.0 

func (s *RecordStatistics) AddFileCursorValidRowPoolGet(i int64)

func (*RecordStatistics) AddFileCursorValidRowPoolGetReUse added in v1.2.0 

func (s *RecordStatistics) AddFileCursorValidRowPoolGetReUse(i int64)

func (*RecordStatistics) AddFileCursorValidRowPoolInUse added in v1.2.0 

func (s *RecordStatistics) AddFileCursorValidRowPoolInUse(i int64)

func (*RecordStatistics) AddFileLoopCursorPoolAbort added in v1.2.0 

func (s *RecordStatistics) AddFileLoopCursorPoolAbort(i int64)

func (*RecordStatistics) AddFileLoopCursorPoolGet added in v1.2.0 

func (s *RecordStatistics) AddFileLoopCursorPoolGet(i int64)

func (*RecordStatistics) AddFileLoopCursorPoolGetReUse added in v1.2.0 

func (s *RecordStatistics) AddFileLoopCursorPoolGetReUse(i int64)

func (*RecordStatistics) AddFileLoopCursorPoolInUse added in v1.2.0 

func (s *RecordStatistics) AddFileLoopCursorPoolInUse(i int64)

func (*RecordStatistics) AddIntervalRecordPoolAbort added in v1.0.0 

func (s *RecordStatistics) AddIntervalRecordPoolAbort(i int64)

func (*RecordStatistics) AddIntervalRecordPoolGet added in v1.0.0 

func (s *RecordStatistics) AddIntervalRecordPoolGet(i int64)

func (*RecordStatistics) AddIntervalRecordPoolGetReUse added in v1.0.0 

func (s *RecordStatistics) AddIntervalRecordPoolGetReUse(i int64)

func (*RecordStatistics) AddIntervalRecordPoolInUse added in v1.0.0 

func (s *RecordStatistics) AddIntervalRecordPoolInUse(i int64)

func (*RecordStatistics) AddLogstoreAbort added in v1.3.0 

func (s *RecordStatistics) AddLogstoreAbort(i int64)

func (*RecordStatistics) AddLogstoreGet added in v1.3.0 

func (s *RecordStatistics) AddLogstoreGet(i int64)

func (*RecordStatistics) AddLogstoreInUse added in v1.3.0 

func (s *RecordStatistics) AddLogstoreInUse(i int64)

func (*RecordStatistics) AddLogstoreReUse added in v1.3.0 

func (s *RecordStatistics) AddLogstoreReUse(i int64)

func (*RecordStatistics) AddSequenceAggPoolAbort added in v1.0.0 

func (s *RecordStatistics) AddSequenceAggPoolAbort(i int64)

func (*RecordStatistics) AddSequenceAggPoolGet added in v1.0.0 

func (s *RecordStatistics) AddSequenceAggPoolGet(i int64)

func (*RecordStatistics) AddSequenceAggPoolGetReUse added in v1.0.0 

func (s *RecordStatistics) AddSequenceAggPoolGetReUse(i int64)

func (*RecordStatistics) AddSequenceAggPoolInUse added in v1.0.0 

func (s *RecordStatistics) AddSequenceAggPoolInUse(i int64)

func (*RecordStatistics) AddSeriesLoopPoolAbort added in v1.3.0 

func (s *RecordStatistics) AddSeriesLoopPoolAbort(i int64)

func (*RecordStatistics) AddSeriesLoopPoolGet added in v1.3.0 

func (s *RecordStatistics) AddSeriesLoopPoolGet(i int64)

func (*RecordStatistics) AddSeriesLoopPoolGetReUse added in v1.3.0 

func (s *RecordStatistics) AddSeriesLoopPoolGetReUse(i int64)

func (*RecordStatistics) AddSeriesLoopPoolInUse added in v1.3.0 

func (s *RecordStatistics) AddSeriesLoopPoolInUse(i int64)

func (*RecordStatistics) AddSeriesPoolAbort added in v1.0.0 

func (s *RecordStatistics) AddSeriesPoolAbort(i int64)

func (*RecordStatistics) AddSeriesPoolGet added in v1.0.0 

func (s *RecordStatistics) AddSeriesPoolGet(i int64)

func (*RecordStatistics) AddSeriesPoolGetReUse added in v1.0.0 

func (s *RecordStatistics) AddSeriesPoolGetReUse(i int64)

func (*RecordStatistics) AddSeriesPoolInUse added in v1.0.0 

func (s *RecordStatistics) AddSeriesPoolInUse(i int64)

func (*RecordStatistics) AddTsmMergePoolAbort added in v1.0.0 

func (s *RecordStatistics) AddTsmMergePoolAbort(i int64)

func (*RecordStatistics) AddTsmMergePoolGet added in v1.0.0 

func (s *RecordStatistics) AddTsmMergePoolGet(i int64)

func (*RecordStatistics) AddTsmMergePoolGetReUse added in v1.0.0 

func (s *RecordStatistics) AddTsmMergePoolGetReUse(i int64)

func (*RecordStatistics) AddTsmMergePoolInUse added in v1.0.0 

func (s *RecordStatistics) AddTsmMergePoolInUse(i int64)

func (*RecordStatistics) AddTsspSequencePoolAbort added in v1.0.0 

func (s *RecordStatistics) AddTsspSequencePoolAbort(i int64)

func (*RecordStatistics) AddTsspSequencePoolGet added in v1.0.0 

func (s *RecordStatistics) AddTsspSequencePoolGet(i int64)

func (*RecordStatistics) AddTsspSequencePoolGetReUse added in v1.0.0 

func (s *RecordStatistics) AddTsspSequencePoolGetReUse(i int64)

func (*RecordStatistics) AddTsspSequencePoolInUse added in v1.0.0 

func (s *RecordStatistics) AddTsspSequencePoolInUse(i int64)

func (*RecordStatistics) Collect added in v1.0.0 

func (s *RecordStatistics) Collect(buffer []byte) ([]byte, error)

func (*RecordStatistics) Init added in v1.0.0 

func (s *RecordStatistics) Init(tags map[string]string)

type ResultCache added in v1.4.0 

type ResultCache struct {
	BaseCollector

	CacheTotal        *ItemInt64
	HitCacheTotal     *ItemInt64
	CacheRequestTotal *ItemInt64
	TotalCacheSize    *ItemInt64
	InuseCacheSize    *ItemInt64
}

func NewResultCache added in v1.4.0 

func NewResultCache() *ResultCache

type SQLSlowQueryStatistics 

type SQLSlowQueryStatistics struct {
	TotalDuration    int64
	PrepareDuration  int64
	IteratorDuration int64
	EmitDuration     int64
	Query            string
	QueryLocs        [][2]int // <stmtId, <startLoc, endLoc>>
	DB               string
	QueryBatch       int64
}

SQL Statistics

func NewSqlSlowQueryStatistics 

func NewSqlSlowQueryStatistics(db string) *SQLSlowQueryStatistics

func (*SQLSlowQueryStatistics) AddDuration 

func (s *SQLSlowQueryStatistics) AddDuration(durationName string, d int64)

func (*SQLSlowQueryStatistics) GetQueryByStmtId added in v1.2.0 

func (s *SQLSlowQueryStatistics) GetQueryByStmtId(stmtId int) string

func (*SQLSlowQueryStatistics) SetDatabase 

func (s *SQLSlowQueryStatistics) SetDatabase(db string)

func (*SQLSlowQueryStatistics) SetQuery 

func (s *SQLSlowQueryStatistics) SetQuery(q string)

func (*SQLSlowQueryStatistics) SetQueryAndLocs added in v1.2.0 

func (s *SQLSlowQueryStatistics) SetQueryAndLocs(q string, locs [][2]int)

func (*SQLSlowQueryStatistics) SetQueryBatch 

func (s *SQLSlowQueryStatistics) SetQueryBatch(n int)

func (*SQLSlowQueryStatistics) SetQueryLocs added in v1.2.0 

func (s *SQLSlowQueryStatistics) SetQueryLocs(locs [][2]int)

type ShardStatistics added in v1.0.0 

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

type Shelf added in v1.4.0 

type Shelf struct {
	BaseCollector

	ActiveShardTotal  *ItemInt64
	WALWaitConvert    *ItemInt64 // Number of WAL files waiting to be converted to TSSP
	WALConverting     *ItemInt64 // Number of WAL files being converted
	WALFileCount      *ItemInt64
	WALFileSizeSum    *ItemInt64 // KB
	TSSPConvertCount  *ItemInt64
	TSSPConvertDurSum *ItemInt64 // milliseconds

	WriteFailedCount *ItemInt64
	WriteCount       *ItemInt64
	WriteDurSum      *ItemInt64 // microseconds
	ScheduleDurSum   *ItemInt64 // microseconds

	IndexCreateCount  *ItemInt64
	IndexCreateDurSum *ItemInt64 // microseconds

	// statistics the number of disk operations and latency
	DiskFlushCount  *ItemInt64
	DiskFlushDurSum *ItemInt64 // microseconds
	DiskSyncCount   *ItemInt64
	DiskSyncDurSum  *ItemInt64 // microseconds
}

func NewShelf added in v1.4.0 

func NewShelf() *Shelf

type SpdyItem 

type SpdyItem uint8
const (
	ConnTotal SpdyItem = iota
	FailedConnTotal
	ClosedConnTotal
	SuccessCreateSessionTotal
	FailedCreateSessionTotal
	ClosedSessionTotal
	ItemEnd
)

type SpdyJob 

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

func NewSpdyJob 

func NewSpdyJob(link SpdyLink) *SpdyJob

func (*SpdyJob) Clone 

func (job *SpdyJob) Clone() *SpdyJob

func (*SpdyJob) Key 

func (job *SpdyJob) Key() uint16

func (*SpdyJob) SetAddr 

func (job *SpdyJob) SetAddr(addr string) *SpdyJob

func (*SpdyJob) SetItem 

func (job *SpdyJob) SetItem(i SpdyItem) *SpdyJob

func (*SpdyJob) SetValue 

func (job *SpdyJob) SetValue(i int64) *SpdyJob
type SpdyLink uint8
const (
	Sql2Meta SpdyLink = iota
	Sql2Store
	Meta2Meta
	Meta2Store
	Store2Meta
	LinkEnd
)

type SpdyStatistics 

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

func NewSpdyStatistics 

func NewSpdyStatistics() *SpdyStatistics

func (*SpdyStatistics) Add 

func (s *SpdyStatistics) Add(job *SpdyJob)

func (*SpdyStatistics) Close 

func (s *SpdyStatistics) Close()

func (*SpdyStatistics) CollectBuf 

func (s *SpdyStatistics) CollectBuf() []byte

type StatItem 

type StatItem interface {
	Push()
	Key() string
}

type StatisticTags added in v1.1.0 

type StatisticTags map[string]string

StatisticTags is a map that can be merged with others without causing mutations to either map.

func (StatisticTags) Merge added in v1.1.0 

func (srcTags StatisticTags) Merge(dstTags map[string]string) map[string]string

Merge creates a new map containing the merged contents of tags and t. If both tags and the receiver map contain the same key, the value in tags is used in the resulting map.

Merge always returns a usable map.

type StatisticTimer 

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

func NewStatisticTimer 

func NewStatisticTimer(accu Accumulator) *StatisticTimer

func (*StatisticTimer) Begin 

func (st *StatisticTimer) Begin()

func (*StatisticTimer) End 

func (st *StatisticTimer) End()

type Statistics 

type Statistics interface {
	BuildAccumulator()
	AssignName()
}

type StoreQuery added in v1.4.1 

type StoreQuery struct {
	BaseCollector

	StoreQueryRequests        *ItemInt64 `name:"storeQueryReq"` // only for SelectProcessor
	StoreQueryRequestDuration *ItemInt64 `name:"storeQueryReqDurationNs"`
	StoreActiveQueryRequests  *ItemInt64 `name:"storeQueryReqActive"`

	UnmarshalQueryTimeTotal    *ItemInt64 `name:"UnmarshalQueryTimeTotal"`    // use with StoreQueryRequests
	GetShardResourceTimeTotal  *ItemInt64 `name:"GetShardResourceTimeTotal"`  // use with StoreQueryRequests
	IndexScanDagBuildTimeTotal *ItemInt64 `name:"IndexScanDagBuildTimeTotal"` // use with StoreQueryRequests

	// use with StoreQueryRequests and QueryShardNumTotal, each IndexScanDagRunTime end until ChunkReaderDag begin run
	IndexScanDagRunTimeTotal *ItemInt64 `name:"IndexScanDagRunTimeTotal"`

	// use with StoreQueryRequests and QueryShardNumTotal
	IndexScanRunTimeTotal *ItemInt64 `name:"IndexScanRunTimeTotal"`

	// use with StoreQueryRequests
	QueryShardNumTotal *ItemInt64 `name:"QueryShardNumTotal"`

	// use with StoreQueryRequests and QueryShardNumTotal
	IndexScanSeriesNumTotal *ItemInt64 `name:"IndexScanSeriesNumTotal"`

	// use with StoreQueryRequests and QueryShardNumTotal
	ChunkReaderDagBuildTimeTotal *ItemInt64 `name:"ChunkReaderDagBuildTimeTotal"`
	// use with StoreQueryRequests and QueryShardNumTotal
	ChunkReaderDagRunTimeTotal *ItemInt64 `name:"ChunkReaderDagRunTimeTotal"`
}

func NewStoreQuery added in v1.4.1 

func NewStoreQuery() *StoreQuery

func (*StoreQuery) MeasurementName added in v1.4.1 

func (s *StoreQuery) MeasurementName() string

type StoreSlowQueryStatistics 

type StoreSlowQueryStatistics struct {
	TotalDuration       int64
	RpcDuration         int64
	ChunkReaderDuration int64
	ChunkReaderCount    int64
	Query               string
	DB                  string
}

Store Statistics

func NewStoreSlowQueryStatistics 

func NewStoreSlowQueryStatistics() *StoreSlowQueryStatistics

func (*StoreSlowQueryStatistics) AddChunkReaderCount 

func (s *StoreSlowQueryStatistics) AddChunkReaderCount(count int64)

func (*StoreSlowQueryStatistics) AddDuration 

func (s *StoreSlowQueryStatistics) AddDuration(durationName string, d int64)

func (*StoreSlowQueryStatistics) SetDatabase 

func (s *StoreSlowQueryStatistics) SetDatabase(db string)

func (*StoreSlowQueryStatistics) SetQuery 

func (s *StoreSlowQueryStatistics) SetQuery(q string)

type StoreTaskDuration added in v1.0.0 

type StoreTaskDuration struct {
	// contains filtered or unexported fields
}
var StoreTaskInstance *StoreTaskDuration

func NewStoreTaskDuration added in v1.0.0 

func NewStoreTaskDuration(enable bool) *StoreTaskDuration

func (*StoreTaskDuration) Collect added in v1.0.0 

func (s *StoreTaskDuration) Collect(buffer []byte) ([]byte, error)

type StreamStatItem added in v1.0.0 

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

func (*StreamStatItem) Duration added in v1.0.0 

func (s *StreamStatItem) Duration() int64

func (*StreamStatItem) Push added in v1.0.0 

func (s *StreamStatItem) Push()

func (*StreamStatItem) Tags added in v1.0.0 

func (s *StreamStatItem) Tags() map[string]string

func (*StreamStatItem) Validate added in v1.0.0 

func (s *StreamStatItem) Validate() bool

func (*StreamStatItem) Values added in v1.0.0 

func (s *StreamStatItem) Values() map[string]interface{}

type StreamStatistics added in v1.0.0 

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

func NewStreamStatistics added in v1.0.0 

func NewStreamStatistics() *StreamStatistics

func (*StreamStatistics) AddStreamFilter added in v1.0.0 

func (s *StreamStatistics) AddStreamFilter(i int64)

func (*StreamStatistics) AddStreamFilterNum added in v1.0.0 

func (s *StreamStatistics) AddStreamFilterNum(i int64)

func (*StreamStatistics) AddStreamIn added in v1.0.0 

func (s *StreamStatistics) AddStreamIn(i int64)

func (*StreamStatistics) AddStreamInNum added in v1.0.0 

func (s *StreamStatistics) AddStreamInNum(i int64)

func (*StreamStatistics) Collect added in v1.0.0 

func (s *StreamStatistics) Collect(buffer []byte) ([]byte, error)

func (*StreamStatistics) CollectOps added in v1.1.0 

func (s *StreamStatistics) CollectOps() []opsStat.OpsStatistic

func (*StreamStatistics) Init added in v1.0.0 

func (s *StreamStatistics) Init(tags map[string]string)

func (*StreamStatistics) Push added in v1.0.0 

func (s *StreamStatistics) Push(item *StreamStatItem)

type StreamWindowStatItem added in v1.0.0 

type StreamWindowStatItem struct {
	WindowIn               int64
	WindowProcess          int64
	WindowSkip             int64
	WindowFlushCost        int64
	WindowFlushMarshalCost int64
	WindowFlushWriteCost   int64
	WindowUpdateCost       int64
	WindowOutMinTime       int64
	WindowOutMaxTime       int64
	WindowStartTime        int64
	WindowEndTime          int64
	WindowGroupKeyCount    int64

	StreamID string
	// contains filtered or unexported fields
}

func NewStreamWindowStatItem added in v1.0.0 

func NewStreamWindowStatItem(streamID uint64) *StreamWindowStatItem

func (*StreamWindowStatItem) AddWindowFlushMarshalCost added in v1.0.0 

func (s *StreamWindowStatItem) AddWindowFlushMarshalCost(c int64)

func (*StreamWindowStatItem) AddWindowFlushWriteCost added in v1.0.0 

func (s *StreamWindowStatItem) AddWindowFlushWriteCost(c int64)

func (*StreamWindowStatItem) AddWindowGroupKeyCount added in v1.1.0 

func (s *StreamWindowStatItem) AddWindowGroupKeyCount(i int64)

func (*StreamWindowStatItem) AddWindowIn added in v1.0.0 

func (s *StreamWindowStatItem) AddWindowIn(i int64)

func (*StreamWindowStatItem) AddWindowProcess added in v1.0.0 

func (s *StreamWindowStatItem) AddWindowProcess(i int64)

func (*StreamWindowStatItem) AddWindowSkip added in v1.0.0 

func (s *StreamWindowStatItem) AddWindowSkip(i int64)

func (*StreamWindowStatItem) Duration added in v1.0.0 

func (s *StreamWindowStatItem) Duration() int64

func (*StreamWindowStatItem) Push added in v1.0.0 

func (s *StreamWindowStatItem) Push()

func (*StreamWindowStatItem) Reset added in v1.0.0 

func (s *StreamWindowStatItem) Reset()

func (*StreamWindowStatItem) StatWindowEndTime added in v1.0.0 

func (s *StreamWindowStatItem) StatWindowEndTime(t int64)

func (*StreamWindowStatItem) StatWindowFlushCost added in v1.0.0 

func (s *StreamWindowStatItem) StatWindowFlushCost(c int64)

func (*StreamWindowStatItem) StatWindowOutMaxTime added in v1.0.0 

func (s *StreamWindowStatItem) StatWindowOutMaxTime(t int64)

func (*StreamWindowStatItem) StatWindowOutMinTime added in v1.0.0 

func (s *StreamWindowStatItem) StatWindowOutMinTime(t int64)

func (*StreamWindowStatItem) StatWindowStartTime added in v1.0.0 

func (s *StreamWindowStatItem) StatWindowStartTime(t int64)

func (*StreamWindowStatItem) StatWindowUpdateCost added in v1.0.0 

func (s *StreamWindowStatItem) StatWindowUpdateCost(c int64)

func (*StreamWindowStatItem) Tags added in v1.0.0 

func (s *StreamWindowStatItem) Tags() map[string]string

func (*StreamWindowStatItem) Validate added in v1.0.0 

func (s *StreamWindowStatItem) Validate() bool

func (*StreamWindowStatItem) Values added in v1.0.0 

func (s *StreamWindowStatItem) Values() map[string]interface{}

type StreamWindowStatistics added in v1.0.0 

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

func NewStreamWindowStatistics added in v1.0.0 

func NewStreamWindowStatistics() *StreamWindowStatistics

func (*StreamWindowStatistics) Collect added in v1.0.0 

func (s *StreamWindowStatistics) Collect(buffer []byte) ([]byte, error)

func (*StreamWindowStatistics) CollectOps added in v1.1.0 

func (s *StreamWindowStatistics) CollectOps() []opsStat.OpsStatistic

func (*StreamWindowStatistics) Init added in v1.0.0 

func (s *StreamWindowStatistics) Init(tags map[string]string)

func (*StreamWindowStatistics) Push added in v1.0.0 

func (s *StreamWindowStatistics) Push(item *StreamWindowStatItem)

type Timestamp 

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

func NewTimestamp 

func NewTimestamp() *Timestamp

func (*Timestamp) Bytes 

func (ts *Timestamp) Bytes() []byte

func (*Timestamp) Incr 

func (ts *Timestamp) Incr()

func (*Timestamp) Init 

func (ts *Timestamp) Init(interval time.Duration)

func (*Timestamp) Reset 

func (ts *Timestamp) Reset()

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.