- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 64 for statusFn (0.14 sec)
-
pkg/kubelet/eviction/eviction_manager_test.go
Type: "DisruptionTarget", Status: "True", Reason: "TerminationByKubelet", Message: "The node was low on resource: memory. Threshold quantity: 2Gi, available: 1500Mi. ", }) } // verify the pod status after applying the status update function podKiller.statusFn(&podKiller.pod.Status)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 119.9K bytes - Viewed (0) -
cmd/server_test.go
c.Assert(err, nil) // execute the HTTP request initiating the new multipart upload. response, err = s.client.Do(request) c.Assert(err, nil) // expecting the response status code to be http.StatusOK(200 OK) . c.Assert(response.StatusCode, http.StatusOK) // parse the response body and obtain the new upload ID. decoder := xml.NewDecoder(response.Body) newResponse := &InitiateMultipartUploadResponse{}
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 115.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/apiserver_test.go
defer server.Close() status := expectAPIStatus(t, "DELETE", fmt.Sprintf("%s/"+prefix+"/"+testGroupVersion.Group+"/"+testGroupVersion.Version+"/namespaces/default/foo/bar", server.URL), nil, http.StatusConflict) if status.Status != metav1.StatusFailure || status.Message == "" || status.Details == nil || status.Reason != metav1.StatusReasonAlreadyExists { t.Errorf("Unexpected status %#v", status) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 20:15:22 UTC 2023 - 158.7K bytes - Viewed (0) -
cmd/object-handlers_test.go
// Call the ServeHTTP to executes the registered handler. apiRouter.ServeHTTP(rec, req) // Assert the response code with the expected status. if rec.Code != http.StatusOK { t.Fatalf("%s: Expected the response status to be `%d`, but instead found `%d`", instanceType, http.StatusOK, rec.Code) } // decode the response body. decoder := xml.NewDecoder(rec.Body)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 161.9K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/translate/import_model.cc
(*node_name_map)[placeholder_node->name()] = placeholder_node; // Add the new placeholder node to the shape refiner. Status status = shape_refiner_->AddNode(placeholder_node); if (!status.ok()) { return EmitErrorWithLocationStr(*placeholder_node, status); } } } else { auto index_it = it->second.find(0); if (index_it == it->second.end()) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 01 11:17:36 UTC 2024 - 183.2K bytes - Viewed (0) -
pkg/printers/internalversion/printers.go
case obj.Status.StartTime == nil: case obj.Status.CompletionTime == nil: jobDuration = duration.HumanDuration(time.Since(obj.Status.StartTime.Time)) default: jobDuration = duration.HumanDuration(obj.Status.CompletionTime.Sub(obj.Status.StartTime.Time)) } var status string if hasJobCondition(obj.Status.Conditions, batch.JobComplete) { status = "Complete"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 14:04:15 UTC 2024 - 128.3K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
status := statuses[container.Name] // If the status we're about to write indicates the default, the Waiting status will force this pod back into Pending. // That isn't true, we know the pod was previously running. isDefaultWaitingStatus := status.State.Waiting != nil && status.State.Waiting.Reason == ContainerCreating if hasInitContainers {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
tests/integration/pilot/common/routing.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 21:52:51 UTC 2024 - 135.9K bytes - Viewed (0) -
pkg/kubelet/eviction/helpers_test.go
} statsFn := func(pod *v1.Pod) (statsapi.PodStats, bool) { result, found := stats[pod] return result, found } pods := []*v1.Pod{pod8, pod7, pod6, pod5, pod4, pod3, pod2, pod1} expected := []*v1.Pod{pod1, pod2, pod3, pod4, pod5, pod6, pod7, pod8} orderedBy(exceedMemoryRequests(statsFn), priority, memory(statsFn)).Sort(pods) for i := range expected {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 106.7K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
func checkPodStatus(t *testing.T, kl *Kubelet, pod *v1.Pod, phase v1.PodPhase) { t.Helper() status, found := kl.statusManager.GetPodStatus(pod.UID) require.True(t, found, "Status of pod %q is not found in the status map", pod.UID) require.Equal(t, phase, status.Phase) } // Tests that we handle port conflicts correctly by setting the failed status in status map. func TestHandlePortConflicts(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0)