cgroup

package
v0.0.0-...-b84de06 Latest Latest
Warning

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

 Go to latest Published: Aug 9, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Unavailable indicates the lack of controller.
	Unavailable = Backend(0)

	// V1 indicates the controller is backed by Cgroup V1.
	V1 = Backend(1)

	// V2 indicates the controller is backed by Cgroup V2.
	V2 = Backend(2)
)

Variables

View Source 
var DeviceSchedRebalance = make(chan []string, 2)

DeviceSchedRebalance channel for scheduling a CPU rebalance.

View Source 
var ErrControllerMissing = fmt.Errorf("Cgroup controller is missing")

ErrControllerMissing indicates that the requested controller isn't setup on the system.

View Source 
var ErrUnknownVersion = fmt.Errorf("Unknown cgroup version")

ErrUnknownVersion indicates that a version other than those supported was detected during init.

Functions

func ParseCPU 

func ParseCPU(cpuAllowance string, cpuPriority string) (string, string, string, error)

ParseCPU parses CPU allowances.

func TaskSchedulerTrigger 

func TaskSchedulerTrigger(srcType string, srcName string, srcStatus string)

TaskSchedulerTrigger triggers a CPU rebalance.

Types

type Backend 

type Backend int

Backend indicates whether to use v1, v2 or unavailable.

type CGroup 

type CGroup struct {
	UnifiedCapable bool
	// contains filtered or unexported fields
}

CGroup represents the main cgroup abstraction.

func New 

func New(rw ReadWriter) (*CGroup, error)

New setups a new CGroup abstraction using the provided read/writer.

func (*CGroup) GetBlkioWeight 

func (cg *CGroup) GetBlkioWeight() (string, error)

GetBlkioWeight returns the currently allowed range of weights

func (*CGroup) GetCPUAcctUsage 

func (cg *CGroup) GetCPUAcctUsage() (string, error)

GetCPUAcctUsage returns the total CPU time in ns used by processes

func (*CGroup) GetMaxMemory 

func (cg *CGroup) GetMaxMemory() (string, error)

GetMaxMemory return the hard limit for memory

func (*CGroup) GetMemoryMaxUsage 

func (cg *CGroup) GetMemoryMaxUsage() (string, error)

GetMemoryMaxUsage returns the record high for memory usage

func (*CGroup) GetMemorySoftLimit 

func (cg *CGroup) GetMemorySoftLimit() (string, error)

GetMemorySoftLimit returns the soft limit for memory

func (*CGroup) GetMemorySwMaxUsage 

func (cg *CGroup) GetMemorySwMaxUsage() (string, error)

GetMemorySwMaxUsage returns the record high for swap usage

func (*CGroup) GetMemorySwapLimit 

func (cg *CGroup) GetMemorySwapLimit() (string, error)

GetMemorySwapLimit returns the hard limit on swap usage

func (*CGroup) GetMemorySwapUsage 

func (cg *CGroup) GetMemorySwapUsage() (string, error)

GetMemorySwapUsage return current usage of swap

func (*CGroup) GetMemoryUsage 

func (cg *CGroup) GetMemoryUsage() (string, error)

GetMemoryUsage returns the current use of memory

func (*CGroup) GetProcessesUsage 

func (cg *CGroup) GetProcessesUsage() (string, error)

GetProcessesUsage returns the current number of pids

func (*CGroup) SetBlkioWeight 

func (cg *CGroup) SetBlkioWeight(value string) error

SetBlkioWeight set the currently allowed range of weights

func (*CGroup) SetCPUCfsPeriod 

func (cg *CGroup) SetCPUCfsPeriod(value string) error

SetCPUCfsPeriod sets the duration in ms for each scheduling period

func (*CGroup) SetCPUCfsQuota 

func (cg *CGroup) SetCPUCfsQuota(value string) error

SetCPUCfsQuota sets the max time in ms during each cfs_period_us that the current group can run for

func (*CGroup) SetCPUShare 

