- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 136 for statusFn (0.28 sec)
-
pkg/kubelet/pod_workers.go
// ones who started it. pod := options.Pod if isRuntimePod { status.observedRuntime = true switch { case status.pendingUpdate != nil && status.pendingUpdate.Pod != nil: pod = status.pendingUpdate.Pod options.Pod = pod options.RunningPod = nil case status.activeUpdate != nil && status.activeUpdate.Pod != nil: pod = status.activeUpdate.Pod options.Pod = pod options.RunningPod = nil default:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/flatbuffer_import.cc
#include "tensorflow/core/platform/errors.h" #include "tensorflow/core/platform/status.h" #include "tensorflow/lite/experimental/remat/metadata_util.h" #include "tensorflow/lite/graph_info.h" #include "tensorflow/lite/model_builder.h" #include "tsl/platform/status.h" #include "tsl/platform/statusor.h" using absl::Status; using absl::StatusOr; using llvm::ArrayRef; using mlir::Builder; using mlir::DenseElementsAttr;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue May 21 18:21:50 UTC 2024 - 66.8K bytes - Viewed (0) -
tensorflow/compiler/jit/mark_for_compilation_pass.cc
// true if successful. absl::StatusOr<bool> TryToContractEdge(Cluster* from, Cluster* to); // Nodes that XLA can compile are put in `compilation_candidates_`. Status FindCompilationCandidates(); bool CompilationDisallowedByXlaCompileAttr(Node* node); // Populates `clusters_`. Status BuildInitialClusterSet(); absl::StatusOr<bool> ShouldCompileClusterImpl(const Cluster& cluster);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 21 12:19:41 UTC 2024 - 85.3K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
client := fake.NewSimpleClientset(pod) m := newTestManager(client) status := v1.PodStatus{Message: "initial status"} m.SetPodStatus(pod, status) status.Message = "first version bump" m.SetPodStatus(pod, status) status.Message = "second version bump" m.SetPodStatus(pod, status) t.Logf("sync batch before syncPods pushes latest status, resulting in one update during the batch") m.syncBatch(true)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/modular_filesystem_test.cc
if (!status.ok()) GTEST_SKIP() << "Append() not supported: " << status; status = new_file->Flush(); if (!status.ok()) GTEST_SKIP() << "Flush() not supported: " << status; status = new_file->Close(); if (!status.ok()) GTEST_SKIP() << "Close() not supported: " << status; std::unique_ptr<ReadOnlyMemoryRegion> region; status = env_->NewReadOnlyMemoryRegionFromFile(filepath, ®ion);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 27 20:25:58 UTC 2022 - 71K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal.go
metricSpecs []autoscalingv2.MetricSpec) (replicas int32, metric string, statuses []autoscalingv2.MetricStatus, timestamp time.Time, err error) { selector, err := a.validateAndParseSelector(hpa, scale.Status.Selector) if err != nil { return -1, "", nil, time.Time{}, err } specReplicas := scale.Spec.Replicas statusReplicas := scale.Status.Replicas statuses = make([]autoscalingv2.MetricStatus, len(metricSpecs))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 63.6K bytes - Viewed (0) -
internal/s3select/select_test.go
if err = s3Select.Open(newStringRSC(in)); err != nil { t.Fatal(err) } w := &testResponseWriter{} s3Select.Evaluate(w) s3Select.Close() resp := http.Response{ StatusCode: http.StatusOK, Body: io.NopCloser(bytes.NewReader(w.response)), ContentLength: int64(len(w.response)), } res, err := minio.NewSelectResults(&resp, "testbucket") if err != nil { t.Error(err)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 23 07:19:11 UTC 2023 - 76.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
if err != nil { t.Fatalf("Expected request: %q to get a response, but got error: %#v", secondRequestPathShouldWork, err) } if response.StatusCode != http.StatusOK { t.Errorf("Expected HTTP status code: %d for request: %q, but got: %#v", http.StatusOK, secondRequestPathShouldWork, response) } select { case <-secondHandlerDoneCh: case <-time.After(wait.ForeverTestTimeout):
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
return nil, err } status := resp.GetStatus() if status == nil { return nil, remote.ErrContainerStatusNil } cStatus := m.convertToKubeContainerStatus(status) statuses = append(statuses, cStatus) } sort.Sort(containerStatusByCreated(statuses)) return statuses, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/installer.go
// http.StatusServiceUnavailable // and api error codes // Note that if we specify a versioned Status object here, we may need to // create one for the tests, also // Success: // http.StatusOK, http.StatusCreated, http.StatusAccepted, http.StatusNoContent // // test/integration/auth_test.go is currently the most comprehensive status code test for _, s := range a.group.Serializer.SupportedMediaTypes() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 51.5K bytes - Viewed (0)