- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for disconnectClient (0.35 sec)
-
pkg/kubelet/cm/devicemanager/plugin/v1beta1/handler.go
} func (s *server) DeRegisterPlugin(pluginName string) { klog.V(2).InfoS("Deregistering plugin", "plugin", pluginName) client := s.getClient(pluginName) if client != nil { s.disconnectClient(pluginName, client) } } func (s *server) ValidatePlugin(pluginName string, endpoint string, versions []string) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/plugin/v1beta1/server.go
go func() { defer s.wg.Done() s.grpc.Serve(ln) }() return nil } func (s *server) Stop() error { s.visitClients(func(r string, c Client) { if err := s.disconnectClient(r, c); err != nil { klog.InfoS("Error disconnecting device plugin client", "resourceName", r, "err", err) } }) s.mutex.Lock() defer s.mutex.Unlock() if s.grpc == nil { return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 5.4K bytes - Viewed (0)