- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 231 for Reconciled (0.22 sec)
-
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) -
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)