Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

metric

package

Go to main page

Versions in this module

v0

v0.7.3

Aug 16, 2018

v0.7.2

Aug 2, 2018

v0.7.1

Aug 1, 2018

v0.6.4

Aug 1, 2018

v0.6.3

Jul 27, 2018

Changes in this version

+ const NAMESPACE_NODE

+ const NAMESPACE_RANGE

+ var RangeStatsSQL = `insert into range_stats (cluster_id, addr, range_id, bytes_written, bytes_read, keys_written, keys_read, approximate_size, update_time) values (%d,"%s",%d,%d,%d,%d,%d,%d,%d)`

+ func GetIndexRule(metric string) string

v0.6.2

Jun 18, 2018

v0.6.1

Jun 17, 2018

Changes in this version

+ const METRIC_CLUSTER_META

+ const METRIC_CLUSTER_NET

+ const METRIC_CLUSTER_SLOWLOG

+ const METRIC_DB_META

+ const METRIC_HOTSPOT

+ const METRIC_MAC_DISK

+ const METRIC_MAC_MEM

+ const METRIC_MAC_META

+ const METRIC_MAC_NET

+ const METRIC_NODE_STATS

+ const METRIC_PROCESS_DISK

+ const METRIC_PROCESS_DS

+ const METRIC_PROCESS_META

+ const METRIC_PROCESS_NET

+ const METRIC_RANGE_STATS

+ const METRIC_SCHEDULE_COUNTER

+ const METRIC_TABLE_META

+ const METRIC_TASK_STATS

+ const NAMESPACE_CLUSTER

+ const NAMESPACE_DB

+ const NAMESPACE_HOTSPOT

+ const NAMESPACE_MAC

+ const NAMESPACE_PROCESS

+ const NAMESPACE_SCHEDULE

+ const NAMESPACE_TABLE

+ const NAMESPACE_TASK

+ const TYPE_ELASTICSEARCH

+ const TYPE_SQL

+ const Type_Cluster

+ const Type_DB

+ const Type_Mac

+ const Type_Process

+ const Type_Table

+ var ClusterMetaSQL = ...

+ var ClusterNetSQL = ...

+ var DbMetaSQL = `insert into db_meta (cluster_id, db_name, table_num, range_size, update_time) values (%d,"%s",%d,%d,%d)`

+ var MacDiskSQL = ...

+ var MacMemSQL = ...

+ var MacMetaSQL = ...

+ var MacNetSQL = ...

+ var ProcessDiskSQL = ...

+ var ProcessDsSQL = ...

+ var ProcessMetaSQL = ...

+ var ProcessNetSQL = ...

+ var TableMetaSQL = `insert into table_meta (cluster_id, db_name, table_name, range_count, range_size, update_time) values (%d,"%s","%s",%d,%d,%d)`

+ var TaskMetaSQL = `insert into task_meta (cluster_id, finish_time, used_time, state, describe, update_time) values (%d,%d,%d,"%s","%s",%d)`

+ type Cluster struct

+ ClusterId uint64

+ DbCache *DbItemCache

+ Item *ClusterItem

+ LastReportTime time.Time

+ MacCache *MacItemCache

+ ProcessCache *ProcessItemCache

+ func NewCluster(clusterId uint64) *Cluster

+ func (c *Cluster) GetDbItem(name string) *DbItem

+ func (c *Cluster) GetMacItem(ip string) *MacItem

+ func (c *Cluster) GetProcessItem(addr string) *ProcessItem

+ func (c *Cluster) SetDbItem(db *DbItem)

+ func (c *Cluster) SetMacItem(item *MacItem)

+ func (c *Cluster) SetProcessItem(item *ProcessItem)

+ type ClusterCache struct

+ func NewClusterCache() *ClusterCache

+ func (c *ClusterCache) Get(clusterId uint64) *Cluster

+ func (c *ClusterCache) GetAll() []*Cluster

+ func (c *ClusterCache) Set(item *Cluster)

+ type ClusterItem struct

+ Avg float64

+ CapacityTotal uint64

+ ClusterId uint64

+ DbNum uint64

+ ErrNumber uint64

+ GsNum uint64

+ LeaderBalanceRatio float64

+ Max float64

+ Min float64

+ NetIoInBytePerSec uint64

