Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 57 for node_def (0.2 sec)

  1. pkg/serviceaccount/claims.go

    			}
    
    			node, err := v.getter.GetNode(noderef.Name)
    			if err != nil {
    				klog.V(4).Infof("Could not retrieve node object %q for service account %s/%s: %v", noderef.Name, namespace, saref.Name, err)
    				return nil, errors.New("service account token has been invalidated")
    			}
    			if noderef.UID != string(node.UID) {
    				klog.V(4).Infof("Node UID no longer matches %s: %q != %q", noderef.Name, string(node.UID), noderef.UID)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 21:15:10 UTC 2023
    - 11.3K bytes
    - Viewed (0)
  2. pkg/kubelet/network/dns/dns_test.go

    		strings.Repeat("A", 127),
    	}
    
    	recorder := record.NewFakeRecorder(20)
    	nodeRef := &v1.ObjectReference{
    		Kind:      "Node",
    		Name:      string("testNode"),
    		UID:       types.UID("testNode"),
    		Namespace: "",
    	}
    	testClusterDNSDomain := "TEST"
    
    	configurer := NewConfigurer(recorder, nodeRef, nil, nil, testClusterDNSDomain, "")
    
    	pod := &v1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  3. pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux_test.go

    			fakeRecorder := &record.FakeRecorder{}
    			nodeRef := &v1.ObjectReference{Kind: "Node", Name: "test", UID: types.UID("test"), Namespace: ""}
    			manager, _ := NewManager(&Config{
    				Logger:                          logger,
    				ProbeManager:                    proberManager,
    				Recorder:                        fakeRecorder,
    				NodeRef:                         nodeRef,
    				GetPodsFunc:                     activePodsFunc,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 29.8K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/node_container_manager_linux.go

    				err := cm.cgroupManager.Update(cgroupConfig)
    				if err == nil {
    					cm.recorder.Event(nodeRef, v1.EventTypeNormal, events.SuccessfulNodeAllocatableEnforcement, "Updated Node Allocatable limit across pods")
    					return
    				}
    				message := fmt.Sprintf("Failed to update Node Allocatable Limits %q: %v", cm.cgroupRoot, err)
    				cm.recorder.Event(nodeRef, v1.EventTypeWarning, events.FailedNodeAllocatableEnforcement, message)
    				time.Sleep(time.Minute)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  5. pkg/kubelet/network/dns/dns.go

    // NewConfigurer returns a DNS configurer for launching pods.
    func NewConfigurer(recorder record.EventRecorder, nodeRef *v1.ObjectReference, nodeIPs []net.IP, clusterDNS []net.IP, clusterDomain, resolverConfig string) *Configurer {
    	return &Configurer{
    		recorder:         recorder,
    		getHostDNSConfig: getHostDNSConfig,
    		nodeRef:          nodeRef,
    		nodeIPs:          nodeIPs,
    		clusterDNS:       clusterDNS,
    		ClusterDomain:    clusterDomain,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 04 11:37:10 UTC 2023
    - 16.1K bytes
    - Viewed (0)
  6. tensorflow/compiler/jit/encapsulate_util.cc

                                   src->name());
          placeholder_builder.Attr(kOutsideCompilationSrcOutputAttrName,
                                   src_output);
          NodeDef placeholder_def;
          TF_RETURN_IF_ERROR(placeholder_builder.Finalize(&placeholder_def));
          TF_ASSIGN_OR_RETURN(placeholder_node, g->AddNode(placeholder_def));
          placeholders[placeholder_index] = placeholder_node;
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Mar 12 06:33:33 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  7. pkg/kubelet/images/image_gc_manager.go

    	im := &realImageGCManager{
    		runtime:       runtime,
    		policy:        policy,
    		imageRecords:  make(map[string]*imageRecord),
    		statsProvider: statsProvider,
    		recorder:      recorder,
    		nodeRef:       nodeRef,
    		tracer:        tracer,
    	}
    
    	return im, nil
    }
    
    func (im *realImageGCManager) Start() {
    	ctx := context.Background()
    	go wait.Until(func() {
    		_, err := im.detectImages(ctx, time.Now())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  8. pkg/kubelet/eviction/eviction_manager.go

    	nodeConditions []v1.NodeConditionType
    	// captures when a node condition was last observed based on a threshold being met
    	nodeConditionsLastObservedAt nodeConditionsObservedAt
    	// nodeRef is a reference to the node
    	nodeRef *v1.ObjectReference
    	// used to record events about the node
    	recorder record.EventRecorder
    	// used to measure usage stats on system
    	summaryProvider stats.SummaryProvider
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 27 18:55:56 UTC 2024
    - 24.6K bytes
    - Viewed (0)
  9. tensorflow/c/experimental/grappler/grappler_test.cc

          TF_NewGraphProperties(reinterpret_cast<TF_GrapplerItem*>(&item));
      TF_InferStatically(graph_properties, true, false, false, false, status);
      EXPECT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
    
      for (const NodeDef& node : item.graph.node()) {
        if (node.op() == "AddN") {
          int num_values = 0;
          TF_GetInputPropertiesListSize(graph_properties, node.name().c_str(),
                                        &num_values, status);
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Apr 13 22:30:58 UTC 2023
    - 11.6K bytes
    - Viewed (0)
  10. pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux.go

    	}
    	manager := &managerImpl{
    		logger:                           conf.Logger,
    		probeManager:                     conf.ProbeManager,
    		recorder:                         conf.Recorder,
    		nodeRef:                          conf.NodeRef,
    		getPods:                          conf.GetPodsFunc,
    		killPodFunc:                      conf.KillPodFunc,
    		syncNodeStatus:                   conf.SyncNodeStatusFunc,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 09 08:02:40 UTC 2022
    - 15.5K bytes
    - Viewed (0)
Back to top