cpusetdevice

package

v1.29.0 Latest Latest Go to latest Published: Mar 18, 2024 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Tencent/bk-bcs

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func IsNumaAvailable() bool
func NUMACPUsOfNode(node string) ([]string, error)
func NUMAConfiguredCPUs() int
func NUMANodes() ([]string, error)
type CpusetDevicePlugin
- func NewCpusetDevicePlugin(conf *config.Config) *CpusetDevicePlugin

Constants ¶

View Source

const (
	// KubeletSocketName socket file name for kubelet
	KubeletSocketName = "kubelet.sock"
	// CpusetSocketName socket file name for cpuset
	CpusetSocketName = "bcs-cpuset-device.sock"
	// CpusetResourceName resource name for cpuset
	CpusetResourceName = "bkbcs.tencent.com/cpuset"

	// EnvBkbcsAllocateCpuset docker env, examples: bkbcs_allocate_cpuset=node:0;cpuset:0,1,2,3
	EnvBkbcsAllocateCpuset = "bkbcs_allocate_cpuset"

	// EnvBcsCpusetCheckIntervalMinute env name for check interval
	EnvBcsCpusetCheckIntervalMinute = "BKBCS_CPUSET_CHECK_INTERVAL_MINUTE"
	// EnvBcsCpusetCleanDelayMinute env name for cpuset expire duration
	EnvBcsCpusetCleanDelayMinute = "BKBCS_CPUSET_CLEAN_DELAY_MINUTE"
)

Variables ¶

View Source

var ErrNumaNotAvailable = fmt.Errorf("No NUMA support available on this system")

ErrNumaNotAvailable error type for NUMA

Functions ¶

func IsNumaAvailable ¶

func IsNumaAvailable() bool

IsNumaAvailable Is Numa available

func NUMACPUsOfNode ¶

func NUMACPUsOfNode(node string) ([]string, error)

NUMACPUsOfNode Get CPU slice from the specified Node

func NUMAConfiguredCPUs ¶

func NUMAConfiguredCPUs() int

NUMAConfiguredCPUs get configure cpu number

func NUMANodes ¶

func NUMANodes() ([]string, error)

NUMANodes Get Numa Nodes

Types ¶

type CpusetDevicePlugin ¶

type CpusetDevicePlugin struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

CpusetDevicePlugin device plugin for cpuset

func NewCpusetDevicePlugin ¶

func NewCpusetDevicePlugin(conf *config.Config) *CpusetDevicePlugin

NewCpusetDevicePlugin new cpuset device plugin

func (*CpusetDevicePlugin) Allocate ¶

func (c *CpusetDevicePlugin) Allocate(ctx context.Context, reqs *pluginapi.AllocateRequest) (
	*pluginapi.AllocateResponse, error)

Allocate which return list of devices.

func (*CpusetDevicePlugin) GetDevicePluginOptions ¶

func (c *CpusetDevicePlugin) GetDevicePluginOptions(context.Context, *pluginapi.Empty) (
	*pluginapi.DevicePluginOptions, error)

GetDevicePluginOptions get device plugin options

func (*CpusetDevicePlugin) ListAndWatch ¶

func (c *CpusetDevicePlugin) ListAndWatch(e *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error

ListAndWatch lists devices and update that list according to the health status

func (*CpusetDevicePlugin) PreStartContainer ¶

func (c *CpusetDevicePlugin) PreStartContainer(context.Context, *pluginapi.PreStartContainerRequest) (
	*pluginapi.PreStartContainerResponse, error)

PreStartContainer callback before starting container

func (*CpusetDevicePlugin) Start ¶

func (c *CpusetDevicePlugin) Start() error

Start start cpu device plugin

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL