- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for getNodes (0.15 sec)
-
pkg/kubelet/kubelet_pods.go
// those pods during admission may still be in use. See // https://github.com/kubernetes/kubernetes/issues/104824 func (kl *Kubelet) GetActivePods() []*v1.Pod { allPods := kl.podManager.GetPods() activePods := kl.filterOutInactivePods(allPods) return activePods } // makeBlockVolumes maps the raw block devices specified in the path of the container // Experimental
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/nodelifecycle/node_lifecycle_controller_test.go
t.Errorf("unexpected error: %v", err) } if err := nodeController.monitorNodeHealth(ctx); err != nil { t.Errorf("unexpected error: %v", err) } zones := testutil.GetZones(item.fakeNodeHandler) logger, _ := ktesting.NewTestContext(t) for _, zone := range zones { nodeController.zoneNoExecuteTainter[zone].Try(logger, func(value scheduler.TimedValue) (bool, time.Duration) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 03:26:45 UTC 2024 - 119K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status_test.go
defer testKubelet.Cleanup() kubelet := testKubelet.kubelet // Ensure we capture actions on the heartbeat client only. // We don't set it to nil or GetNode() doesn't read from nodeLister. kubelet.kubeClient = &fake.Clientset{} kubeClient := testKubelet.fakeKubeClient node := &v1.Node{ ObjectMeta: metav1.ObjectMeta{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 19:23:19 UTC 2024 - 115.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/ir/tf_ops_n_z.cc
new_result_types.push_back(valid_output_type); auto nmsv4 = CreateTfOp<TF::NonMaxSuppressionV4Op>( rewriter, nms_op, new_result_types, nms_op.getBoxes(), nms_op.getScores(), nms_op.getMaxOutputSize(), nms_op.getIouThreshold(), nms_op.getScoreThreshold()); // Cannot replace the NMSv3 Op with NMSv4 since the outputs between the
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 09 22:07:10 UTC 2024 - 170.8K bytes - Viewed (0) -
pkg/config/validation/validation.go
return errs.Unwrap() }) func validateSidecarOutboundTrafficPolicy(tp *networking.OutboundTrafficPolicy) (errs error) { if tp == nil { return } mode := tp.GetMode() if tp.EgressProxy != nil { if mode != networking.OutboundTrafficPolicy_ALLOW_ANY { errs = appendErrors(errs, fmt.Errorf("sidecar: egress_proxy must be set only with ALLOW_ANY outbound_traffic_policy mode")) return
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 04:03:33 UTC 2024 - 107.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/flatbuffer_export.cc
return translator->TranslateInternal(); } return ret; } bool Translator::CheckGpuDelegateCompatibility(uint8_t* model_buffer_pointer) { bool gpu_compatibile = true; auto model = tflite::GetModel(model_buffer_pointer); auto subgraphs = model->subgraphs(); for (int i = 0; i < subgraphs->Length(); ++i) { const tflite::SubGraph* subgraph = subgraphs->Get(i);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Jun 12 21:41:49 UTC 2024 - 164.5K bytes - Viewed (0)