deviceplugin

Documentation

Index

• type HostPathDevicePlugin
  • func NewHostPathDevicePlugin(cfg config.HostPathDevicePluginConfig) (*HostPathDevicePlugin, error)
  • 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
  • func MustNewRunner(cfg config.HostPathDevicePluginConfig) *Runner
  • func (r *Runner) Run()

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

func (*Runner) Run

func (r *Runner) Run()