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

type Server …

type server …

// NewServer returns an initialized device plugin registration server.
func NewServer(socketPath string, rh RegistrationHandler, ch ClientHandler) (Server, error) { … }

func (s *server) Start() error { … }

func (s *server) Stop() error { … }

func (s *server) SocketPath() string { … }

func (s *server) Register(ctx context.Context, r *api.RegisterRequest) (*api.Empty, error) { … }

func (s *server) isVersionCompatibleWithPlugin(versions ...string) bool { … }

func (s *server) visitClients(visit func(r string, c Client)) { … }