cgroups

type BlkioDeviceBytes ¶

type BlkioDeviceBytes struct {
	Major      int
	Minor      int
	Operations map[string]int64
}

BlkioDeviceBytes contains a single operations line of blkio.throttle.io_service_bytes_recursive file

type BlkioThrottleBytes ¶

type BlkioThrottleBytes struct {
	DeviceBytes []*BlkioDeviceBytes
	TotalBytes  int64
}

BlkioThrottleBytes has parsed contents of blkio.throttle.io_service_bytes_recursive file

func GetBlkioThrottleBytes(cgroupPath string) (BlkioThrottleBytes, error)

type CPUAcctUsage ¶

type CPUAcctUsage struct {
	CPU    int
	User   int64
	System int64
}

CPUAcctUsage has a parsed line of cpuacct.usage_all file

func GetCPUAcctStats(cgroupPath string) ([]CPUAcctUsage, error)

type CgroupID ¶

type CgroupID struct {
	sync.Mutex
	// contains filtered or unexported fields
}

CgroupID implements mapping kernel cgroup IDs to cgroupfs paths with transparent caching.

func NewCgroupID(root string) *CgroupID

func (cgid *CgroupID) Find(id uint64) (string, error)

type Controller ¶ added in v0.6.0

type Controller int

Controller is our enumerated type for cgroup controllers.

const (
	// UnkownController represents a controller of unknown type.
	UnknownController Controller = iota
	// blkio cgroup controller.
	Blkio
	// cpu cgroup controller.
	Cpu
	// cpuacct cgroup controller.
	Cpuacct
	// cpuset cgroup controller.
	Cpuset
	// devices cgroup controller.
	Devices
	// freezer cgroup controller.
	Freezer
	// hugetlb cgroup controller.
	Hugetlb
	// memory cgroup controller.
	Memory
	// net_cls cgroup controller.
	NetCls
	// net_prio cgroup controller.
	NetPrio
	// per_event cgroup controller.
	PerfEvent
	// pids cgroup controller.
	Pids
)

func (c Controller) Group(group string) Group

func (c Controller) Path() string

func (c Controller) RelPath() string

func (c Controller) String() string

type GlobalNumaStats ¶

type GlobalNumaStats struct {
	NumaHit       int64
	NumaMiss      int64
	NumaForeign   int64
	InterleaveHit int64
	LocalNode     int64
	OtherNode     int64
}

GlobalNumaStats has the statistics from one global NUMA nodestats file.

type Group ¶ added in v0.6.0

type Group string

Group represents a control group.

func AsGroup(absDir string) Group

func (g Group) AddProcesses(pids ...string) error

func (g Group) AddTasks(pids ...string) error

func (g Group) Controller() Controller

func (g Group) GetProcesses() ([]string, error)

func (g Group) GetTasks() ([]string, error)

func (g Group) Write(entry, format string, args ...interface{}) error

type HugetlbUsage ¶

type HugetlbUsage struct {
	Size     string
	Bytes    int64
	MaxBytes int64
}

HugetlbUsage has parsed contents of huge pages usage in bytes.

func GetHugetlbUsage(cgroupPath string) ([]HugetlbUsage, error)

type MemoryUsage ¶

type MemoryUsage struct {
	Bytes    int64
	MaxBytes int64
}

MemoryUsage has parsed contents of memory usage in bytes.

func GetMemoryUsage(cgroupPath string) (MemoryUsage, error)

type NumaLine ¶

type NumaLine struct {
	Total int64
	Nodes map[string]int64
}

NumaLine represents one line in the NUMA statistics file.

type NumaStat ¶

type NumaStat struct {
	Total       NumaLine
	File        NumaLine
	Anon        NumaLine
	Unevictable NumaLine

	HierarchicalTotal       NumaLine
	HierarchicalFile        NumaLine
	HierarchicalAnon        NumaLine
	HierarchicalUnevictable NumaLine
}

NumaStat has parsed contets of a NUMA statistics file.

func GetNumaStats(cgroupPath string) (NumaStat, error)

type OciBlockIOParameters ¶

type OciBlockIOParameters struct {
	Weight                  int64
	WeightDevice            OciDeviceWeights
	ThrottleReadBpsDevice   OciDeviceRates
	ThrottleWriteBpsDevice  OciDeviceRates
	ThrottleReadIOPSDevice  OciDeviceRates
	ThrottleWriteIOPSDevice OciDeviceRates
}

OciBlockIOParameters contains OCI standard configuration of cgroups blkio parameters.

Effects of Weight and Rate values in SetBlkioParameters(): Value | Effect -------+-------------------------------------------------------------------

  -1  |  Do not write to cgroups, value is missing
   0  |  Write to cgroups, will remove the setting as specified in cgroups blkio interface
other |  Write to cgroups, sets the value

func GetBlkioParameters(cgroupsDir string) (OciBlockIOParameters, error)

func NewOciBlockIOParameters() OciBlockIOParameters

type OciDeviceParameters ¶

type OciDeviceParameters interface {
	Append(maj, min, val int64)
	Update(maj, min, val int64)
}

OciDeviceParameters interface provides functions common to OciDeviceWeights and OciDeviceRates

type OciDeviceRate ¶

type OciDeviceRate struct {
	Major int64
	Minor int64
	Rate  int64
}

OciDeviceRate contains values for - blkio.throttle.read_bps_device - blkio.throttle.write_bps_device - blkio.throttle.read_iops_device - blkio.throttle.write_iops_device

func NewOciDeviceRate() OciDeviceRate

type OciDeviceRates ¶

type OciDeviceRates []OciDeviceRate

OciDeviceRates contains throttling rates for devices

func (r *OciDeviceRates) Append(maj, min, val int64)

func (r *OciDeviceRates) Update(maj, min, val int64)

type OciDeviceWeight ¶

type OciDeviceWeight struct {
	Major  int64
	Minor  int64
	Weight int64
}

OciDeviceWeight contains values for - blkio.[io-scheduler].weight

func NewOciDeviceWeight() OciDeviceWeight

type OciDeviceWeights ¶

type OciDeviceWeights []OciDeviceWeight

OciDeviceWeights contains weights for devices

func (w *OciDeviceWeights) Append(maj, min, val int64)

func (w *OciDeviceWeights) Update(maj, min, val int64)