- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for AddOrUpdatePlugin (0.24 sec)
-
pkg/kubelet/pluginmanager/cache/desired_state_of_world_test.go
} } // Calls AddOrUpdatePlugin() to add an empty string for socket path // Verifies the plugin does not exist in GetPluginsToRegister() after AddOrUpdatePlugin() // Verifies the plugin returns false for PluginExists() func Test_DSW_AddOrUpdatePlugin_Negative_PluginMissingInfo(t *testing.T) { dsw := NewDesiredStateOfWorld() socketPath := "" err := dsw.AddOrUpdatePlugin(socketPath)
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/desired_state_of_world.go
// all plugins attached to this node. type DesiredStateOfWorld interface { // AddOrUpdatePlugin add the given plugin in the cache if it doesn't already exist. // If it does exist in the cache, then the timestamp of the PluginInfo object in the cache will be updated. // An error will be returned if socketPath is empty. AddOrUpdatePlugin(socketPath string) error
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/pluginmanager/reconciler/reconciler_test.go
require.NoError(t, p.Serve("v1beta1", "v1beta2")) timestampBeforeRegistration := time.Now() dsw.AddOrUpdatePlugin(socketPath) waitForRegistration(t, socketPath, timestampBeforeRegistration, asw) timeStampBeforeReRegistration := time.Now() // Add the plugin again to update the timestamp dsw.AddOrUpdatePlugin(socketPath) // This should trigger a deregistration and a regitration
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/pluginwatcher/plugin_watcher.go
// removed from the desired world cache, so we still need to call AddOrUpdatePlugin // in this case to update the timestamp klog.V(2).InfoS("Adding socket path or updating timestamp to desired state cache", "path", socketPath) err := w.desiredStateOfWorld.AddOrUpdatePlugin(socketPath) if err != nil {
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/cache/actual_state_of_world.go
GetRegisteredPlugins() []PluginInfo // AddPlugin add the given plugin in the cache. // An error will be returned if socketPath of the PluginInfo object is empty. // Note that this is different from desired world cache's AddOrUpdatePlugin // because for the actual state of world cache, there won't be a scenario where // we need to update an existing plugin if the timestamps don't match. This is
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 24 21:20:24 UTC 2022 - 4.1K bytes - Viewed (0)