plugin

Documentation

Index

• Constants
• func NewDRAPluginClient(pluginName string) (drapb.NodeClient, error)
• type RegistrationHandler
  • func NewRegistrationHandler(kubeClient kubernetes.Interface, getNode func() (*v1.Node, error)) *RegistrationHandler
  • func (h *RegistrationHandler) DeRegisterPlugin(pluginName string)
  • func (h *RegistrationHandler) RegisterPlugin(pluginName string, endpoint string, versions []string, ...) error
  • func (h *RegistrationHandler) ValidatePlugin(pluginName string, endpoint string, versions []string) error

Constants

const (
	// DRAPluginName is the name of the in-tree DRA Plugin.
	DRAPluginName = "kubernetes.io/dra"
)

const PluginClientTimeout = 45 * time.Second

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, getNode func() (*v1.Node, error)) *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, pluginClientTimeout *time.Duration) 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.