statistics

package
v1.3.1 Latest Latest
Warning

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

 Go to latest Published: Jan 2, 2025 License: Apache-2.0 Imports: 21 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 (
	StatImmuLevel          = "level"
	StatImmuMemSize        = "ImmuMemSize"
	StatImmuMemOrderSize   = "ImmuMemOrderSize"
	StatImmuMemUnOrderSize = "ImmuMemUnOrderSize"
)
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 (
	Query400ErrorStmtCount = "query400ErrorStmtCount" // Number of query stmt occur 400(client) error.

)
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 HandlerStat = NewHandlerStatistics()
View Source 
var HandlerStatisticsName = "httpd"
View Source 
var HandlerTagMap 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 ImmutableStat = NewImmutableStatistics()
View Source 
var ImmutableStatisticsName = "immutable"
View Source 
var ImmutableTagMap 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 StoreQueryStat = NewStoreQueryStatistics()
View Source 
var StoreQueryTagMap map[string]string
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 CollectHandlerStatistics 

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

func CollectIOStatistics 

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

func CollectImmutableStatistics 

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

func CollectOpsEngineStatStatistics added in v1.0.0 

func CollectOpsEngineStatStatistics() []opsStat.OpsStatistic

func CollectOpsHandlerStatistics added in v1.0.0 

func CollectOpsHandlerStatistics() []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 CollectOpsStoreQueryStatistics added in v1.2.0 

func CollectOpsStoreQueryStatistics() []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 CollectStoreQueryStatistics added in v1.2.0 

func CollectStoreQueryStatistics(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 InitHandlerStatistics 

func InitHandlerStatistics(tags map[string]string)

func InitIOStatistics 

func InitIOStatistics(tags map[string]string)

func InitImmutableStatistics 

func InitImmutableStatistics(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 InitStoreQueryStatistics 

func InitStoreQueryStatistics(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 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 BaseStatistics 

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

func (*BaseStatistics) Init 

func (bs *BaseStatistics) Init(derived Statistics)

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 HandlerStatistics 

type HandlerStatistics struct {
	Requests                     int64
	QueryStmtCount               int64
	Query400ErrorStmtCount       int64 // client error
	QueryErrorStmtCount          int64
	QueryRequests                int64
	WriteRequests                int64
	Write400ErrRequests          int64
	Write500ErrRequests          int64
	PingRequests                 int64
	StatusRequests               int64
	WriteRequestBytesReceived    int64
	WriteRequestBytesIn          int64
	QueryRequestBytesTransmitted int64
	PointsWrittenOK              int64
	FieldsWritten                int64
	PointsWrittenDropped         int64
	PointsWrittenFail            int64
	AuthenticationFailures       int64
	RequestDuration              int64
	WriteRequestParseDuration    int64
	QueryRequestDuration         int64
	WriteRequestDuration         int64
	ActiveRequests               int64
	ActiveWriteRequests          int64
	ActiveQueryRequests          int64
	ClientErrors                 int64
	ServerErrors                 int64
	RecoveredPanics              int64
	WriteScheduleUnMarshalDns    int64
	WriteCreateMstDuration       int64
	WriteUpdateSchemaDuration    int64
	WriteCreateSgDuration        int64
	WriteUnmarshalSkDuration     int64
	WriteStoresDuration          int64
	WriteUpdateIndexDuration     int64
	WriteMapRowsDuration         int64
	WriteStreamRoutineDuration   int64
	ConnectionNums               int64
}

Statistics keeps statistics related to the Handler

func NewHandlerStatistics 

func NewHandlerStatistics() *HandlerStatistics

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) AddChunkMetaGetTotal added in v1.2.0 

func (s *HitRatioStatistics) AddChunkMetaGetTotal(i int64)

func (*HitRatioStatistics) AddChunkMetaHitTotal added in v1.2.0 

func (s *HitRatioStatistics) AddChunkMetaHitTotal(i int64)

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)

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
	IOReadPageCacheCount int64
	IOReadPageCacheRatio int64
	IOReadPageCacheMem   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 ImmuStats 

type ImmuStats struct {
	ImmuMemSize        int64
	ImmuMemOrderSize   int64
	ImmuMemUnOrderSize int64
}

type ImmutableStatistics 

type ImmutableStatistics struct {
	Mu    sync.RWMutex
	Stats map[string]*ImmuStats
}

ImmutableStatistics keeps statistics related to the Immutable

func NewImmutableStatistics 

func NewImmutableStatistics() *ImmutableStatistics

func (*ImmutableStatistics) AddMemSize 

func (immu *ImmutableStatistics) AddMemSize(path string, memSize, memOrderSize, memUnOrderSize int64)

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 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 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 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 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 StoreQueryStatistics added in v1.2.0 

type StoreQueryStatistics struct {
	StoreQueryRequests        int64 // only for SelectProcessor
	StoreQueryRequestDuration int64
	StoreActiveQueryRequests  int64

	UnmarshalQueryTimeTotal   int64 // use with StoreQueryRequests
	GetShardResourceTimeTotal int64 // use with StoreQueryRequests

	IndexScanDagBuildTimeTotal int64 // use with StoreQueryRequests
	IndexScanDagRunTimeTotal   int64 // use with StoreQueryRequests and QueryShardNumTotal, each IndexScanDagRunTime end until ChunkReaderDag begin run
	IndexScanRunTimeTotal      int64 // use with StoreQueryRequests and QueryShardNumTotal
	QueryShardNumTotal         int64 // use with StoreQueryRequests
	IndexScanSeriesNumTotal    int64 // use with StoreQueryRequests and QueryShardNumTotal

	ChunkReaderDagBuildTimeTotal int64 // use with StoreQueryRequests and QueryShardNumTotal
	ChunkReaderDagRunTimeTotal   int64 // use with StoreQueryRequests and QueryShardNumTotal
}

func NewStoreQueryStatistics added in v1.2.0 

func NewStoreQueryStatistics() *StoreQueryStatistics

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.