- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 306 for Reconciled (0.22 sec)
-
pkg/kubelet/status/status_manager.go
// needsReconcile compares the given status with the status in the pod manager (which // in fact comes from apiserver), returns whether the status needs to be reconciled with // the apiserver. Now when pod status is inconsistent between apiserver and kubelet, // kubelet should forcibly send an update to reconcile the inconsistence, because kubelet // should be the source of truth of pod status.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 44.3K bytes - Viewed (0) -
operator/pkg/helmreconciler/prune.go
continue } usList = append(usList, objects) } return usList, nil } // getIstioOperatorCR is a helper function to get IstioOperator CR during purge, // otherwise the resources would be reconciled back later if there is in-cluster operator deployment. // And it is needed to remove the IstioOperator CRD. func (h *HelmReconciler) getIstioOperatorCR() *unstructured.UnstructuredList { iopGVR := iopv1alpha1.IstioOperatorGVR
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 15.9K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2.go
for _, job := range jobList { // If it has a ControllerRef, that's all that matters. if controllerRef := metav1.GetControllerOf(job); controllerRef != nil && controllerRef.Name == cronJob.Name { // this job is needs to be reconciled jobsToBeReconciled = append(jobsToBeReconciled, job) } } return jobsToBeReconciled, nil } // When a job is created, enqueue the controller that manages it and update it's expectations.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler_test.go
// Test Helpers func newReconciler(ctx context.Context, client *fake.Clientset, maxEndpointsPerSubset int32) *reconciler { broadcaster := record.NewBroadcaster(record.WithContext(ctx)) recorder := broadcaster.NewRecorder(scheme.Scheme, corev1.EventSource{Component: "endpoint-slice-mirroring-controller"}) return &reconciler{ client: client, maxEndpointsPerSubset: maxEndpointsPerSubset,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 42.7K bytes - Viewed (0) -
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) -
pkg/kubelet/pod_workers.go
} } // StartTime is not copied - that is purely for tracking latency of config propagation // from kubelet to pod worker. } // podWorkers keeps track of operations on pods and ensures each pod is // reconciled with the container runtime and other subsystems. The worker // also tracks which pods are in flight for starting, which pods are // shutting down but still have running containers, and which pods have
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler.go
limitations under the License. */ package reconciler import ( "k8s.io/apimachinery/pkg/util/wait" "k8s.io/klog/v2" ) func (rc *reconciler) Run(stopCh <-chan struct{}) { rc.reconstructVolumes() klog.InfoS("Reconciler: start to sync state") wait.Until(rc.reconcile, rc.loopSleepDuration, stopCh) } func (rc *reconciler) reconcile() { readyToUnmount := rc.readyToUnmount() if readyToUnmount {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 2.1K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/reconciler/reconciler.go
handlers map[string]cache.PluginHandler sync.RWMutex } var _ Reconciler = &reconciler{} func (rc *reconciler) Run(stopCh <-chan struct{}) { wait.Until(func() { rc.reconcile() }, rc.loopSleepDuration, stopCh) } func (rc *reconciler) AddHandler(pluginType string, pluginHandler cache.PluginHandler) { rc.Lock() defer rc.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 6.2K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
continue } // Static pods should be reconciled the same way as regular pods } // TODO: reconcile being calculated in the config manager is questionable, and avoiding // extra syncs may no longer be necessary. Reevaluate whether Reconcile and Sync can be // merged (after resolving the next two TODOs). // Reconcile Pod "Ready" condition if necessary. Trigger sync pod for reconciliation.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler.go
// as the efficiency of EndpointSlice endpoints distribution metricsCache *metrics.Cache } // reconcile takes an Endpoints resource and ensures that corresponding // EndpointSlices exist. It creates, updates, or deletes EndpointSlices to // ensure the desired set of addresses are represented by EndpointSlices. func (r *reconciler) reconcile(logger klog.Logger, endpoints *corev1.Endpoints, existingSlices []*discovery.EndpointSlice) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 13.1K bytes - Viewed (0)