package plugin

import "k8s.io/kubernetes/pkg/kubelet/cm/dra/plugin"

Index ¶

• Constants
• func NewDRAPluginClient(pluginName string) (drapb.NodeClient, error)
• type RegistrationHandler
• func NewRegistrationHandler() *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{}

RegistrationHandler is the handler which is fed to the pluginwatcher API.

func NewRegistrationHandler ¶

func NewRegistrationHandler() *RegistrationHandler

NewPluginHandler returns new registration handler.

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.

Source Files ¶

client.go plugin.go plugins_store.go