Documentation
¶
Index ¶
Constants ¶
View Source
const (
// DRAPluginName is the name of the in-tree DRA Plugin.
DRAPluginName = "kubernetes.io/dra"
)
View Source
const PluginClientTimeout = 45 * time.Second
Variables ¶
This section is empty.
Functions ¶
func NewDRAPluginClient ¶
func NewDRAPluginClient(pluginName string) (drapb.NodeClient, error)
Types ¶
type RegistrationHandler ¶
type RegistrationHandler struct {
// contains filtered or unexported fields
}
RegistrationHandler is the handler which is fed to the pluginwatcher API.
func NewRegistrationHandler ¶
func NewRegistrationHandler(kubeClient kubernetes.Interface, nodeName string) *RegistrationHandler
NewPluginHandler returns new registration handler.
Must only be called once per process because it manages global state. If a kubeClient is provided, then it synchronizes ResourceSlices with the resource information provided by plugins.
func (*RegistrationHandler) DeRegisterPlugin ¶
func (h *RegistrationHandler) DeRegisterPlugin(pluginName string)
DeRegisterPlugin is called when a plugin has removed its socket, signaling it is no longer available.
func (*RegistrationHandler) RegisterPlugin ¶
func (h *RegistrationHandler) RegisterPlugin(pluginName string, endpoint string, versions []string) error
RegisterPlugin is called when a plugin can be registered.
func (*RegistrationHandler) ValidatePlugin ¶
func (h *RegistrationHandler) ValidatePlugin(pluginName string, endpoint string, versions []string) error
ValidatePlugin is called by kubelet's plugin watcher upon detection of a new registration socket opened by DRA plugin.
Click to show internal directories.
Click to hide internal directories.