Documentation
¶
Index ¶
- Constants
- func NewFSWatcher(files ...string) (*fsnotify.Watcher, error)
- type DevicePluginServer
- type OrinDeviceConfig
- type OrinDeviceGrpcServer
- 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
Constants ¶
View Source
const (
HostVitualPath = "/data/edge/device"
)
Variables ¶
This section is empty.
Functions ¶
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{})
Source Files
Click to show internal directories.
Click to hide internal directories.