package testdeviceplugin

import "k8s.io/kubernetes/test/e2e_node/testdeviceplugin"

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, request *kubeletdevicepluginv1beta1.PreferredAllocationRequest) (*kubeletdevicepluginv1beta1.PreferredAllocationResponse, error)
• func (dp *DevicePlugin) ListAndWatch(empty *kubeletdevicepluginv1beta1.Empty, stream kubeletdevicepluginv1beta1.DevicePlugin_ListAndWatchServer) error
• func (dp *DevicePlugin) PreStartContainer(ctx context.Context, request *kubeletdevicepluginv1beta1.PreStartContainerRequest) (*kubeletdevicepluginv1beta1.PreStartContainerResponse, error)
• func (dp *DevicePlugin) RegisterDevicePlugin(ctx context.Context, uniqueName, resourceName string, devices []kubeletdevicepluginv1beta1.Device) 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

Source Files ¶

device-plugin.go