- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 306 for Reconciled (0.14 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
informer Informer[T], reconciler func(namepace, name string, newObj T) error, options ControllerOptions, ) Controller[T] { if options.Workers == 0 { options.Workers = 2 } if len(options.Name) == 0 { options.Name = fmt.Sprintf("%T-controller", *new(T)) } c := &controller[T]{ options: options, informer: informer, reconciler: reconciler, queue: nil, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/plugin_manager.go
// periodic loop to populate the desiredStateOfWorld. desiredStateOfWorldPopulator *pluginwatcher.Watcher // reconciler runs an asynchronous periodic loop to reconcile the // desiredStateOfWorld with the actualStateOfWorld by triggering register // and unregister operations using the operationExecutor. reconciler reconciler.Reconciler // actualStateOfWorld is a data structure containing the actual state of
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 01 05:56:33 UTC 2022 - 4.3K 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) -
pkg/kubelet/kubelet_test.go
return false, nil } return true, nil }, ) if err != nil { t.Fatalf("expected labels to be reconciled but it failed with %v", err) } }) } } func waitForVolumeUnmount( volumeManager kubeletvolume.VolumeManager, pod *v1.Pod) error { var podVolumes kubecontainer.VolumeMap
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct.go
limitations under the License. */ package reconciler import ( "context" v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/volume/util/operationexecutor" ) // readyToUnmount returns true when reconciler can start unmounting volumes. func (rc *reconciler) readyToUnmount() bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/controller/validatingadmissionpolicystatus/controller.go
return nil } return err } return c.reconcile(ctx, policy) }() if err == nil { c.policyQueue.Forget(key) return true } utilruntime.HandleError(err) c.policyQueue.AddRateLimited(key) return true } func (c *Controller) reconcile(ctx context.Context, policy *v1.ValidatingAdmissionPolicy) error { if policy == nil { return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 5.3K 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) -
staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease.go
klog.Infof("Shutting down peer endpoint lease reconciler") // stop reconciliation c.reconciler.StopReconciling() // Ensure that there will be no race condition with the ReconcileEndpointLeases. if err := c.reconciler.RemoveLease(c.serverId); err != nil { klog.Errorf("Unable to remove peer endpoint leases: %v", err) } c.reconciler.Destroy() }() select { case <-finishedReconciling:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 12.3K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal_test.go
) // From now on, the HPA controller does have history in it (scaleUpEvents, scaleDownEvents) // Hence the second HPA controller reconcile cycle might return different result (comparing with the first run). // Current test infrastructure has a race condition, when several reconcile cycles will be performed // while it should be stopped right after the first one. And the second will raise an exception // because of different result.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 199.3K bytes - Viewed (0)