- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 231 for Reconciled (0.2 sec)
-
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
assert.False(t, reconciler.StatesHasBeenSynced()) reconciler.volumesNeedUpdateFromNodeStatus = append(reconciler.volumesNeedUpdateFromNodeStatus, volumeName1, volumeName2) // Act - run reconcile loop just once. // "volumesNeedUpdateFromNodeStatus" is not empty, so no unmount will be triggered. reconciler.reconcile() // Assert assert.True(t, reconciler.StatesHasBeenSynced())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
reconciler reconciler.Reconciler // desiredStateOfWorldPopulator runs an asynchronous periodic loop to // populate the desiredStateOfWorld using the kubelet PodManager. desiredStateOfWorldPopulator populator.DesiredStateOfWorldPopulator // csiMigratedPluginManager keeps track of CSI migration status of plugins csiMigratedPluginManager csimigration.PluginManager
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/namespacecontroller.go
// // 5ms, 10ms, 20ms, 40ms, 80ms maxRetries = 5 ) var configMapLabel = map[string]string{"istio.io/config": "true"} // NamespaceController manages reconciles a configmap in each namespace with a desired set of data. type NamespaceController struct { caBundleWatcher *keycertbundle.Watcher queue controllers.Queue namespaces kclient.Client[*v1.Namespace]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.4K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/deploymentcontroller_test.go
env := &model.Environment{} d := NewDeploymentController(c, "", env, testInjectionConfig(t, ""), func(fn func()) {}, tw, "") reconciles := atomic.NewInt32(0) wantReconcile := int32(0) expectReconciled := func() { t.Helper() wantReconcile++ assert.EventuallyEqual(t, reconciles.Load, wantReconcile, retry.Timeout(time.Second*5), retry.Message("no reconciliation")) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 16.5K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
attacherDetacher operationexecutor.OperationExecutor // reconciler is used to run an asynchronous periodic loop to reconcile the // desiredStateOfWorld with the actualStateOfWorld by triggering attach // detach operations using the attacherDetacher. reconciler reconciler.Reconciler // nodeStatusUpdater is used to update node status with the list of attached // volumes
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/reconciler/reconciler_test.go
fakeRecorder, )) reconciler := NewReconciler( oex, reconcilerLoopSleepDuration, dsw, asw, ) reconciler.AddHandler(registerapi.DevicePlugin, cache.PluginHandler(di)) // Start the reconciler to fill ASW. stopChan := make(chan struct{}) defer close(stopChan) go reconciler.Run(stopChan) socketPath := filepath.Join(socketDir, "plugin.sock")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 10.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler_test.go
baseKey := "/" + uuid.New().String() + "/peer-testleases/" leaseTime := 1 * time.Minute reconciler, err := reconcilers.NewPeerEndpointLeaseReconciler(&config, baseKey, leaseTime) if err != nil { t.Fatalf("Error creating storage: %v", err) } return reconciler } func newHandlerChain(t *testing.T, handler http.Handler, reconciler reconcilers.PeerEndpointLeaseReconciler, informerFinishedSync bool, svdata FakeSVMapData) http.Handler {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 10.8K bytes - Viewed (0) -
operator/cmd/operator/server.go
maxConcurrentReconciles int monitoring monitoringArgs } func addServerFlags(cmd *cobra.Command, args *serverArgs) { cmd.PersistentFlags().BoolVar(&args.force, "force", false, root.ForceFlagHelpStr) cmd.PersistentFlags().IntVar(&args.maxConcurrentReconciles, "max-concurrent-reconciles", 1, root.MaxConcurrentReconcilesFlagHelpStr)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 30 21:09:08 UTC 2023 - 7.6K bytes - Viewed (0) -
releasenotes/notes/operator-max-concurrent-reconcile-40810.yaml
deveshkandpal1224 <******@****.***> 1664341212 -0700
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Sep 28 05:00:12 UTC 2022 - 211 bytes - Viewed (0) -
cluster/addons/kube-network-policies/kube-network-policies-rbac.yaml
kind: ClusterRole apiVersion: rbac.authorization.k8s.io/v1 metadata: name: system:network-policies namespace: kube-system labels: addonmanager.kubernetes.io/mode: Reconcile rules: - apiGroups: [""] resources: - pods - nodes - namespaces verbs: - get - watch - list # Watch for changes to Kubernetes NetworkPolicies. - apiGroups: ["networking.k8s.io"] resources:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 21 10:01:31 UTC 2024 - 1.1K bytes - Viewed (0)