plugins

Documentation

Index

• Constants
• type BlockDevicePlugin
  • func (m *BlockDevicePlugin) Allocate(ctx context.Context, reqs *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)
  • func (m *BlockDevicePlugin) GetDevicePluginOptions(context.Context, *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)
  • func (m *BlockDevicePlugin) GetPreferredAllocation(context.Context, *pluginapi.PreferredAllocationRequest) (*pluginapi.PreferredAllocationResponse, error)
  • func (m *BlockDevicePlugin) ListAndWatch(e *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error
  • func (m *BlockDevicePlugin) PreStartContainer(context.Context, *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)
  • func (m *BlockDevicePlugin) Register(kubeletEndpoint, resourceName string) error
  • func (m *BlockDevicePlugin) Serve() error
  • func (m *BlockDevicePlugin) Start() error
  • func (m *BlockDevicePlugin) Stop() error
• type DevicePlugin
  • func NewBlockDevicePlugin() (DevicePlugin, error)
  • func NewFuseDevicePlugin(number int) DevicePlugin
• type FuseDevicePlugin
  • func (m *FuseDevicePlugin) Allocate(ctx context.Context, reqs *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)
  • func (m *FuseDevicePlugin) GetDevicePluginOptions(context.Context, *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)
  • func (m *FuseDevicePlugin) GetPreferredAllocation(context.Context, *pluginapi.PreferredAllocationRequest) (*pluginapi.PreferredAllocationResponse, error)
  • func (m *FuseDevicePlugin) ListAndWatch(e *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error
  • func (m *FuseDevicePlugin) PreStartContainer(context.Context, *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)
  • func (m *FuseDevicePlugin) Register(kubeletEndpoint, resourceName string) error
  • func (m *FuseDevicePlugin) Serve() error
  • func (m *FuseDevicePlugin) Start() error
  • func (m *FuseDevicePlugin) Stop() error

Constants

const (
	FuseServerSock = pluginapi.DevicePluginPath + "fuse.sock"
)

Types

type BlockDevicePlugin

type BlockDevicePlugin struct {
	Exec utilexec.Interface
	// contains filtered or unexported fields
}

BlockDevicePlugin implements the Kubernetes device plugin API

func (*BlockDevicePlugin) Allocate

func (m *BlockDevicePlugin) Allocate(ctx context.Context, reqs *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)

Allocate which return list of devices.

func (*BlockDevicePlugin) GetDevicePluginOptions

func (m *BlockDevicePlugin) GetDevicePluginOptions(context.Context, *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)

func (*BlockDevicePlugin) GetPreferredAllocation

func (m *BlockDevicePlugin) GetPreferredAllocation(context.Context, *pluginapi.PreferredAllocationRequest) (*pluginapi.PreferredAllocationResponse, error)

func (*BlockDevicePlugin) ListAndWatch

func (m *BlockDevicePlugin) ListAndWatch(e *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error

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

func (*BlockDevicePlugin) PreStartContainer

func (m *BlockDevicePlugin) PreStartContainer(context.Context, *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)

func (*BlockDevicePlugin) Register

func (m *BlockDevicePlugin) Register(kubeletEndpoint, resourceName string) error

Register registers the device plugin for the given resourceName with Kubelet.

func (*BlockDevicePlugin) Serve

func (m *BlockDevicePlugin) Serve() error

Serve starts the gRPC server and register the device plugin to Kubelet

func (*BlockDevicePlugin) Start

func (m *BlockDevicePlugin) Start() error

Start starts the gRPC server of the device plugin

func (*BlockDevicePlugin) Stop

func (m *BlockDevicePlugin) Stop() error

Stop stops the gRPC server

type DevicePlugin

type DevicePlugin interface {
	Serve() error
	Stop() error
}

func NewBlockDevicePlugin

func NewBlockDevicePlugin() (DevicePlugin, error)

func NewFuseDevicePlugin

func NewFuseDevicePlugin(number int) DevicePlugin

type FuseDevicePlugin

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

FuseDevicePlugin implements the Kubernetes device plugin API

func (*FuseDevicePlugin) Allocate

func (m *FuseDevicePlugin) Allocate(ctx context.Context, reqs *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)

Allocate which return list of devices.

func (*FuseDevicePlugin) GetDevicePluginOptions

func (m *FuseDevicePlugin) GetDevicePluginOptions(context.Context, *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)

func (*FuseDevicePlugin) GetPreferredAllocation

func (m *FuseDevicePlugin) GetPreferredAllocation(context.Context, *pluginapi.PreferredAllocationRequest) (*pluginapi.PreferredAllocationResponse, error)

func (*FuseDevicePlugin) ListAndWatch

func (m *FuseDevicePlugin) ListAndWatch(e *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error

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

func (*FuseDevicePlugin) PreStartContainer

func (m *FuseDevicePlugin) PreStartContainer(context.Context, *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)

func (*FuseDevicePlugin) Register

func (m *FuseDevicePlugin) Register(kubeletEndpoint, resourceName string) error

Register registers the device plugin for the given resourceName with Kubelet.

func (*FuseDevicePlugin) Serve

func (m *FuseDevicePlugin) Serve() error

Serve starts the gRPC server and register the device plugin to Kubelet

func (*FuseDevicePlugin) Start

func (m *FuseDevicePlugin) Start() error

Start starts the gRPC server of the device plugin

func (*FuseDevicePlugin) Stop

func (m *FuseDevicePlugin) Stop() error

Stop stops the gRPC server