- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 242 for syncPod (0.18 sec)
-
pkg/kubelet/kuberuntime/kuberuntime_manager_test.go
// GetPodStatus and the following SyncPod will not return errors in the // case where the pod has been deleted. We are not adding any pods into // the fakePodProvider so they are 'deleted'. podStatus, err := m.GetPodStatus(ctx, pod.UID, pod.Name, pod.Namespace) assert.NoError(t, err) result := m.SyncPod(context.Background(), pod, podStatus, []v1.Secret{}, backOff)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 96K bytes - Viewed (0) -
pkg/kubelet/preemption/preemption.go
Message: "Pod was preempted by Kubelet to accommodate a critical pod.", }) } }) if err != nil { klog.ErrorS(err, "Failed to evict pod", "pod", klog.KObj(pod)) // In future syncPod loops, the kubelet will retry the pod deletion steps that it was stuck on. continue } if len(insufficientResources) > 0 { metrics.Preemptions.WithLabelValues(insufficientResources[0].resourceName.String()).Inc()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 02 16:53:19 UTC 2023 - 11.5K bytes - Viewed (0) -
pkg/kubelet/container/runtime.go
// will be GC'd. // TODO: Revisit this method and make it cleaner. GarbageCollect(ctx context.Context, gcPolicy GCPolicy, allSourcesReady bool, evictNonDeletedPods bool) error // SyncPod syncs the running pod into the desired pod. SyncPod(ctx context.Context, pod *v1.Pod, podStatus *PodStatus, pullSecrets []v1.Secret, backOff *flowcontrol.Backoff) PodSyncResult
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 27.8K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
} return resource.ExtractResourceValueByContainerName(fs, pod, containerName) } // killPod instructs the container runtime to kill the pod. This method requires that // the pod status contains the result of the last syncPod, otherwise it may fail to // terminate newly created containers and sandboxes. func (kl *Kubelet) killPod(ctx context.Context, pod *v1.Pod, p kubecontainer.Pod, gracePeriodOverride *int64) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
if err != nil { return err } switch prefix { case podKeyPrefix: return ec.syncPod(ctx, namespace, name) case claimKeyPrefix: return ec.syncClaim(ctx, namespace, name) default: return fmt.Errorf("unexpected key prefix: %s", prefix) } } func (ec *Controller) syncPod(ctx context.Context, namespace, name string) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
// processing it at a very high frequency. The pod will be reprocessed when volume manager calls // ReprocessPod() which is triggered by SyncPod. dswp.markPodProcessed(uniquePodName) } } // checkVolumeFSResize records desired PVC size for a volume mounted by the pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.3.md
* This eliminates the race conditions between the pod creation loop and the orphaned volumes loops. It also removes the unmount/detach from the `syncPod()` path so volume clean up never blocks the `syncPod` loop. # v1.3.0-beta.1 [Documentation](http://kubernetes.github.io) & [Examples](http://releases.k8s.io/release-1.3/examples) ## Downloads
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 24 02:28:26 UTC 2020 - 84K bytes - Viewed (0) -
src/internal/pkgbits/sync.go
const ( _ SyncMarker = iota // Public markers (known to go/types importers). // Low-level coding markers. SyncEOF SyncBool SyncInt64 SyncUint64 SyncString SyncValue SyncVal SyncRelocs SyncReloc SyncUseReloc // Higher-level object and type markers. SyncPublic SyncPos SyncPosBase SyncObject SyncObject1 SyncPkg SyncPkgDef SyncMethod SyncType SyncTypeIdx
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Aug 04 17:12:28 UTC 2022 - 2.4K bytes - Viewed (0) -
src/internal/pkgbits/syncmarker_string.go
// Re-run the stringer command to generate them again. var x [1]struct{} _ = x[SyncEOF-1] _ = x[SyncBool-2] _ = x[SyncInt64-3] _ = x[SyncUint64-4] _ = x[SyncString-5] _ = x[SyncValue-6] _ = x[SyncVal-7] _ = x[SyncRelocs-8] _ = x[SyncReloc-9] _ = x[SyncUseReloc-10] _ = x[SyncPublic-11] _ = x[SyncPos-12] _ = x[SyncPosBase-13] _ = x[SyncObject-14] _ = x[SyncObject1-15] _ = x[SyncPkg-16]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 11 20:24:07 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/proxy/healthcheck/healthcheck_test.go
} testProxierHealthUpdater(hs, hsTest, fakeClock, t) // Should return 200 "OK" if we've synced a node, tainted in any other way hs.SyncNode(makeNode(tweakTainted("other"))) testHTTPHandler(hsTest, http.StatusOK, t) // Should return 503 "ServiceUnavailable" if we've synced a ToBeDeletedTaint node hs.SyncNode(makeNode(tweakTainted(ToBeDeletedTaint))) testHTTPHandler(hsTest, http.StatusServiceUnavailable, t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 21.4K bytes - Viewed (0)