Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 84 for INITIALIZING (0.28 sec)

  1. pkg/controller/volume/attachdetach/attach_detach_controller.go

    	return adc.volumeAttachmentLister
    }
    
    // VolumeHost implementation
    // This is an unfortunate requirement of the current factoring of volume plugin
    // initializing code. It requires kubelet specific methods used by the mounting
    // code to be implemented by all initializers even if the initializer does not
    // do mounting (like this attach/detach controller).
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/container_manager_linux.go

    					"might be swapped to disk and should no longer be considered secure.",
    			)
    		}
    	}
    
    	var internalCapacity = v1.ResourceList{}
    	// It is safe to invoke `MachineInfo` on cAdvisor before logically initializing cAdvisor here because
    	// machine info is computed and cached once as part of cAdvisor object creation.
    	// But `RootFsInfo` and `ImagesFsInfo` are not available at this moment so they will be called later during manager starts
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_node_status.go

    	copy(nodeTaints, kl.registerWithTaints)
    	unschedulableTaint := v1.Taint{
    		Key:    v1.TaintNodeUnschedulable,
    		Effect: v1.TaintEffectNoSchedule,
    	}
    
    	// Taint node with TaintNodeUnschedulable when initializing
    	// node to avoid race condition; refer to #63897 for more detail.
    	if node.Spec.Unschedulable &&
    		!taintutil.TaintExists(nodeTaints, &unschedulableTaint) {
    		nodeTaints = append(nodeTaints, unschedulableTaint)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  4. src/cmd/compile/internal/types2/decl.go

    	// is such that the color value of a grey object indicates the index of
    	// that object in the object path.
    
    	// During type-checking, white objects may be assigned a type without
    	// traversing through objDecl; e.g., when initializing constants and
    	// variables. Update the colors of those objects here (rather than
    	// everywhere where we set the type) to satisfy the color invariants.
    	if obj.color() == white && obj.Type() != nil {
    		obj.setColor(black)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 29.6K bytes
    - Viewed (0)
  5. src/go/types/decl.go

    	// is such that the color value of a grey object indicates the index of
    	// that object in the object path.
    
    	// During type-checking, white objects may be assigned a type without
    	// traversing through objDecl; e.g., when initializing constants and
    	// variables. Update the colors of those objects here (rather than
    	// everywhere where we set the type) to satisfy the color invariants.
    	if obj.color() == white && obj.Type() != nil {
    		obj.setColor(black)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 31K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/kube/controller/controller.go

    		c.networkManager.HasSynced()
    }
    
    func (c *Controller) syncPods() error {
    	var err *multierror.Error
    	pods := c.podsClient.List(metav1.NamespaceAll, klabels.Everything())
    	log.Debugf("initializing %d pods", len(pods))
    	for _, s := range pods {
    		err = multierror.Append(err, c.pods.onEvent(nil, s, model.EventAdd))
    	}
    	return err.ErrorOrNil()
    }
    
    // Run all controllers until a signal is received
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  7. cmd/erasure-multipart.go

    	if !result.IsTruncated {
    		result.NextKeyMarker = ""
    		result.NextUploadIDMarker = ""
    	}
    
    	return result, nil
    }
    
    // newMultipartUpload - wrapper for initializing a new multipart
    // request; returns a unique upload id.
    //
    // Internally this function creates 'uploads.json' associated for the
    // incoming object at
    // '.minio.sys/multipart/bucket/object/uploads.json' on all the
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 44.8K bytes
    - Viewed (0)
  8. src/runtime/symtab.go

    	textsectmap []textsect
    	typelinks   []int32 // offsets from types
    	itablinks   []*itab
    
    	ptab []ptabEntry
    
    	pluginpath string
    	pkghashes  []modulehash
    
    	// This slice records the initializing tasks that need to be
    	// done to start up the program. It is built by the linker.
    	inittasks []*initTask
    
    	modulename   string
    	modulehashes []modulehash
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 40K bytes
    - Viewed (0)
  9. pkg/controller/nodelifecycle/node_lifecycle_controller.go

    			scheduler.NewRateLimitedTimedQueue(
    				flowcontrol.NewTokenBucketRateLimiter(nc.evictionLimiterQPS, scheduler.EvictionRateLimiterBurst))
    		// Init the metric for the new zone.
    		logger.Info("Initializing eviction metric for zone", "zone", zone)
    		evictionsTotal.WithLabelValues(zone).Add(0)
    	}
    }
    
    func (nc *Controller) markNodeForTainting(node *v1.Node, status v1.ConditionStatus) bool {
    	nc.evictorLock.Lock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  10. pkg/proxy/winkernel/proxier.go

    	healthzServer *healthcheck.ProxierHealthServer,
    	healthzBindAddress string,
    	config config.KubeProxyWinkernelConfiguration,
    ) (*Proxier, error) {
    	if nodeIP == nil {
    		klog.InfoS("Invalid nodeIP, initializing kube-proxy with 127.0.0.1 as nodeIP")
    		nodeIP = netutils.ParseIPSloppy("127.0.0.1")
    	}
    
    	// windows listens to all node addresses
    	nodePortAddresses := proxyutil.NewNodePortAddresses(ipFamily, nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
Back to top