- Sort Score
- Result 10 results
- Languages All
Results 21 - 26 of 26 for _get_node (0.13 sec)
-
pkg/kubelet/kubelet_node_status.go
kl.containerRuntimeReadyExpected = true } }() if timeout { klog.ErrorS(nil, "Node not becoming ready in time after startup") return true } originalNode, err := kl.GetNode() if err != nil { klog.ErrorS(err, "Error getting the current node from lister") return false } readyIdx, originalNodeReady := nodeutil.GetNodeCondition(&originalNode.Status, v1.NodeReady)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 31.1K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
secretManager = secret.NewCachingSecretManager( klet.kubeClient, manager.GetObjectTTLFromNodeFunc(klet.GetNode)) configMapManager = configmap.NewCachingConfigMapManager( klet.kubeClient, manager.GetObjectTTLFromNodeFunc(klet.GetNode)) case kubeletconfiginternal.GetChangeDetectionStrategy: secretManager = secret.NewSimpleSecretManager(klet.kubeClient)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/kubelet/server/server_test.go
PodSandboxId: testPodSandboxID, Port: portForwardOpts.Ports, }) if err != nil { return nil, err } return url.Parse(resp.GetUrl()) } // Unused functions func (*fakeKubelet) GetNode() (*v1.Node, error) { return nil, nil } func (*fakeKubelet) GetNodeConfig() cm.NodeConfig { return cm.NodeConfig{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/translate/import_model.cc
for (const auto& ret_node_and_idx : llvm::enumerate(*ret_nodes)) { auto& ret_node = ret_node_and_idx.value(); if (ret_node.node == nullptr) return errors::InvalidArgument("Graph missing _Retval at index ", ret_node_and_idx.index()); TF_ASSIGN_OR_RETURN(auto type, InferInputType(*ret_node.node, /*idx=*/0, builder)); ret_types.push_back(type); }
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/workloadapi/workload.pb.go
return x.Waypoint } return nil } func (x *Workload) GetNetworkGateway() *GatewayAddress { if x != nil { return x.NetworkGateway } return nil } func (x *Workload) GetNode() string { if x != nil { return x.Node } return "" } func (x *Workload) GetCanonicalName() string { if x != nil { return x.CanonicalName } return "" }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:35 UTC 2024 - 65.9K 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)