- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for GetRegisteredPlugins (0.19 sec)
-
pkg/kubelet/pluginmanager/cache/actual_state_of_world_test.go
*/ package cache import ( "runtime" "testing" "time" "github.com/stretchr/testify/require" ) // Calls AddPlugin() to add a plugin // Verifies newly added plugin exists in GetRegisteredPlugins() // Verifies PluginExistsWithCorrectTimestamp returns true for the plugin func Test_ASW_AddPlugin_Positive_NewPlugin(t *testing.T) { pluginInfo := PluginInfo{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 18 12:18:41 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/cache/actual_state_of_world.go
// all plugins attached to this node. type ActualStateOfWorld interface { // GetRegisteredPlugins generates and returns a list of plugins // that are successfully registered plugins in the current actual state of world. GetRegisteredPlugins() []PluginInfo // AddPlugin add the given plugin in the cache. // An error will be returned if socketPath of the PluginInfo object is empty.
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/reconciler/reconciler.go
func (rc *reconciler) reconcile() { // Unregisterations are triggered before registrations // Ensure plugins that should be unregistered are unregistered. for _, registeredPlugin := range rc.actualStateOfWorld.GetRegisteredPlugins() { unregisterPlugin := false if !rc.desiredStateOfWorld.PluginExists(registeredPlugin.SocketPath) { unregisterPlugin = true } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 6.2K bytes - Viewed (0)