Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for serviceCluster (0.24 sec)

  1. pkg/kubelet/kubelet.go

    	registrationCompleted bool
    
    	// dnsConfigurer is used for setting up DNS resolver configuration when launching pods.
    	dnsConfigurer *dns.Configurer
    
    	// serviceLister knows how to list services
    	serviceLister serviceLister
    	// serviceHasSynced indicates whether services have been sync'd at least once.
    	// Check this before trusting a response from the lister.
    	serviceHasSynced cache.InformerSynced
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_pods_test.go

    			defer testKubelet.Cleanup()
    			kl := testKubelet.kubelet
    			if tc.nilLister {
    				kl.serviceLister = nil
    			} else if tc.unsyncedServices {
    				kl.serviceLister = testServiceLister{}
    				kl.serviceHasSynced = func() bool { return false }
    			} else {
    				kl.serviceLister = testServiceLister{services}
    				kl.serviceHasSynced = func() bool { return true }
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_pods.go

    	)
    
    	// Get all service resources from the master (via a cache),
    	// and populate them into service environment variables.
    	if kl.serviceLister == nil {
    		// Kubelets without masters (e.g. plain GCE ContainerVM) don't set env vars.
    		return m, nil
    	}
    	services, err := kl.serviceLister.List(labels.Everything())
    	if err != nil {
    		return m, fmt.Errorf("failed to list services when setting up env vars")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_test.go

    	kubelet.runtimeState.setNetworkState(nil)
    	kubelet.rootDirectory = t.TempDir()
    	kubelet.podLogsDirectory = t.TempDir()
    	kubelet.sourcesReady = config.NewSourcesReady(func(_ sets.Set[string]) bool { return true })
    	kubelet.serviceLister = testServiceLister{}
    	kubelet.serviceHasSynced = func() bool { return true }
    	kubelet.nodeHasSynced = func() bool { return true }
    	kubelet.nodeLister = testNodeLister{
    		nodes: []*v1.Node{
    			{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
Back to top