- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for ActualStateOfworld (1.04 sec)
-
pkg/kubelet/pluginmanager/cache/actual_state_of_world.go
PluginExistsWithCorrectTimestamp(pluginInfo PluginInfo) bool } // NewActualStateOfWorld returns a new instance of ActualStateOfWorld func NewActualStateOfWorld() ActualStateOfWorld { return &actualStateOfWorld{ socketFileToInfo: make(map[string]PluginInfo), } } type actualStateOfWorld struct { // socketFileToInfo is a map containing the set of successfully registered plugins
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/volume/util/operationexecutor/fakegenerator.go
} func (f *fakeOGCounter) GenerateUnmountVolumeFunc(volumeToUnmount MountedVolume, actualStateOfWorld ActualStateOfWorldMounterUpdater, podsDir string) (volumetypes.GeneratedOperations, error) { return f.recordFuncCall("GenerateUnmountVolumeFunc"), nil } func (f *fakeOGCounter) GenerateAttachVolumeFunc(logger klog.Logger, volumeToAttach VolumeToAttach, actualStateOfWorld ActualStateOfWorldAttacherUpdater) volumetypes.GeneratedOperations {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 5.1K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/plugin_manager.go
// reconciler runs an asynchronous periodic loop to reconcile the // desiredStateOfWorld with the actualStateOfWorld by triggering register // and unregister operations using the operationExecutor. reconciler reconciler.Reconciler // actualStateOfWorld is a data structure containing the actual state of // the world according to the manager: i.e. which plugins are registered.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 01 05:56:33 UTC 2022 - 4.3K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/statusupdater/node_status_updater.go
nodeLister corelisters.NodeLister, actualStateOfWorld cache.ActualStateOfWorld) NodeStatusUpdater { return &nodeStatusUpdater{ actualStateOfWorld: actualStateOfWorld, nodeLister: nodeLister, kubeClient: kubeClient, } } type nodeStatusUpdater struct { kubeClient clientset.Interface nodeLister corelisters.NodeLister actualStateOfWorld cache.ActualStateOfWorld }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/reconciler/reconciler.go
desiredStateOfWorld: desiredStateOfWorld, actualStateOfWorld: actualStateOfWorld, handlers: make(map[string]cache.PluginHandler), } } type reconciler struct { operationExecutor operationexecutor.OperationExecutor loopSleepDuration time.Duration desiredStateOfWorld cache.DesiredStateOfWorld actualStateOfWorld cache.ActualStateOfWorld handlers map[string]cache.PluginHandler
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 6.2K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/operationexecutor/operation_executor.go
// behavior. // // Once an operation completes successfully, the actualStateOfWorld is updated // to indicate the plugin is registered/unregistered. // // Once the operation is started, since it is executed asynchronously, // errors are simply logged and the goroutine is terminated without updating // actualStateOfWorld. type OperationExecutor interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 4.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct.go
if volumeID != attachedVolume.Name { continue } rc.actualStateOfWorld.UpdateReconstructedDevicePath(volumeID, attachedVolume.DevicePath) attachable = true klog.V(4).InfoS("Updated devicePath from node status for volume", "volumeName", attachedVolume.Name, "path", attachedVolume.DevicePath) } rc.actualStateOfWorld.UpdateReconstructedVolumeAttachability(volumeID, attachable) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 8.9K bytes - Viewed (0) -
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) } metricCollector := &totalPluginsCollector{asw: asw, dsw: dsw}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 12 12:48:20 UTC 2019 - 2.2K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/metrics/metrics.go
} // Register registers Plugin Manager metrics. func Register(asw cache.ActualStateOfWorld, dsw cache.DesiredStateOfWorld) { registerMetrics.Do(func() { legacyregistry.CustomMustRegister(&totalPluginsCollector{asw: asw, dsw: dsw}) }) } type totalPluginsCollector struct { metrics.BaseStableCollector asw cache.ActualStateOfWorld dsw cache.DesiredStateOfWorld }
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/volumemanager/metrics/metrics_test.go
mapper, err := fakePlugin.NewBlockVolumeMapper(volumeSpec, pod, volume.VolumeOptions{}) if err != nil { t.Fatalf("NewBlockVolumeMapper failed. Expected: <no error> Actual: <%v>", err) } // Add one volume to ActualStateOfWorld devicePath := "fake/device/path" logger, _ := ktesting.NewTestContext(t) err = asw.MarkVolumeAsAttached(logger, "", volumeSpec, "", devicePath) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 4K bytes - Viewed (0)