statistics

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: Dec 7, 2022 License: Apache-2.0 Imports: 13 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.

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"
)
View Source
const (
	StatImmuLevel          = "level"
	StatImmuMemSize        = "ImmuMemSize"
	StatImmuMemOrderSize   = "ImmuMemOrderSize"
	StatImmuMemUnOrderSize = "ImmuMemUnOrderSize"
)
View Source
const (
	TypeMetaStatItem     = "MetaStatItem"
	TypeMetaRaftStatItem = "MetaRaftStatItem"
)
View Source
const (
	StatMutablePath = "path"
	StatMutableSize = "mutableSize"
)
View Source
const (
	StatSlowQueryDatabase   = "database"
	StatTotalDuration       = "totalDuration"
	StatPrepareDuration     = "prepareDuration"
	StatIteratorDuration    = "sqlIteratorDuration"
	StatChunkReaderCount    = "ChunkReaderCount"
	StatEmitDuration        = "emitDuration"
	StatQuery               = "query"
	StatQueryBatch          = "queryBatch"
	StatRpcDuration         = "rpcDuration"
	StatChunkReaderDuration = "chunkReaderDuration"
)

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 HandlerStat = NewHandlerStatistics()
View Source
var HandlerStatisticsName = "httpd"
View Source
var HandlerTagMap map[string]string
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 MutableStat = NewMutableStatistics()
View Source
var MutableStatisticsName = "mutable"
View Source
var MutableTagMap 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 chan *SQLSlowQueryStatistics
View Source
var SlowQueryStat = NewSqlSlowQueryStatistics()
View Source
var SlowQueryStatisticsName = "slow_queries"
View Source
var SlowQueryTagMap map[string]string
View Source
var SqlSlowQueryStatisticsName = "sql_slow_queries"
View Source
var StoreSlowQueries chan *StoreSlowQueryStatistics
View Source
var StoreSlowQueryStat = NewStoreSlowQueryStatistics()
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 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 CollectHandlerStatistics

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

func CollectIOStatistics

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

func CollectImmutableStatistics

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

func CollectMutableStatistics

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

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 CreateRuntimeWithShardKey

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

func FileStatisticsLimited

func FileStatisticsLimited(i int64) bool

func GetCpuUsage

func GetCpuUsage() (int64, int64)

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 InitMutableStatistics

func InitMutableStatistics(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 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

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 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) Init

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

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

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
	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 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 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) Collect

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

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) Collect

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

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 MutableStats struct {
	MutableSize int64
	MutableRows int64
}

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 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 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 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

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()

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL