nodestore

type DiskIOState struct {
	DiskReadKiBps  float64 `structs:"diskio_read_kibps"`
	DiskWriteKiBps float64 `structs:"diskio_write_kibps"`
	DiskReadIOps   float64 `structs:"diskio_read_iops"`
	DiskWriteIOps  float64 `structs:"diskio_write_iops"`
	Util           float64 `structs:"diskio_util"`
}

type IfaceStat struct {
	Iface string `structs:"iface"`
	// Speed is the total kilobits for the iface
	Speed int `structs:"netio_speed"`
	// NetRecvkbps is the kilobits per second for ingress
	NetRecvkbps float64 `structs:"netio_recv_kbps"`
	// NetSentkbps is the kilobits per second for egress
	NetSentkbps float64 `structs:"netio_sent_kbps"`
	// NetRecvPckps is the package per second for ingress
	NetRecvPckps float64 `structs:"netio_recv_pckps"`
	// NetSendPckps is the package per second for egress
	NetSentPckps float64 `structs:"netio_sent_pckps"`
	// NetDroIn is the package dropped per second for ingress
	NetDropIn float64 `structs:"netio_drop_in"`
	// NetDropOut is the package dropped per second for egress
	NetDropOut float64 `structs:"netio_drop_out"`
	// NetFifoIn is the number of in FIFO buffer errors
	NetFifoIn float64 `structs:"netio_fifo_in"`
	// NetFifoOut is the number of out FIFO buffer errors
	NetFifoOut float64 `structs:"netio_fifo_out"`
	// NetErrin is the number of errors while receiving
	NetErrin float64 `structs:"netio_err_in"`
	// NetErrout is the number of errors while receiving
	NetErrout float64 `structs:"netio_err_out"`
}

type NodeCpu struct {

	// core used per second
	CpuTotal   float64   `structs:"cpu_total"`
	CpuPerCore []float64 `structs:"cpu_per_core"`
	CpuAvg     float64   `structs:"cpu_avg"`

	CpuStealTotal   float64   `structs:"cpu_steal_total"`
	CpuStealPerCore []float64 `structs:"cpu_steal_per_core"`
	// contains filtered or unexported fields
}

type NodeDiskIO struct {

	// disk io
	IOState map[string]DiskIOState `structs:"diskio_state"`
	// contains filtered or unexported fields
}

type NodeLoad struct {
	Load1Min  float64 `structs:"load_1min"`
	Load5Min  float64 `structs:"load_5min"`
	Load15Min float64 `structs:"load_15min"`
}

type NodeMemory struct {
	Total      float64 `structs:"memory_total"`
	UsageTotal float64 `structs:"memory_usage_total"`
	UsageCache float64 `structs:"memory_usage_cache"`
	UsageRss   float64 `structs:"memory_usage_rss"`
	Available  float64 `structs:"memory_available"`
}

type NodeNetwork struct {
	IfaceStats map[string]*IfaceStat `structs:"netio_stats"`
	// contains filtered or unexported fields
}

type NodeProcess struct {
	// Number of tasks in uninterruptible state
	NrUninterruptible uint64 `structs:"process_nr_uninterruptible"`
}

type NodeResourceState struct {
	Timestamp time.Time    `structs:"timestamp,omitempty"`
	CPU       *NodeCpu     `structs:"cpu"`
	Load      *NodeLoad    `structs:"load"`
	Memory    *NodeMemory  `structs:"memory"`
	DiskIO    *NodeDiskIO  `structs:"diskio"`
	NetIO     *NodeNetwork `structs:"netio"`
	Process   *NodeProcess `structs:"process"`
}

type NodeStore interface {
	NodeStoreInterface
	Name() string
	Run(stop <-chan struct{})
}

type NodeStoreInterface interface {
	GetNodeResourceRangeStats(start, end time.Time, count int) ([]*NodeResourceState, error)
	GetNodeResourceRecentState() (*NodeResourceState, error)
	GetNodeStoreSupportedTags() []string
}