types

Documentation

Index

• type RdmaDeviceSpec
• type ResourceManager
• type ResourceServer
• type ResourceServerPort
• type SignalNotifier
• type UserConfig
• type UserConfigList

Types

type RdmaDeviceSpec

type RdmaDeviceSpec interface {
	Get(string) []*pluginapi.DeviceSpec
}

RdmaDeviceSpec used to find the rdma devices

type ResourceManager

type ResourceManager interface {
	ReadConfig() error
	ValidateConfigs() error
	InitServers() error
	StartAllServers() error
	StopAllServers() error
	RestartAllServers() error
}

ResourceManager manger multi plugins

type ResourceServer

type ResourceServer interface {
	pluginapi.DevicePluginServer
	Start() error
	Stop() error
	Restart() error
	Watch() error
}

ResourceServer is gRPC server implements K8s device plugin api

type ResourceServerPort

type ResourceServerPort interface {
	GetServer() *grpc.Server
	CreateServer()
	DeleteServer()
	Listen(string, string) (net.Listener, error)
	Serve(net.Listener)
	Stop()
	Close(*grpc.ClientConn)
	Register(pluginapi.RegistrationClient, *pluginapi.RegisterRequest) error
	Dial(string, time.Duration) (*grpc.ClientConn, error)
}

ResourceServerPort to connect the resources server to k8s

type SignalNotifier

type SignalNotifier interface {
	Notify() chan os.Signal
}

NotifierFactory register signals to listen for

type UserConfig

type UserConfig struct {
	ResourceName string   `json:"resourceName"`
	RdmaHcaMax   int      `json:"rdmaHcaMax"`
	Devices      []string `json:"devices"`
}

UserConfig configuration for device plugin

type UserConfigList

type UserConfigList struct {
	ConfigList []UserConfig `json:"configList"`
}

UserConfigList config list for servers