cgroup

Documentation

Index

• Constants
• func GenerateDefaultDeviceRules() []*devices.Rule
• func GetGlobalCpuSetPath() string
• type CgroupVersion
• type Manager
  • func NewManagerFromPid(pid int) (manager Manager, err error)
  • func NewManagerFromVM(vmi *v1.VirtualMachineInstance) (Manager, error)
• type MockManager
  • func NewMockManager(ctrl *gomock.Controller) *MockManager
  • func (_m *MockManager) EXPECT() *_MockManagerRecorder
  • func (_m *MockManager) GetBasePathToHostSubsystem(subsystem string) (string, error)
  • func (_m *MockManager) GetCgroupVersion() CgroupVersion
  • func (_m *MockManager) GetCpuSet() (string, error)
  • func (_m *MockManager) Set(r *configs.Resources) error
• type MockruncManager
  • func NewMockruncManager(ctrl *gomock.Controller) *MockruncManager
  • func (_m *MockruncManager) Apply(pid int) error
  • func (_m *MockruncManager) Destroy() error
  • func (_m *MockruncManager) EXPECT() *_MockruncManagerRecorder
  • func (_m *MockruncManager) Exists() bool
  • func (_m *MockruncManager) Freeze(state configs.FreezerState) error
  • func (_m *MockruncManager) GetAllPids() ([]int, error)
  • func (_m *MockruncManager) GetCgroups() (*configs.Cgroup, error)
  • func (_m *MockruncManager) GetFreezerState() (configs.FreezerState, error)
  • func (_m *MockruncManager) GetPaths() map[string]string
  • func (_m *MockruncManager) GetPids() ([]int, error)
  • func (_m *MockruncManager) GetStats() (*cgroups.Stats, error)
  • func (_m *MockruncManager) OOMKillCount() (uint64, error)
  • func (_m *MockruncManager) Path(_param0 string) string
  • func (_m *MockruncManager) Set(r *configs.Resources) error

Constants

const (
	HostRootPath = procMountPoint + "/1/root"

	HostCgroupBasePath = HostRootPath + cgroupBasePath
)

Functions

func GenerateDefaultDeviceRules

func GenerateDefaultDeviceRules() []*devices.Rule

func GetGlobalCpuSetPath

func GetGlobalCpuSetPath() string

GetGlobalCpuSetPath returns the CPU set of the main cgroup slice

Types

type CgroupVersion

type CgroupVersion string

const (
	V1 CgroupVersion = "v1"
	V2 CgroupVersion = "v2"
)

Templates for logging / error messages

type Manager

type Manager interface {
	Set(r *configs.Resources) error

	// GetBasePathToHostSubsystem returns the path to the specified subsystem
	// from the host's viewpoint.
	GetBasePathToHostSubsystem(subsystem string) (string, error)

	// GetCgroupVersion returns the current cgroup version (i.e. v1 or v2)
	GetCgroupVersion() CgroupVersion

	// GetCpuSet returns the cpu set
	GetCpuSet() (string, error)
}

Manager is the only interface to use in order to inspect, update or define cgroup properties. This interface is agnostic to cgroups version (supports v1 and v2) and is completely transparent from the users perspective. To achieve this "runc"'s cgroup manager is being levitated. This package's implementation guide-line is to have the thinnest glue layer possible in order to have all runc's capabilities without extra effort. This interface can, of course, extend runc and introduce new functionalities that are specific to Kubevirt's use.

func NewManagerFromPid

func NewManagerFromPid(pid int) (manager Manager, err error)

NewManagerFromPid initializes a new cgroup manager from VMI's pid. The pid is expected to VMI's pid from the host's viewpoint.

func NewManagerFromVM

func NewManagerFromVM(vmi *v1.VirtualMachineInstance) (Manager, error)

type MockManager

type MockManager struct {
	// contains filtered or unexported fields
}

Mock of Manager interface

func NewMockManager

func NewMockManager(ctrl *gomock.Controller) *MockManager

func (*MockManager) EXPECT

func (_m *MockManager) EXPECT() *_MockManagerRecorder

func (*MockManager) GetBasePathToHostSubsystem

func (_m *MockManager) GetBasePathToHostSubsystem(subsystem string) (string, error)

func (*MockManager) GetCgroupVersion

func (_m *MockManager) GetCgroupVersion() CgroupVersion

func (*MockManager) GetCpuSet

func (_m *MockManager) GetCpuSet() (string, error)

func (*MockManager) Set

func (_m *MockManager) Set(r *configs.Resources) error

type MockruncManager

type MockruncManager struct {
	// contains filtered or unexported fields
}

Mock of runcManager interface

func NewMockruncManager

func NewMockruncManager(ctrl *gomock.Controller) *MockruncManager

func (*MockruncManager) Apply

func (_m *MockruncManager) Apply(pid int) error

func (*MockruncManager) Destroy

func (_m *MockruncManager) Destroy() error

func (*MockruncManager) EXPECT

func (_m *MockruncManager) EXPECT() *_MockruncManagerRecorder

func (*MockruncManager) Exists

func (_m *MockruncManager) Exists() bool

func (*MockruncManager) Freeze

func (_m *MockruncManager) Freeze(state configs.FreezerState) error

func (*MockruncManager) GetAllPids

func (_m *MockruncManager) GetAllPids() ([]int, error)

func (*MockruncManager) GetCgroups

func (_m *MockruncManager) GetCgroups() (*configs.Cgroup, error)

func (*MockruncManager) GetFreezerState

func (_m *MockruncManager) GetFreezerState() (configs.FreezerState, error)

func (*MockruncManager) GetPaths

func (_m *MockruncManager) GetPaths() map[string]string

func (*MockruncManager) GetPids

func (_m *MockruncManager) GetPids() ([]int, error)

func (*MockruncManager) GetStats

func (_m *MockruncManager) GetStats() (*cgroups.Stats, error)

func (*MockruncManager) OOMKillCount

func (_m *MockruncManager) OOMKillCount() (uint64, error)

func (*MockruncManager) Path

func (_m *MockruncManager) Path(_param0 string) string

func (*MockruncManager) Set

func (_m *MockruncManager) Set(r *configs.Resources) error