Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for _get_node (0.13 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top