kubernetes/pkg/kubelet/configmap/configmap_manager.go

type Manager …

type simpleConfigMapManager …

// NewSimpleConfigMapManager creates a new ConfigMapManager instance.
func NewSimpleConfigMapManager(kubeClient clientset.Interface) Manager { … }

func (s *simpleConfigMapManager) GetConfigMap(namespace, name string) (*v1.ConfigMap, error) { … }

func (s *simpleConfigMapManager) RegisterPod(pod *v1.Pod) { … }

func (s *simpleConfigMapManager) UnregisterPod(pod *v1.Pod) { … }

type configMapManager …

func (c *configMapManager) GetConfigMap(namespace, name string) (*v1.ConfigMap, error) { … }

func (c *configMapManager) RegisterPod(pod *v1.Pod) { … }

func (c *configMapManager) UnregisterPod(pod *v1.Pod) { … }

func getConfigMapNames(pod *v1.Pod) sets.Set[string] { … }

const defaultTTL …

// NewCachingConfigMapManager creates a manager that keeps a cache of all configmaps
// necessary for registered pods.
// It implement the following logic:
//   - whenever a pod is create or updated, the cached versions of all configmaps
//     are invalidated
//   - every GetObject() call tries to fetch the value from local cache; if it is
//     not there, invalidated or too old, we fetch it from apiserver and refresh the
//     value in cache; otherwise it is just fetched from cache
func NewCachingConfigMapManager(kubeClient clientset.Interface, getTTL manager.GetObjectTTLFunc) Manager { … }

// NewWatchingConfigMapManager creates a manager that keeps a cache of all configmaps
// necessary for registered pods.
// It implements the following logic:
//   - whenever a pod is created or updated, we start individual watches for all
//     referenced objects that aren't referenced from other registered pods
//   - every GetObject() returns a value from local cache propagated via watches
func NewWatchingConfigMapManager(kubeClient clientset.Interface, resyncInterval time.Duration) Manager { … }