- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 306 for Reconciled (0.13 sec)
-
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
// synced at least once. Added as a member to the struct to allow injection // for testing. servicesSynced cache.InformerSynced // reconciler is an util used to reconcile EndpointSlice changes. reconciler *reconciler // Endpoints that need to be updated. A channel is inappropriate here, // because it allows Endpoints with lots of addresses to be serviced much
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/controlplane/reconcilers/instancecount.go
*/ // Package reconcilers master count based reconciler package reconcilers import ( "net" "sync" corev1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/client-go/util/retry" "k8s.io/klog/v2" endpointsv1 "k8s.io/kubernetes/pkg/api/v1/endpoints" ) // masterCountEndpointReconciler reconciles endpoints based on a specified expected number of
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 7.2K bytes - Viewed (0) -
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) -
releasenotes/notes/validating-webhook-reconcile-change.yaml
Douglas Reid <******@****.***> 1619204788 -0700
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 23 19:06:28 UTC 2021 - 302 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)