cgroup

type CgroupVersion ¶ added in v0.50.0

type CgroupVersion string

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

type Manager ¶ added in v0.50.0

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)

	// SetCpuSet returns the cpu set
	SetCpuSet(subcgroup string, cpulist []int) error

	// Create new child cgroup
	CreateChildCgroup(name string, subSystem string) error

	// Attach TID to cgroup
	AttachTID(subSystem string, subCgroup string, tid int) error

	// Get list of threads attached to cgroup
	GetCgroupThreads() ([]int, 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 NewManagerFromVM(vmi *v1.VirtualMachineInstance) (Manager, error)

type MockManager ¶ added in v0.50.0

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

Mock of Manager interface

func NewMockManager(ctrl *gomock.Controller) *MockManager

func (_m *MockManager) AttachTID(subSystem string, subCgroup string, tid int) error

func (_m *MockManager) CreateChildCgroup(name string, subSystem string) error

func (_m *MockManager) EXPECT() *_MockManagerRecorder

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

func (_m *MockManager) GetCgroupThreads() ([]int, error)

func (_m *MockManager) GetCgroupVersion() CgroupVersion

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

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

func (_m *MockManager) SetCpuSet(subcgroup string, cpulist []int) error

type MockruncManager ¶ added in v0.56.0

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

Mock of runcManager interface

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