ed47d6ba76
The rpc only reports one field, i.e. the cgroup driver, to kubelet. Containerd determines the effective cgroup driver by looking at all runtime handlers, starting from the default runtime handler (the rest in alphabetical order), and returning the cgroup driver setting of the first runtime handler that supports one. If no runtime handler supports cgroup driver (i.e. has a config option for it) containerd falls back to auto-detection, returning systemd if systemd is running and cgroupfs otherwise. This patch implements the CRI server side of Kubernetes KEP-4033: https://github.com/kubernetes/enhancements/tree/master/keps/sig-node/4033-group-driver-detection-over-cri Signed-off-by: Markus Lehtonen <markus.lehtonen@intel.com>
67 lines
2.1 KiB
Go
67 lines
2.1 KiB
Go
package configs
|
|
|
|
import "fmt"
|
|
|
|
// blockIODevice holds major:minor format supported in blkio cgroup
|
|
type blockIODevice struct {
|
|
// Major is the device's major number
|
|
Major int64 `json:"major"`
|
|
// Minor is the device's minor number
|
|
Minor int64 `json:"minor"`
|
|
}
|
|
|
|
// WeightDevice struct holds a `major:minor weight`|`major:minor leaf_weight` pair
|
|
type WeightDevice struct {
|
|
blockIODevice
|
|
// Weight is the bandwidth rate for the device, range is from 10 to 1000
|
|
Weight uint16 `json:"weight"`
|
|
// LeafWeight is the bandwidth rate for the device while competing with the cgroup's child cgroups, range is from 10 to 1000, cfq scheduler only
|
|
LeafWeight uint16 `json:"leafWeight"`
|
|
}
|
|
|
|
// NewWeightDevice returns a configured WeightDevice pointer
|
|
func NewWeightDevice(major, minor int64, weight, leafWeight uint16) *WeightDevice {
|
|
wd := &WeightDevice{}
|
|
wd.Major = major
|
|
wd.Minor = minor
|
|
wd.Weight = weight
|
|
wd.LeafWeight = leafWeight
|
|
return wd
|
|
}
|
|
|
|
// WeightString formats the struct to be writable to the cgroup specific file
|
|
func (wd *WeightDevice) WeightString() string {
|
|
return fmt.Sprintf("%d:%d %d", wd.Major, wd.Minor, wd.Weight)
|
|
}
|
|
|
|
// LeafWeightString formats the struct to be writable to the cgroup specific file
|
|
func (wd *WeightDevice) LeafWeightString() string {
|
|
return fmt.Sprintf("%d:%d %d", wd.Major, wd.Minor, wd.LeafWeight)
|
|
}
|
|
|
|
// ThrottleDevice struct holds a `major:minor rate_per_second` pair
|
|
type ThrottleDevice struct {
|
|
blockIODevice
|
|
// Rate is the IO rate limit per cgroup per device
|
|
Rate uint64 `json:"rate"`
|
|
}
|
|
|
|
// NewThrottleDevice returns a configured ThrottleDevice pointer
|
|
func NewThrottleDevice(major, minor int64, rate uint64) *ThrottleDevice {
|
|
td := &ThrottleDevice{}
|
|
td.Major = major
|
|
td.Minor = minor
|
|
td.Rate = rate
|
|
return td
|
|
}
|
|
|
|
// String formats the struct to be writable to the cgroup specific file
|
|
func (td *ThrottleDevice) String() string {
|
|
return fmt.Sprintf("%d:%d %d", td.Major, td.Minor, td.Rate)
|
|
}
|
|
|
|
// StringName formats the struct to be writable to the cgroup specific file
|
|
func (td *ThrottleDevice) StringName(name string) string {
|
|
return fmt.Sprintf("%d:%d %s=%d", td.Major, td.Minor, name, td.Rate)
|
|
}
|