- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 30 for socketPath (0.15 sec)
-
pkg/kubelet/pluginmanager/cache/desired_state_of_world_test.go
t.Fatalf("Desired state of world length should be one but it's %d", len(dswPlugins)) } if dswPlugins[0].SocketPath != socketPath { t.Fatalf("Expected\n%s\nin desired state of world, but got\n%v\n", socketPath, dswPlugins[0]) } // Check PluginExists returns true if !dsw.PluginExists(socketPath) { t.Fatalf("PluginExists returns false for the newly added plugin") } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 18 12:18:41 UTC 2023 - 5.2K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/cache/actual_state_of_world.go
} asw.socketFileToInfo[pluginInfo.SocketPath] = pluginInfo return nil } func (asw *actualStateOfWorld) RemovePlugin(socketPath string) { asw.Lock() defer asw.Unlock() delete(asw.socketFileToInfo, socketPath) } func (asw *actualStateOfWorld) GetRegisteredPlugins() []PluginInfo { asw.RLock() defer asw.RUnlock() currentPlugins := []PluginInfo{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 24 21:20:24 UTC 2022 - 4.1K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/plugin_watcher_test.go
} } func waitForUnregistration( t *testing.T, socketPath string, dsw cache.DesiredStateOfWorld) { err := retryWithExponentialBackOff( time.Duration(500*time.Millisecond), func() (bool, error) { if !dsw.PluginExists(socketPath) { return true, nil } return false, nil }, ) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 8K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/operationexecutor/operation_generator.go
socketPath string, timestamp time.Time, pluginHandlers map[string]cache.PluginHandler, actualStateOfWorldUpdater ActualStateOfWorldUpdater) func() error { registerPluginFunc := func() error { client, conn, err := dial(socketPath, dialTimeoutDuration) if err != nil { return fmt.Errorf("RegisterPlugin error -- dial failed at socket %s, err: %v", socketPath, err) } defer conn.Close()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 7.1K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/metrics/metrics.go
socketPath := registeredPlugin.SocketPath counter.add("actual_state_of_world", socketPath) } for _, pluginToRegister := range c.dsw.GetPluginsToRegister() { socketPath := pluginToRegister.SocketPath counter.add("desired_state_of_world", socketPath) } return counter
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 08 01:16:57 UTC 2019 - 2.7K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/plugin_watcher.go
return nil } return w.handlePluginRegistration(event.Name) } return w.traversePluginDir(event.Name) } func (w *Watcher) handlePluginRegistration(socketPath string) error { socketPath = getSocketPath(socketPath) // Update desired state of world list of plugins // If the socket path does exist in the desired world cache, there's still
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 01 00:26:37 UTC 2023 - 6.1K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/reconciler/reconciler_test.go
} if aswPlugins[0].SocketPath != socketPath { t.Fatalf("Test_Run_Positive_RegisterThenUnregister: expected\n%s\nin actual state of world, but got\n%v\n", socketPath, aswPlugins[0]) } dsw.RemovePlugin(socketPath) os.Remove(socketPath) waitForUnregistration(t, socketPath, asw) // Get asw plugins; it should no longer contain the added plugin
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 10.5K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/cache/desired_state_of_world.go
// version as the plugin in the desired state of world dsw.socketFileToInfo[socketPath] = PluginInfo{ SocketPath: socketPath, Timestamp: time.Now(), } return nil } func (dsw *desiredStateOfWorld) RemovePlugin(socketPath string) { dsw.Lock() defer dsw.Unlock() delete(dsw.socketFileToInfo, socketPath) } func (dsw *desiredStateOfWorld) GetPluginsToRegister() []PluginInfo {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 02 12:47:44 UTC 2022 - 6.1K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/plugin/v1beta1/server.go
func NewServer(socketPath string, rh RegistrationHandler, ch ClientHandler) (Server, error) { if socketPath == "" || !filepath.IsAbs(socketPath) { return nil, fmt.Errorf(errBadSocket+" %s", socketPath) } dir, name := filepath.Split(socketPath) klog.V(2).InfoS("Creating device plugin registration server", "version", api.Version, "socket", socketPath) s := &server{ socketName: name,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 5.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/testing/v1beta1/kms_plugin_mock.go
inFailedState bool ver string socketPath string } // NewBase64Plugin is a constructor for Base64Plugin. func NewBase64Plugin(t *testing.T, socketPath string) *Base64Plugin { server := grpc.NewServer() result := &Base64Plugin{ grpcServer: server, mu: &sync.Mutex{}, ver: kmsapiVersion, socketPath: socketPath, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 29 05:36:41 UTC 2023 - 5.2K bytes - Viewed (0)