Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewWatchBasedManager (0.21 sec)

  1. pkg/kubelet/util/manager/watch_based_manager.go

    	<-stopCh
    
    	c.lock.Lock()
    	defer c.lock.Unlock()
    
    	c.stopped = true
    	for _, item := range c.items {
    		item.stop()
    	}
    }
    
    // NewWatchBasedManager creates a manager that keeps a cache of all objects
    // necessary for registered pods.
    // It implements the following logic:
    //   - whenever a pod is created or updated, we start individual watches for all
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  2. pkg/kubelet/configmap/configmap_manager.go

    			return configMap.Immutable != nil && *configMap.Immutable
    		}
    		return false
    	}
    	gr := corev1.Resource("configmap")
    	return &configMapManager{
    		manager: manager.NewWatchBasedManager(listConfigMap, watchConfigMap, newConfigMap, isImmutable, gr, resyncInterval, getConfigMapNames),
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  3. pkg/kubelet/secret/secret_manager.go

    		if secret, ok := object.(*v1.Secret); ok {
    			return secret.Immutable != nil && *secret.Immutable
    		}
    		return false
    	}
    	gr := corev1.Resource("secret")
    	return &secretManager{
    		manager: manager.NewWatchBasedManager(listSecret, watchSecret, newSecret, isImmutable, gr, resyncInterval, getSecretNames),
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 5.3K bytes
    - Viewed (0)
Back to top