+ NetIoInPackagePerSec uint64

+ NetIoOutBytePerSec uint64

+ NetIoOutPackagePerSec uint64

+ NetTcpActiveOpensPerSec uint32

+ NetTcpConnections uint32

+ NodeDownCount uint64

+ NodeOfflineCount uint64

+ NodeTombstoneCount uint64

+ NodeUpCount uint64

+ RangeNum uint64

+ RegionBalanceRatio float64

+ SizeUsed uint64

+ SlowLog []string

+ TP50 float64

+ TP90 float64

+ TP99 float64

+ TP999 float64

+ TableNum uint64

+ TaskNum uint64

+ TotalNumber uint64

+ Tps uint64

+ UpdateTime int64

+ type Context struct

+ type DbItem struct

+ DbName string

+ Size uint64

+ TableCache *TableItemCache

+ TableNum uint32

+ UpdateTime int64

+ func NewDbItem(name string) *DbItem

+ func (i *DbItem) GetTableItem(name string) *TableItem

+ func (i *DbItem) SetTableTtem(item *TableItem)

+ type DbItemCache struct

+ func NewDbCache() *DbItemCache

+ func (c *DbItemCache) Get(name string) *DbItem

+ func (c *DbItemCache) GetAll() []*DbItem

+ func (c *DbItemCache) Set(item *DbItem)

+ type EsStore struct

+ func (s *EsStore) Close()

+ func (s *EsStore) Open() error

+ func (s *EsStore) Put(message *Message) error

+ type MacItem struct

+ Ip string

+ Item *statspb.MacStats

+ Type string

+ UpdateTime int64

+ type MacItemCache struct

+ func NewMacItemCache() *MacItemCache

+ func (c *MacItemCache) Get(addr string) *MacItem

+ func (c *MacItemCache) GetAll() []*MacItem

+ func (c *MacItemCache) Set(item *MacItem)

+ type Message struct

+ ClusterId uint64

+ Items map[string]interface{}

+ MsgId string

+ Namespace string

+ Subsystem string

+ type Metric struct

+ AlarmCli *alarm.Client

+ Threshold ThresholdConfig

+ func NewMetric(svr *server.Server, store Store, threshold ThresholdConfig) *Metric

+ func NewRawMetric(ip string, port uint16, store Store) *Metric

+ func (m *Metric) Open() error

+ func (m *Metric) Start()

+ func (m *Metric) Stop()

+ type NodeThreshold struct

+ CapacityUsedRate uint64

+ ReadBps uint64

+ ReadOps uint64

+ WriteBps uint64

+ WriteOps uint64

+ type ProcessItem struct

+ Addr string

+ Item *statspb.ProcessStats

+ SlowLog *statspb.SlowLogStats

+ Type string

+ UpdateTime int64

+ type ProcessItemCache struct

+ func NewProcessItemCache() *ProcessItemCache

+ func (c *ProcessItemCache) Get(addr string) *ProcessItem

+ func (c *ProcessItemCache) GetAll() []*ProcessItem

+ func (c *ProcessItemCache) Set(item *ProcessItem)

+ type RangeThreshold struct

+ ReadBps uint64

+ ReadOps uint64

+ WriteBps uint64

+ WriteOps uint64

+ type SlowLogItem struct

+ Addr string

+ Item *statspb.SlowLogStats

+ Type string

+ UpdateTime int64

+ type SqlStore struct

+ func (s *SqlStore) Close()

+ func (s *SqlStore) Open() error

+ func (s *SqlStore) Put(message *Message) error

+ type Store interface

+ Close func()

+ Open func() error

+ Put func(message *Message) error

+ func NewEsStore(nodes []string, worker_num int) Store

+ func NewSqlStore(dns string, worker_num int) Store

+ type TableItem struct

+ DbName string

+ RangeNum uint64

+ Size uint64

+ TableName string

+ UpdateTime int64

+ type TableItemCache struct

+ func NewTableItemCache() *TableItemCache

+ func (c *TableItemCache) Get(name string) *TableItem

+ func (c *TableItemCache) GetAll() []*TableItem

+ func (c *TableItemCache) Set(item *TableItem)

+ type TaskItem struct

+ UpdateTime int64

+ type ThresholdConfig struct

+ Node NodeThreshold

+ Range RangeThreshold