plugin

Documentation

Index

• Constants
• func NewFSWatcher(files ...string) (*fsnotify.Watcher, error)
• type DevicePluginServer
  • func (p *DevicePluginServer) Register() error
  • func (p *DevicePluginServer) Run(stop <-chan struct{})
  • func (p *DevicePluginServer) Serve(stop <-chan struct{})
  • func (p *DevicePluginServer) Wait() error
• type OrinDeviceConfig
• type OrinDeviceGrpcServer
  • func NewOrinDeviceGrpcServer(c *OrinDeviceConfig, resourceName string, orinID int, boardIDSets sets.Int) (*OrinDeviceGrpcServer, error)
  • func (s *OrinDeviceGrpcServer) Allocate(ctx context.Context, request *v1beta1.AllocateRequest) (*v1beta1.AllocateResponse, error)
  • func (s *OrinDeviceGrpcServer) GetDevicePluginOptions(ctx context.Context, empty *v1beta1.Empty) (*v1beta1.DevicePluginOptions, error)
  • func (s *OrinDeviceGrpcServer) GetPreferredAllocation(ctx context.Context, request *v1beta1.PreferredAllocationRequest) (*v1beta1.PreferredAllocationResponse, error)
  • func (s *OrinDeviceGrpcServer) ListAndWatch(empty *v1beta1.Empty, server v1beta1.DevicePlugin_ListAndWatchServer) error
  • func (s *OrinDeviceGrpcServer) PreStartContainer(ctx context.Context, request *v1beta1.PreStartContainerRequest) (*v1beta1.PreStartContainerResponse, error)
• type OrinDevicePlugin
  • func NewOrinDevicePlugin(c *OrinDeviceConfig) (OrinDevicePlugin, error)
  • func (odp OrinDevicePlugin) Run(stop <-chan struct{})

Constants

const (
	HostVitualPath = "/data/edge/device"
)

Functions

func NewFSWatcher

func NewFSWatcher(files ...string) (*fsnotify.Watcher, error)

Types

type DevicePluginServer

type DevicePluginServer struct {
	Endpoint           string
	ResourceName       string
	DevicePluginServer v1beta1.DevicePluginServer
}

func (*DevicePluginServer) Register

func (p *DevicePluginServer) Register() error

func (*DevicePluginServer) Run

func (p *DevicePluginServer) Run(stop <-chan struct{})

func (*DevicePluginServer) Serve

func (p *DevicePluginServer) Serve(stop <-chan struct{})

func (*DevicePluginServer) Wait

func (p *DevicePluginServer) Wait() error

type OrinDeviceConfig

type OrinDeviceConfig struct {
	DeviceLocator  map[v1.ResourceName]kubeapis.DeviceLocator
	Sitter         kubeapis.Sitter
	DeviceProvider provider.DeviceProvider
	NodeName       string
	ClientSet      *kubernetes.Clientset
}

type OrinDeviceGrpcServer

type OrinDeviceGrpcServer struct {
	OrinID       int
	ResourceName v1.ResourceName

	*OrinDeviceConfig
	// contains filtered or unexported fields
}

func NewOrinDeviceGrpcServer

func NewOrinDeviceGrpcServer(c *OrinDeviceConfig, resourceName string, orinID int, boardIDSets sets.Int) (*OrinDeviceGrpcServer, error)

func (*OrinDeviceGrpcServer) Allocate

func (s *OrinDeviceGrpcServer) Allocate(ctx context.Context, request *v1beta1.AllocateRequest) (*v1beta1.AllocateResponse, error)

func (*OrinDeviceGrpcServer) GetDevicePluginOptions

func (s *OrinDeviceGrpcServer) GetDevicePluginOptions(ctx context.Context, empty *v1beta1.Empty) (*v1beta1.DevicePluginOptions, error)

func (*OrinDeviceGrpcServer) GetPreferredAllocation

func (s *OrinDeviceGrpcServer) GetPreferredAllocation(ctx context.Context, request *v1beta1.PreferredAllocationRequest) (*v1beta1.PreferredAllocationResponse, error)

func (*OrinDeviceGrpcServer) ListAndWatch

func (s *OrinDeviceGrpcServer) ListAndWatch(empty *v1beta1.Empty, server v1beta1.DevicePlugin_ListAndWatchServer) error

func (*OrinDeviceGrpcServer) PreStartContainer

func (s *OrinDeviceGrpcServer) PreStartContainer(ctx context.Context, request *v1beta1.PreStartContainerRequest) (*v1beta1.PreStartContainerResponse, error)

type OrinDevicePlugin

type OrinDevicePlugin map[string]*DevicePluginServer

func NewOrinDevicePlugin

func NewOrinDevicePlugin(c *OrinDeviceConfig) (OrinDevicePlugin, error)

func (OrinDevicePlugin) Run

func (odp OrinDevicePlugin) Run(stop <-chan struct{})