Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for GetPluginsToRegister (0.33 sec)

  1. pkg/kubelet/pluginmanager/cache/desired_state_of_world_test.go

    */
    
    package cache
    
    import (
    	"runtime"
    	"testing"
    
    	"github.com/stretchr/testify/require"
    )
    
    // Calls AddOrUpdatePlugin() to add a plugin
    // Verifies newly added plugin exists in GetPluginsToRegister()
    // Verifies newly added plugin returns true for PluginExists()
    func Test_DSW_AddOrUpdatePlugin_Positive_NewPlugin(t *testing.T) {
    	dsw := NewDesiredStateOfWorld()
    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/pluginwatcher/plugin_watcher_test.go

    		require.NoError(t, p.Serve("v1beta1", "v1beta2"))
    
    		pluginInfo := GetPluginInfo(p)
    		waitForRegistration(t, pluginInfo.SocketPath, dsw)
    
    		// Check the desired state for plugins
    		dswPlugins := dsw.GetPluginsToRegister()
    		if len(dswPlugins) != 1 {
    			t.Fatalf("TestPluginRegistration: desired state of world length should be 1 but it's %d", len(dswPlugins))
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 04 06:56:50 UTC 2023
    - 8K bytes
    - Viewed (0)
  3. pkg/kubelet/pluginmanager/cache/desired_state_of_world.go

    	// state of world.
    	// If a plugin does not exist with the given socket path, this is a no-op.
    	RemovePlugin(socketPath string)
    
    	// GetPluginsToRegister generates and returns a list of plugins
    	// in the current desired state of world.
    	GetPluginsToRegister() []PluginInfo
    
    	// PluginExists checks if the given socket path exists in the current desired
    	// state of world cache
    	PluginExists(socketPath string) bool
    }
    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.go

    			// Iterate through desired state of world plugins and see if there's any plugin
    			// with the same socket path but different timestamp.
    			for _, dswPlugin := range rc.desiredStateOfWorld.GetPluginsToRegister() {
    				if dswPlugin.SocketPath == registeredPlugin.SocketPath && dswPlugin.Timestamp != registeredPlugin.Timestamp {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Dec 18 04:27:38 UTC 2022
    - 6.2K bytes
    - Viewed (0)
  5. pkg/kubelet/pluginmanager/metrics/metrics.go

    	for _, registeredPlugin := range c.asw.GetRegisteredPlugins() {
    		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)
  6. pkg/kubelet/pluginmanager/reconciler/reconciler_test.go

    	// Get dsw and asw plugins; they should both be empty
    	if len(asw.GetRegisteredPlugins()) != 0 {
    		t.Fatalf("Test_Run_Positive_DoNothing: actual state of world should be empty but it's not")
    	}
    	if len(dsw.GetPluginsToRegister()) != 0 {
    		t.Fatalf("Test_Run_Positive_DoNothing: desired state of world should be empty but it's not")
    	}
    }
    
    // Populates desiredStateOfWorld cache with one plugin.
    // Calls Run()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:21:15 UTC 2024
    - 10.5K bytes
    - Viewed (0)
Back to top