- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 68 for Reconciled (0.15 sec)
-
pkg/controller/volume/attachdetach/reconciler/reconciler.go
) // Reconciler runs a periodic loop to reconcile the desired state of the world with // the actual state of the world by triggering attach detach operations. // Note: This is distinct from the Reconciler implemented by the kubelet volume // manager. This reconciles state for the attach/detach controller. That // reconciles state for the kubelet volume manager. type Reconciler interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 21:02:38 UTC 2024 - 21.1K bytes - Viewed (0) -
operator/pkg/helmreconciler/reconciler.go
for _, parent := range ComponentDependencies { for _, child := range parent { ret[child] = make(chan struct{}, 1) } } return ret } // Reconcile reconciles the associated resources. func (h *HelmReconciler) Reconcile() (*v1alpha1.InstallStatus, error) { if err := util.CreateNamespace(h.kubeClient.Kube(), istioV1Alpha1.Namespace(h.iop.Spec), h.networkName(), h.opts.DryRun); err != nil { return nil, err
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 22 08:32:23 UTC 2024 - 22K bytes - Viewed (0) -
operator/pkg/controller/istiocontrolplane/istiocontrolplane_controller.go
if err != nil { scope.Errorf("Error during reconcile. Error: %s", err) return reconcile.Result{}, err } if err := reconciler.SetStatusBegin(); err != nil { scope.Errorf("Error during reconcile, failed to update status to Begin. Error: %s", err) return reconcile.Result{}, err } status, err := reconciler.Reconcile() if err != nil { scope.Errorf("Error during reconcile: %s", err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 13:56:46 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_common.go
"k8s.io/mount-utils" ) // Reconciler runs a periodic loop to reconcile the desired state of the world // with the actual state of the world by triggering attach, detach, mount, and // unmount operations. // Note: This is distinct from the Reconciler implemented by the attach/detach // controller. This reconciles state for the kubelet volume manager. That // reconciles state for the attach/detach controller.
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/kubelet/config/config.go
// no ADD or UPDATE or DELETE pods from the source. This signals kubelet that // the source is ready. s.updates <- *adds } // Only add reconcile support here, because kubelet doesn't support Snapshot update now. if len(reconciles.Pods) > 0 { s.updates <- *reconciles } case PodConfigNotificationSnapshotAndUpdates: if len(removes.Pods) > 0 || len(adds.Pods) > 0 || firstSet {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 16.7K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
return nil, err } iop.Spec.InstallPackagePath = string(chartSource) reconciler, err := helmreconciler.NewHelmReconciler(testClient, c, iop, opts) if err != nil { return nil, err } if err := fakeInstallOperator(reconciler, chartSource); err != nil { return nil, err } if _, err := reconciler.Reconcile(); err != nil { return nil, err } return NewObjectSet(getAllIstioObjects()), nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 20 22:39:28 UTC 2024 - 11.7K bytes - Viewed (0) -
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)