在线时间:8:00-16:00
迪恩网络APP
随时随地掌握行业动态
扫描二维码
关注迪恩网络微信公众号
开源软件名称:containerd/cgroups开源软件地址:https://github.com/containerd/cgroups开源编程语言:Go 99.6%开源软件介绍:cgroupsGo package for creating, managing, inspecting, and destroying cgroups. The resources format for settings on the cgroup uses the OCI runtime-spec found here. Examples (v1)Create a new cgroupThis creates a new cgroup using a static path for all subsystems under
It uses a single hierarchy and specifies cpu shares as a resource constraint and uses the v1 implementation of cgroups. shares := uint64(100)
control, err := cgroups.New(cgroups.V1, cgroups.StaticPath("/test"), &specs.LinuxResources{
CPU: &specs.LinuxCPU{
Shares: &shares,
},
})
defer control.Delete() Create with systemd slice supportcontrol, err := cgroups.New(cgroups.Systemd, cgroups.Slice("system.slice", "runc-test"), &specs.LinuxResources{
CPU: &specs.CPU{
Shares: &shares,
},
}) Load an existing cgroupcontrol, err = cgroups.Load(cgroups.V1, cgroups.StaticPath("/test")) Add a process to the cgroupif err := control.Add(cgroups.Process{Pid:1234}); err != nil {
} Update the cgroupTo update the resources applied in the cgroup shares = uint64(200)
if err := control.Update(&specs.LinuxResources{
CPU: &specs.LinuxCPU{
Shares: &shares,
},
}); err != nil {
} Freeze and Thaw the cgroupif err := control.Freeze(); err != nil {
}
if err := control.Thaw(); err != nil {
} List all processes in the cgroup or recursivelyprocesses, err := control.Processes(cgroups.Devices, recursive) Get Stats on the cgroupstats, err := control.Stat() By adding stats, err := control.Stat(cgroups.IgnoreNotExist) Move process across cgroupsThis allows you to take processes from one cgroup and move them to another. err := control.MoveTo(destination) Create subcgroupsubCgroup, err := control.New("child", resources) Registering for memory eventsThis allows you to get notified by an eventfd for v1 memory cgroups events. event := cgroups.MemoryThresholdEvent(50 * 1024 * 1024, false)
efd, err := control.RegisterMemoryEvent(event) event := cgroups.MemoryPressureEvent(cgroups.MediumPressure, cgroups.DefaultMode)
efd, err := control.RegisterMemoryEvent(event) efd, err := control.OOMEventFD()
// or by using RegisterMemoryEvent
event := cgroups.OOMEvent()
efd, err := control.RegisterMemoryEvent(event) Examples (v2/unified)Check that the current system is running cgroups v2var cgroupV2 bool
if cgroups.Mode() == cgroups.Unified {
cgroupV2 = true
} Create a new cgroupThis creates a new systemd v2 cgroup slice. Systemd slices consider "-" a special character, so the resulting slice would be located here on disk:
import (
cgroupsv2 "github.com/containerd/cgroups/v2"
specs "github.com/opencontainers/runtime-spec/specs-go"
)
res := cgroupsv2.Resources{}
// dummy PID of -1 is used for creating a "general slice" to be used as a parent cgroup.
// see https://github.com/containerd/cgroups/blob/1df78138f1e1e6ee593db155c6b369466f577651/v2/manager.go#L732-L735
m, err := cgroupsv2.NewSystemd("/", "my-cgroup-abc.slice", -1, &res)
if err != nil {
return err
} Load an existing cgroupm, err := cgroupsv2.LoadSystemd("/", "my-cgroup-abc.slice")
if err != nil {
return err
} Delete a cgroupm, err := cgroupsv2.LoadSystemd("/", "my-cgroup-abc.slice")
if err != nil {
return err
}
err = m.DeleteSystemd()
if err != nil {
return err
} AttentionAll static path should not include Project detailsCgroups is a containerd sub-project, licensed under the Apache 2.0 license. As a containerd sub-project, you will find the: information in our |
2023-10-27
2022-08-15
2022-08-17
2022-09-23
2022-08-13
请发表评论