func (cg *CGroup) SetCPUShare(value string) error

SetCPUShare sets the weight of each group in the same hierarchy

func (*CGroup) SetMaxHugepages 

func (cg *CGroup) SetMaxHugepages(pageType string, value string) error

SetMaxHugepages applies a limit to the number of processes

func (*CGroup) SetMaxProcesses 

func (cg *CGroup) SetMaxProcesses(max int64) error

SetMaxProcesses applies a limit to the number of processes

func (*CGroup) SetMemoryMaxUsage 

func (cg *CGroup) SetMemoryMaxUsage(max string) error

SetMemoryMaxUsage sets the hard limit for memory

func (*CGroup) SetMemorySoftLimit 

func (cg *CGroup) SetMemorySoftLimit(softLim string) error

SetMemorySoftLimit set the soft limit for memory

func (*CGroup) SetMemorySwapMax 

func (cg *CGroup) SetMemorySwapMax(max string) error

SetMemorySwapMax sets the hard limit for swap

func (*CGroup) SetMemorySwappiness 

func (cg *CGroup) SetMemorySwappiness(value string) error

SetMemorySwappiness sets swappiness paramet of vmscan

func (*CGroup) SetNetIfPrio 

func (cg *CGroup) SetNetIfPrio(value string) error

SetNetIfPrio sets the priority for the process

type Info 

type Info struct {
	// Layout is one of CgroupsDisabled, CgroupsUnified, CgroupsHybrid, CgroupsLegacy
	Layout Layout

	// Namespacing indicates support for the cgroup namespace
	Namespacing bool
}

Info contains system cgroup information

func GetInfo 

func GetInfo() Info

GetInfo returns basic system cgroup information

func (*Info) Log 

func (info *Info) Log()

Log logs cgroup info

func (*Info) Mode 

func (info *Info) Mode() string

Mode returns the cgroup layout name

func (*Info) Supports 

func (info *Info) Supports(resource Resource, cgroup *CGroup) bool

Supports indicates whether or not a given resource is controllable.

func (*Info) SupportsVersion 

func (info *Info) SupportsVersion(resource Resource) (Backend, bool)

SupportsVersion indicates whether or not a given cgroup resource is controllable and in which type of cgroup filesystem.

type Layout 

type Layout int

Layout determines the cgroup layout on this system 

const (
	// CgroupsDisabled indicates that cgroups are not supported
	CgroupsDisabled Layout = iota
	// CgroupsUnified indicates that this is a pure cgroup2 layout
	CgroupsUnified
	// CgroupsHybrid indicates that this is a mixed cgroup1 and cgroup2 layout
	CgroupsHybrid
	// CgroupsLegacy indicates that this is a pure cgroup1 layout
	CgroupsLegacy
)

type ReadWriter 

type ReadWriter interface {
	Get(backend Backend, controller string, key string) (string, error)
	Set(backend Backend, controller string, key string, value string) error
}

The ReadWriter interface is used to read/write cgroup data.

type Resource 

type Resource int

Resource is a generic type used to abstract resource control features support for the legacy and unified hierarchy. 

const (
	// Blkio resource control
	Blkio Resource = iota

	// BlkioWeight resource control
	BlkioWeight

	// CPU resource control
	CPU

	// CPUAcct resource control
	CPUAcct

	// CPUSet resource control
	CPUSet

	// Devices resource control
	Devices

	// Freezer resource control
	Freezer

	// Hugetlb resource control
	Hugetlb

	// Memory resource control
	Memory

	// MemoryMaxUsage resource control
	MemoryMaxUsage

	// MemorySwap resource control
	MemorySwap

	// MemorySwapMaxUsage resource control
	MemorySwapMaxUsage

	// MemorySwapUsage resource control
	MemorySwapUsage

	// MemorySwappiness resource control
	MemorySwappiness

	// NetPrio resource control
	NetPrio

	// Pids resource control
	Pids
)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.