Documentation
¶
Index ¶
- type HostPathDevicePlugin
- func (m *HostPathDevicePlugin) Allocate(ctx context.Context, request *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)
- func (m *HostPathDevicePlugin) GetDevicePluginOptions(context.Context, *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)
- func (m *HostPathDevicePlugin) GetPreferredAllocation(context.Context, *pluginapi.PreferredAllocationRequest) (*pluginapi.PreferredAllocationResponse, error)
- func (m *HostPathDevicePlugin) ListAndWatch(e *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error
- func (m *HostPathDevicePlugin) PreStartContainer(context.Context, *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)
- func (m *HostPathDevicePlugin) Register(kubeletEndpoint, resourceName string) error
- func (m *HostPathDevicePlugin) Serve() error
- func (m *HostPathDevicePlugin) Start() error
- func (m *HostPathDevicePlugin) Stop() error
- type Runner
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HostPathDevicePlugin ¶
type HostPathDevicePlugin struct {
// contains filtered or unexported fields
}
NewHostPathDevicePlugin implements the Kubernetes device plugin API
func NewHostPathDevicePlugin ¶
func NewHostPathDevicePlugin(cfg config.HostPathDevicePluginConfig) (*HostPathDevicePlugin, error)
NewHostPathDevicePlugin returns an initialized NewHostPathDevicePlugin
func (*HostPathDevicePlugin) Allocate ¶
func (m *HostPathDevicePlugin) Allocate(ctx context.Context, request *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)
Allocate which return list of devices.
func (*HostPathDevicePlugin) GetDevicePluginOptions ¶
func (m *HostPathDevicePlugin) GetDevicePluginOptions(context.Context, *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)
func (*HostPathDevicePlugin) GetPreferredAllocation ¶
func (m *HostPathDevicePlugin) GetPreferredAllocation(context.Context, *pluginapi.PreferredAllocationRequest) (*pluginapi.PreferredAllocationResponse, error)
func (*HostPathDevicePlugin) ListAndWatch ¶
func (m *HostPathDevicePlugin) ListAndWatch(e *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error
ListAndWatch lists devices and update that list according to the health status
func (*HostPathDevicePlugin) PreStartContainer ¶
func (m *HostPathDevicePlugin) PreStartContainer(context.Context, *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)
func (*HostPathDevicePlugin) Register ¶
func (m *HostPathDevicePlugin) Register(kubeletEndpoint, resourceName string) error
Register registers the device plugin for the given resourceName with Kubelet.
func (*HostPathDevicePlugin) Serve ¶
func (m *HostPathDevicePlugin) Serve() error
Serve starts the gRPC server and register the device plugin to Kubelet
func (*HostPathDevicePlugin) Start ¶
func (m *HostPathDevicePlugin) Start() error
Start starts the gRPC server of the device plugin
func (*HostPathDevicePlugin) Stop ¶
func (m *HostPathDevicePlugin) Stop() error
Stop stops the gRPC server
type Runner ¶
type Runner struct {
// contains filtered or unexported fields
}
func MustNewRunner ¶
func MustNewRunner( cfg config.HostPathDevicePluginConfig, ) *Runner
Source Files
Click to show internal directories.
Click to hide internal directories.