kubernetes/pkg/kubelet/cm/devicemanager/plugin/v1beta1/handler.go

func (s *server) GetPluginHandler() cache.PluginHandler { … }

func (s *server) RegisterPlugin(pluginName string, endpoint string, versions []string, pluginClientTimeout *time.Duration) error { … }

func (s *server) DeRegisterPlugin(pluginName string) { … }

func (s *server) ValidatePlugin(pluginName string, endpoint string, versions []string) error { … }

func (s *server) connectClient(name string, socketPath string) error { … }

func (s *server) disconnectClient(name string, c Client) error { … }

func (s *server) registerClient(name string, c Client) { … }

func (s *server) deregisterClient(name string) { … }

func (s *server) runClient(name string, c Client) { … }

func (s *server) getClient(name string) Client { … }