common

Documentation

Index

• Constants
• func GetMemInuse() uint64
• func GetNetIO() (uint64, uint64)
• type ControllerIngesterShared
  • func NewControllerIngesterShared() *ControllerIngesterShared
• type Counter
• type Monitor
  • func NewMonitor() (*Monitor, error)
  • func (m *Monitor) GetCounter() interface{}
  • func (m *Monitor) GetCpuNum() uint64
  • func (m *Monitor) GetCpuPercent() float64
  • func (m *Monitor) GetDiskIO() (uint64, uint64)
  • func (m *Monitor) GetLoad1() float64
  • func (m *Monitor) GetMemRSS() uint64
  • func (m *Monitor) Stop()

Constants

const QUEUE_SIZE = 1 << 16

Functions

func GetMemInuse

func GetMemInuse() uint64

func GetNetIO

func GetNetIO() (uint64, uint64)

Types

type ControllerIngesterShared

type ControllerIngesterShared struct {
	ResourceEventQueue *queue.OverwriteQueue
}

func NewControllerIngesterShared

func NewControllerIngesterShared() *ControllerIngesterShared

type Counter

type Counter struct {
	CpuPercent float64 `statsd:"cpu-percent"`
	MemRSS     uint64  `statsd:"mem-rss"`
	MemInuse   uint64  `statsd:"mem-inuse"`
	BytesSend  uint64  `statsd:"bytes-send"`
	BytesRecv  uint64  `statsd:"bytes-recv"`
	BytesRead  uint64  `statsd:"bytes-read"`
	BytesWrite uint64  `statsd:"bytes-write"`
	Load1      float64 `statsd:"load1"`
	CPUNum     uint64  `statsd:"cpu-num"`
}

type Monitor

type Monitor struct {
	utils.Closable
	// contains filtered or unexported fields
}

func NewMonitor

func NewMonitor() (*Monitor, error)

func (*Monitor) GetCounter

func (m *Monitor) GetCounter() interface{}

func (*Monitor) GetCpuNum

func (m *Monitor) GetCpuNum() uint64

func (*Monitor) GetCpuPercent

func (m *Monitor) GetCpuPercent() float64

func (*Monitor) GetDiskIO

func (m *Monitor) GetDiskIO() (uint64, uint64)

func (*Monitor) GetLoad1

func (m *Monitor) GetLoad1() float64

func (*Monitor) GetMemRSS

func (m *Monitor) GetMemRSS() uint64

func (*Monitor) Stop

func (m *Monitor) Stop()