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.
nolint
Index ¶
- Constants
- Variables
- func AddPointToBuffer(statisticsName string, tagMap map[string]string, ...) []byte
- func AllocTagMap(tagMap, globalTag map[string]string)
- func AppendSqlQueryDuration(d *SQLSlowQueryStatistics)
- func AppendStoreQueryDuration(d *StoreSlowQueryStatistics)
- func CollectDatabaseStatistics(buffer []byte) ([]byte, error)
- func CollectEngineStatStatistics(buffer []byte) ([]byte, error)
- func CollectExecutorStatistics(buffer []byte) ([]byte, error)
- func CollectHandlerStatistics(buffer []byte) ([]byte, error)
- func CollectIOStatistics(buffer []byte) ([]byte, error)
- func CollectImmutableStatistics(buffer []byte) ([]byte, error)
- func CollectMutableStatistics(buffer []byte) ([]byte, error)
- func CollectPerfStatistics(buffer []byte) ([]byte, error)
- func CollectRuntimeStatistics(buffer []byte) ([]byte, error)
- func CollectSpdyStatistics(buffer []byte) ([]byte, error)
- func CollectSqlSlowQueryStatistics(buffer []byte) ([]byte, error)
- func CollectStoreSlowQueryStatistics(buffer []byte) ([]byte, error)
- func CreateExecutorWithShardKey(buffer []byte) ([]byte, error)
- func CreateRuntimeWithShardKey(buffer []byte) ([]byte, error)
- func FileStatisticsLimited(i int64) bool
- func GetCpuUsage() (int64, int64)
- func InitDatabaseStatistics(tags map[string]string)
- func InitEngineStatistics(tags map[string]string)
- func InitExecutorStatistics(tags map[string]string)
- func InitFileStatistics(tags map[string]string)
- func InitHandlerStatistics(tags map[string]string)
- func InitIOStatistics(tags map[string]string)
- func InitImmutableStatistics(tags map[string]string)
- func InitMutableStatistics(tags map[string]string)
- func InitPerfStatistics(tags map[string]string)
- func InitRuntimeStatistics(tags map[string]string, interval int)
- func InitSlowQueryStatistics(tags map[string]string)
- func InitSpdyStatistics(tags map[string]string)
- func InitStoreQueryStatistics(tags map[string]string)
- func UpdateEngineStatS()
- type Accumulator
- type BaseStatistics
- type CompactStatItem
- type CompactStatistics
- func (s *CompactStatistics) AddActive(i int64)
- func (s *CompactStatistics) AddErrors(i int64)
- func (s *CompactStatistics) AddMaxMemoryUsed(i int64)
- func (s *CompactStatistics) AddRecordPoolGetTotal(i int64)
- func (s *CompactStatistics) AddRecordPoolHitTotal(i int64)
- func (s *CompactStatistics) Collect(buffer []byte) ([]byte, error)
- func (s *CompactStatistics) Init(tags map[string]string)
- func (s *CompactStatistics) PushCompaction(item *CompactStatItem)
- func (s *CompactStatistics) SetActive(i int64)
- type DBStatistics
- type DBStats
- type EngineStatus
- type ErrnoStat
- type ExecutorStatistics
- type FileStat
- type FileStatItem
- type FileStatistics
- func (s *FileStatistics) Collect(buffer []byte, originTags map[string]string, fileStat *FileStat) ([]byte, error)
- func (s *FileStatistics) CollectLevel(buffer []byte, originTags map[string]string, fileStat map[uint16]*FileStatItem) ([]byte, error)
- func (s *FileStatistics) CollectMst(buffer []byte, originTags map[string]string, ...) ([]byte, error)
- type HandlerStatistics
- type IOStatistics
- type ImmuStats
- type ImmutableStatistics
- type Int64Accumulator
- type MergeStatItem
- func (s *MergeStatItem) Duration() int64
- func (s *MergeStatItem) Push()
- func (s *MergeStatItem) StatMergedFile(size int64)
- func (s *MergeStatItem) StatOrderFile(size int64)
- func (s *MergeStatItem) StatOutOfOrderFile(size int64)
- func (s *MergeStatItem) Tags() map[string]string
- func (s *MergeStatItem) Validate() bool
- func (s *MergeStatItem) Values() map[string]interface{}
- type MergeStatistics
- func (s *MergeStatistics) AddActive(i int64)
- func (s *MergeStatistics) AddCurrentOutOfOrderFile(i int64)
- func (s *MergeStatistics) AddErrors(i int64)
- func (s *MergeStatistics) AddRecordPoolGetTotal(i int64)
- func (s *MergeStatistics) AddRecordPoolHitTotal(i int64)
- func (s *MergeStatistics) Collect(buffer []byte) ([]byte, error)
- func (s *MergeStatistics) Init(tags map[string]string)
- func (s *MergeStatistics) Push(item *MergeStatItem)
- func (s *MergeStatistics) SetCurrentOutOfOrderFile(i int64)
- type MetaRaftStatItem
- type MetaRaftStatistics
- type MetaStatCollector
- type MetaStatItem
- type MetaStatistics
- func (s *MetaStatistics) AddLeaderSwitchTotal(i int64)
- func (s *MetaStatistics) AddSnapshotDataSize(i int64)
- func (s *MetaStatistics) AddSnapshotTotal(i int64)
- func (s *MetaStatistics) AddSnapshotUnmarshalDuration(i int64)
- func (s *MetaStatistics) AddStoreApplyTotal(i int64)
- func (s *MetaStatistics) Collect(buffer []byte) ([]byte, error)
- func (s *MetaStatistics) Init(tags map[string]string)
- func (s *MetaStatistics) Push(item *MetaStatItem)
- type MutableStatistics
- type MutableStats
- type NamedAccumulator
- type NamedInt64Accumulator
- type PerfStatistics
- type SQLSlowQueryStatistics
- type SpdyItem
- type SpdyJob
- type SpdyLink
- type SpdyStatistics
- type StatItem
- type StatisticTimer
- type Statistics
- type StoreSlowQueryStatistics
- type Timestamp
Constants ¶
const ( UNDERLINE = "_" COUNT_NAME = "count" SUM_NAME = "sum" LAST_NAME = "last" )
const ( StatDBDatabase = "database" StatNumMeasurements = "numMeasurements" StatNumRecentSeries = "numRecentSeries" StatNumHistorySeries = "numHistorySeries" )
const ( StatFileCount = "FileCount" StatFileSize = "FileSize" )
const ( StatImmuLevel = "level" StatImmuMemSize = "ImmuMemSize" StatImmuMemOrderSize = "ImmuMemOrderSize" StatImmuMemUnOrderSize = "ImmuMemUnOrderSize" )
const ( TypeMetaStatItem = "MetaStatItem" TypeMetaRaftStatItem = "MetaRaftStatItem" )
const ( StatMutablePath = "path" StatMutableSize = "mutableSize" )
const ( StatSlowQueryDatabase = "database" StatTotalDuration = "totalDuration" StatPrepareDuration = "prepareDuration" StatIteratorDuration = "sqlIteratorDuration" StatChunkReaderCount = "ChunkReaderCount" StatEmitDuration = "emitDuration" StatQuery = "query" StatQueryBatch = "queryBatch" StatRpcDuration = "rpcDuration" StatChunkReaderDuration = "chunkReaderDuration" )
Variables ¶
var CpuInterval = 10
var CpuStatFile = "/sys/fs/cgroup/cpu,cpuacct/cpuacct.stat"
var DatabaseStat = NewDBStatistics()
var DatabaseStatisticsName = "database"
var DatabaseTagMap map[string]string
var (
EngineStat = &EngineStatus{}
)
var ExecutorStat = NewExecutorStatistics()
var HandlerStat = NewHandlerStatistics()
var HandlerStatisticsName = "httpd"
var HandlerTagMap map[string]string
var IOStat = NewIOStatistics()
var IOStatisticsName = "io"
var IOTagMap map[string]string
var ImmutableStat = NewImmutableStatistics()
var ImmutableStatisticsName = "immutable"
var ImmutableTagMap map[string]string
var MutableStat = NewMutableStatistics()
var MutableStatisticsName = "mutable"
var MutableTagMap map[string]string
var PerfStat = NewPerfStatistics()
var PerfStatisticsName = "performance"
var PerfTagMap map[string]string
var RuntimeStatisticsName = "runtime"
var RuntimeTagMap map[string]string
var SlowQueries chan *SQLSlowQueryStatistics
var SlowQueryStat = NewSqlSlowQueryStatistics()
var SlowQueryStatisticsName = "slow_queries"
var SlowQueryTagMap map[string]string
var SqlSlowQueryStatisticsName = "sql_slow_queries"
var StoreSlowQueries chan *StoreSlowQueryStatistics
var StoreSlowQueryStat = NewStoreSlowQueryStatistics()
var StoreSlowQueryStatisticsName = "store_slow_queries"
var StoreSlowQueryTagMap map[string]string
Functions ¶
func AddPointToBuffer ¶
func AllocTagMap ¶
func AppendSqlQueryDuration ¶
func AppendSqlQueryDuration(d *SQLSlowQueryStatistics)
func AppendStoreQueryDuration ¶
func AppendStoreQueryDuration(d *StoreSlowQueryStatistics)
func CollectIOStatistics ¶
func CollectPerfStatistics ¶
func CollectSpdyStatistics ¶
func FileStatisticsLimited ¶
func GetCpuUsage ¶
func InitDatabaseStatistics ¶
func InitEngineStatistics ¶
func InitExecutorStatistics ¶
func InitFileStatistics ¶
func InitHandlerStatistics ¶
func InitIOStatistics ¶
func InitImmutableStatistics ¶
func InitMutableStatistics ¶
func InitPerfStatistics ¶
func InitRuntimeStatistics ¶
func InitSlowQueryStatistics ¶
func InitSpdyStatistics ¶
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) 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 DBStatistics ¶
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 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
type ExecutorStatistics ¶
type ExecutorStatistics struct {
BaseStatistics
Memory Accumulator
Goroutine Accumulator
ExecWaitTime Accumulator
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
type FileStatItem ¶
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) 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
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
}
Statistics keeps statistics related to the Handler
func NewHandlerStatistics ¶
func NewHandlerStatistics() *HandlerStatistics
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
IOSyncTotalCount int64
IOSyncActiveCount int64
IOSyncOkCount int64
IOSyncDuration int64
IOSnapshotCount int64
IOSnapshotBytes int64
}
func NewIOStatistics ¶
func NewIOStatistics() *IOStatistics
func (*IOStatistics) AddIOSnapshotBytes ¶
func (s *IOStatistics) AddIOSnapshotBytes(i int64)
type ImmutableStatistics ¶
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 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 MergeStatItem ¶
type MergeStatItem struct {
OutOfOrderFileCount int64
OutOfOrderFileSize int64
OrderFileCount int64
OrderFileSize int64
MergedFileCount int64
MergedFileSize 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)
func (*MergeStatItem) StatOrderFile ¶
func (s *MergeStatItem) StatOrderFile(size int64)
func (*MergeStatItem) StatOutOfOrderFile ¶
func (s *MergeStatItem) StatOutOfOrderFile(size int64)
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) AddRecordPoolGetTotal ¶
func (s *MergeStatistics) AddRecordPoolGetTotal(i int64)
func (*MergeStatistics) AddRecordPoolHitTotal ¶
func (s *MergeStatistics) AddRecordPoolHitTotal(i int64)
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) 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) 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) Init ¶
func (s *MetaStatistics) Init(tags map[string]string)
func (*MetaStatistics) Push ¶
func (s *MetaStatistics) Push(item *MetaStatItem)
type MutableStatistics ¶
type MutableStatistics struct {
Mu sync.RWMutex
Stats map[string]*MutableStats
}
Statistics keeps statistics related to the Mutable
func NewMutableStatistics ¶
func NewMutableStatistics() *MutableStatistics
func (*MutableStatistics) AddMutableSize ¶
func (mu *MutableStatistics) AddMutableSize(path string, size int64)
type MutableStats ¶
type NamedAccumulator ¶
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 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 SQLSlowQueryStatistics ¶
type SQLSlowQueryStatistics struct {
TotalDuration int64
PrepareDuration int64
IteratorDuration int64
EmitDuration int64
Query string
DB string
QueryBatch int64
}
SQL Statistics
func NewSqlSlowQueryStatistics ¶
func NewSqlSlowQueryStatistics() *SQLSlowQueryStatistics
func (*SQLSlowQueryStatistics) AddDuration ¶
func (s *SQLSlowQueryStatistics) AddDuration(durationName string, d int64)
func (*SQLSlowQueryStatistics) SetDatabase ¶
func (s *SQLSlowQueryStatistics) SetDatabase(db string)
func (*SQLSlowQueryStatistics) SetQuery ¶
func (s *SQLSlowQueryStatistics) SetQuery(q string)
func (*SQLSlowQueryStatistics) SetQueryBatch ¶
func (s *SQLSlowQueryStatistics) SetQueryBatch(n int)
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 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 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 Timestamp ¶
type Timestamp struct {
// contains filtered or unexported fields
}
func NewTimestamp ¶
func NewTimestamp() *Timestamp
Source Files
¶
- accumulator.go
- compact_statistics.gen.go
- compact_statistics.go
- db_statistics.go
- errno_statistics.go
- executor_statistics.go
- file_statistics.go
- handler_statistics.go
- immutable_statistics.go
- io_statistics.go
- merge_statistics.gen.go
- merge_statistics.go
- meta_raft_statistics.gen.go
- meta_stat.go
- meta_statistics.gen.go
- mutable_statistics.go
- perf_statistics.go
- runtime_statistics.go
- slowquery_statistics.go
- spdy_statistics.go
- util_statistics.go