- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for newReconciler (0.17 sec)
-
pkg/kubelet/pluginmanager/reconciler/reconciler_test.go
asw := cache.NewActualStateOfWorld() fakeRecorder := &record.FakeRecorder{} oex := operationexecutor.NewOperationExecutor(operationexecutor.NewOperationGenerator( fakeRecorder, )) reconciler := NewReconciler( oex, reconcilerLoopSleepDuration, dsw, asw, ) // Act runReconciler(reconciler) // Get dsw and asw plugins; they should both be empty if len(asw.GetRegisteredPlugins()) != 0 {
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/volumemanager/reconciler/reconciler_common.go
Run(stopCh <-chan struct{}) // StatesHasBeenSynced returns true only after syncStates process starts to sync // states at least once after kubelet starts StatesHasBeenSynced() bool } // NewReconciler returns a new instance of Reconciler. // // controllerAttachDetachEnabled - if true, indicates that the attach/detach // controller is responsible for managing the attach/detach operations for
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler.go
// if volumes that should be attached are attached and volumes that should // be detached are detached. If not, it will trigger attach/detach // operations to rectify. Run(ctx context.Context) } // NewReconciler returns a new instance of Reconciler that waits loopPeriod // between successive executions. // loopPeriod is the amount of time the reconciler loop waits between // successive executions.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 21:02:38 UTC 2024 - 21.1K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler_test.go
} numInitialActions++ } maxEndpointsPerSubset := tc.maxEndpointsPerSubset if maxEndpointsPerSubset == 0 { maxEndpointsPerSubset = defaultMaxEndpointsPerSubset } r := newReconciler(tCtx, client, maxEndpointsPerSubset) reconcileHelper(t, r, &endpoints, tc.existingEndpointSlices) numExtraActions := len(client.Actions()) - numInitialActions if numExtraActions != tc.expectedClientActions {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 42.7K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
podStateProvider, vm.desiredStateOfWorld, vm.actualStateOfWorld, kubeContainerRuntime, csiMigratedPluginManager, intreeToCSITranslator, volumePluginMgr) vm.reconciler = reconciler.NewReconciler( kubeClient, controllerAttachDetachEnabled, reconcilerLoopSleepPeriod, waitForAttachTimeout, nodeName, vm.desiredStateOfWorld, vm.actualStateOfWorld,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
}, DeleteFunc: func(_ interface{}) { c.deleteNode() }, }) c.topologyCache = topologycache.NewTopologyCache() } c.reconciler = endpointslicerec.NewReconciler( c.client, c.nodeLister, c.maxEndpointsPerSlice, c.endpointSliceTracker, c.topologyCache, c.eventRecorder, controllerName,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
blkutil)) adc.nodeStatusUpdater = statusupdater.NewNodeStatusUpdater( kubeClient, nodeInformer.Lister(), adc.actualStateOfWorld) // Default these to values in options adc.reconciler = reconciler.NewReconciler( timerConfig.ReconcilerLoopPeriod, timerConfig.ReconcilerMaxWaitForUnmountDuration, reconcilerSyncDuration, disableReconciliationSync, disableForceDetachOnTimeout, adc.desiredStateOfWorld,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0)