- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for checkpointing_ (0.2 sec)
-
pkg/kubelet/server/server_test.go
if err != nil { t.Errorf("Got error POSTing: %v", err) } defer resp.Body.Close() if resp.StatusCode != http.StatusNotFound { t.Errorf("Unexpected non-error checkpointing container: %#v", resp) } }) // Now the checkpointing of the container fails fw.fakeKubelet.podByNameFunc = func(namespace, name string) (*v1.Pod, bool) { return &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Namespace: podNamespace,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.5K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.30.md
- Graduated _forensic container checkpointing_ [KEP #2008](https://kep.k8s.io/2008) from Alpha to Beta. ([#123215](https://github.com/kubernetes/kubernetes/pull/123215), [@adrianreber](https://github.com/adrianreber)) [SIG Node and Testing]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 04:05:28 UTC 2024 - 253.2K bytes - Viewed (0) -
pkg/kubelet/cm/dra/manager.go
if !exists { return nil } // Skip calling NodeUnprepareResource if other pods are still referencing it if len(claimInfo.PodUIDs) > 1 { // We delay checkpointing of this change until // UnprepareResources returns successfully. It is OK to do // this because we will only return successfully from this call // if the checkpoint has succeeded. That means if the kubelet
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:29 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/kubelet/server/server.go
} if err := s.host.CheckpointContainer(ctx, pod.UID, kubecontainer.GetPodFullName(pod), containerName, options); err != nil { response.WriteError( http.StatusInternalServerError, fmt.Errorf( "checkpointing of %v/%v/%v failed (%v)", request.PathParameter("podNamespace"), request.PathParameter("podID"), containerName, err, ), ) return } writeJSONResponse(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 40.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler.go
// For HA clusters, we want to prevent race conditions when changing status to Established, // so we want to be sure that CRD is Installing at least for 5 seconds before Establishing it. // TODO: find a real HA safe checkpointing mechanism instead of an arbitrary wait. if !apiextensionshelpers.IsCRDConditionTrue(newCRD, apiextensionsv1.Established) && apiextensionshelpers.IsCRDConditionTrue(newCRD, apiextensionsv1.NamesAccepted) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 19:06:46 UTC 2024 - 52.9K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
// updates are delivered to the pod workers while this method is running. func (kl *Kubelet) HandlePodCleanups(ctx context.Context) error { // The kubelet lacks checkpointing, so we need to introspect the set of pods // in the cgroup tree prior to inspecting the set of pods in our pod manager. // this ensures our view of the cgroup tree does not mistakenly observe pods
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/prove.go
lens map[ID]*Value caps map[ID]*Value // zero is a zero-valued constant zero *Value } // checkpointFact is an invalid value used for checkpointing // and restoring factsTable. var checkpointFact = fact{} var checkpointBound = limitFact{} func newFactsTable(f *Func) *factsTable { ft := &factsTable{} ft.orderS = f.newPoset()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 17:30:21 UTC 2024 - 48.9K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
// After restarting, kubelet will get all existing pods through // ADD as if they are new pods. These pods will then go through the // admission process and *may* be rejected. This can be resolved // once we have checkpointing. handler.HandlePodAdditions(u.Pods) case kubetypes.UPDATE: klog.V(2).InfoS("SyncLoop UPDATE", "source", u.Source, "pods", klog.KObjSlice(u.Pods)) handler.HandlePodUpdates(u.Pods)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (1) -
RELEASE.md
* Add `tf.experimental.dtensor.is_dtensor` to check if a tensor is a DTensor instance. * `tf.data`:
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jun 11 23:24:08 UTC 2024 - 730.3K bytes - Viewed (0) -
common-protos/k8s.io/api/core/v1/generated.proto
// to load or validate the Assigned config, etc. // Errors may occur at different points while syncing config. Earlier errors (e.g. download or // checkpointing errors) will not result in a rollback to LastKnownGood, and may resolve across // Kubelet retries. Later errors (e.g. loading or validating a checkpointed config) will result in
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 255.8K bytes - Viewed (0)