- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 52 for Reconciled (0.19 sec)
-
pkg/controller/endpointslice/endpointslice_controller.go
// Added as a member to the struct to allow injection for testing. nodesSynced cache.InformerSynced // reconciler is an util used to reconcile EndpointSlice changes. reconciler *endpointslicerec.Reconciler // triggerTimeTracker is an util used to compute and export the // EndpointsLastChangeTriggerTime annotation. triggerTimeTracker *endpointsliceutil.TriggerTimeTracker
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/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/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/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) -
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) -
cmd/kube-apiserver/app/options/validation_test.go
wantErr bool }{ { name: "master endpoint reconciler - IPv4 families", extra: Extra{ EndpointReconcilerType: "master-count", PrimaryServiceClusterIPRange: *ipv4cidr, }, generic: apiserveroptions.ServerRunOptions{ AdvertiseAddress: ipv4address, }, wantErr: false, }, { name: "master endpoint reconciler - IPv6 families", extra: Extra{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 11.4K bytes - Viewed (0) -
operator/cmd/mesh/install.go
opts := &helmreconciler.Options{ DryRun: dryRun, Log: l, WaitTimeout: waitTimeout, ProgressLog: progress.NewLog(), Force: force, } reconciler, err := helmreconciler.NewHelmReconciler(client, kubeClient, iop, opts) if err != nil { return err } status, err := reconciler.Reconcile() if err != nil { return fmt.Errorf("errors occurred during operation: %v", err) } if status.Status != v1alpha1.InstallStatus_HEALTHY {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 21:52:35 UTC 2024 - 15.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct_common.go
VolumeSpecName: gvi.volumeSpec.Name(), DevicePath: gvi.devicePath, PodVolumes: podVolumes, } } func (rc *reconciler) updateLastSyncTime() { rc.timeOfLastSyncLock.Lock() defer rc.timeOfLastSyncLock.Unlock() rc.timeOfLastSync = time.Now() } func (rc *reconciler) StatesHasBeenSynced() bool { rc.timeOfLastSyncLock.Lock() defer rc.timeOfLastSyncLock.Unlock() return !rc.timeOfLastSync.IsZero()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/webhooks/validation/controller/controller.go
return c } func (c *Controller) Reconcile(key types.NamespacedName) error { name := key.Name whc := c.webhooks.Get(name, "") scope := scope.WithLabels("webhook", name) // Stop early if webhook is not present, rather than attempting (and failing) to reconcile permanently // If the webhook is later added a new reconciliation request will trigger it to update
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 16:52:19 UTC 2024 - 11.3K bytes - Viewed (0)