Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for AddOrUpdatePlugin (0.44 sec)

  1. 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)
  2. pkg/kubelet/pluginmanager/metrics/metrics_test.go

    	}
    	// Add one plugin to DesiredStateOfWorld
    	err := dsw.AddOrUpdatePlugin(fakePlugin.SocketPath)
    	if err != nil {
    		t.Fatalf("AddOrUpdatePlugin failed. Expected: <no error> Actual: <%v>", err)
    	}
    
    	// Add one plugin to ActualStateOfWorld
    	err = asw.AddPlugin(fakePlugin)
    	if err != nil {
    		t.Fatalf("AddOrUpdatePlugin failed. Expected: <no error> Actual: <%v>", err)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 12 12:48:20 UTC 2019
    - 2.2K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top