testdeviceplugin

Documentation

Index

• type DevicePlugin
  • func NewDevicePlugin(errorInjector func(string) error) *DevicePlugin
  • func (dp *DevicePlugin) Allocate(ctx context.Context, request *kubeletdevicepluginv1beta1.AllocateRequest) (*kubeletdevicepluginv1beta1.AllocateResponse, error)
  • func (dp *DevicePlugin) Calls() []string
  • func (dp *DevicePlugin) GetDevicePluginOptions(context.Context, *kubeletdevicepluginv1beta1.Empty) (*kubeletdevicepluginv1beta1.DevicePluginOptions, error)
  • func (dp *DevicePlugin) GetPreferredAllocation(ctx context.Context, ...) (*kubeletdevicepluginv1beta1.PreferredAllocationResponse, error)
  • func (dp *DevicePlugin) ListAndWatch(empty *kubeletdevicepluginv1beta1.Empty, ...) error
  • func (dp *DevicePlugin) PreStartContainer(ctx context.Context, ...) (*kubeletdevicepluginv1beta1.PreStartContainerResponse, error)
  • func (dp *DevicePlugin) RegisterDevicePlugin(ctx context.Context, uniqueName, resourceName string, ...) error
  • func (dp *DevicePlugin) Stop()
  • func (dp *DevicePlugin) UpdateDevices(devices []kubeletdevicepluginv1beta1.Device)
  • func (dp *DevicePlugin) WasCalled(method string) bool

Types

type DevicePlugin

type DevicePlugin struct {
	// contains filtered or unexported fields
}

func NewDevicePlugin

func NewDevicePlugin(errorInjector func(string) error) *DevicePlugin

func (*DevicePlugin) Allocate

func (dp *DevicePlugin) Allocate(ctx context.Context, request *kubeletdevicepluginv1beta1.AllocateRequest) (*kubeletdevicepluginv1beta1.AllocateResponse, error)

func (*DevicePlugin) Calls

func (dp *DevicePlugin) Calls() []string

func (*DevicePlugin) GetDevicePluginOptions

func (dp *DevicePlugin) GetDevicePluginOptions(context.Context, *kubeletdevicepluginv1beta1.Empty) (*kubeletdevicepluginv1beta1.DevicePluginOptions, error)

func (*DevicePlugin) GetPreferredAllocation

func (dp *DevicePlugin) GetPreferredAllocation(ctx context.Context, request *kubeletdevicepluginv1beta1.PreferredAllocationRequest) (*kubeletdevicepluginv1beta1.PreferredAllocationResponse, error)

func (*DevicePlugin) ListAndWatch

func (dp *DevicePlugin) ListAndWatch(empty *kubeletdevicepluginv1beta1.Empty, stream kubeletdevicepluginv1beta1.DevicePlugin_ListAndWatchServer) error

func (*DevicePlugin) PreStartContainer

func (dp *DevicePlugin) PreStartContainer(ctx context.Context, request *kubeletdevicepluginv1beta1.PreStartContainerRequest) (*kubeletdevicepluginv1beta1.PreStartContainerResponse, error)

func (*DevicePlugin) RegisterDevicePlugin

func (dp *DevicePlugin) RegisterDevicePlugin(ctx context.Context, uniqueName, resourceName string, devices []kubeletdevicepluginv1beta1.Device) error

func (*DevicePlugin) Stop

func (dp *DevicePlugin) Stop()

func (*DevicePlugin) UpdateDevices

func (dp *DevicePlugin) UpdateDevices(devices []kubeletdevicepluginv1beta1.Device)

func (*DevicePlugin) WasCalled

func (dp *DevicePlugin) WasCalled(method string) bool