Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for NewCacheBasedManager (0.23 sec)

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

    	delete(c.registeredPods, key)
    	if prev != nil {
    		for name := range c.getReferencedObjects(prev) {
    			c.objectStore.DeleteReference(prev.Namespace, name, prev.UID)
    		}
    	}
    }
    
    // NewCacheBasedManager 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, the cached versions of all objects
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  2. pkg/kubelet/secret/secret_manager_test.go

    func TestCacheBasedSecretManager(t *testing.T) {
    	fakeClient := &fake.Clientset{}
    	store := manager.NewObjectStore(getSecret(fakeClient), clock.RealClock{}, noObjectTTL, 0)
    	manager := &secretManager{
    		manager: manager.NewCacheBasedManager(store, getSecretNames),
    	}
    
    	// Create a pod with some secrets.
    	s1 := secretsToAttach{
    		imagePullSecretNames: []string{"s1"},
    		containerEnvSecrets: []envSecrets{
    			{envVarNames: []string{"s1"}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 10 10:20:09 UTC 2021
    - 4.5K bytes
    - Viewed (0)
  3. pkg/kubelet/configmap/configmap_manager_test.go

    	fakeClient := &fake.Clientset{}
    	store := manager.NewObjectStore(getConfigMap(fakeClient), clock.RealClock{}, noObjectTTL, 0)
    	manager := &configMapManager{
    		manager: manager.NewCacheBasedManager(store, getConfigMapNames),
    	}
    
    	// Create a pod with some configMaps.
    	s1 := configMapsToAttach{
    		containerEnvConfigMaps: []envConfigMaps{
    			{envVarNames: []string{"s1"}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 10 10:20:09 UTC 2021
    - 4.8K bytes
    - Viewed (0)
  4. pkg/kubelet/configmap/configmap_manager.go

    	}
    	configMapStore := manager.NewObjectStore(getConfigMap, clock.RealClock{}, getTTL, defaultTTL)
    	return &configMapManager{
    		manager: manager.NewCacheBasedManager(configMapStore, getConfigMapNames),
    	}
    }
    
    // NewWatchingConfigMapManager creates a manager that keeps a cache of all configmaps
    // necessary for registered pods.
    // It implements the following logic:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  5. pkg/kubelet/secret/secret_manager.go

    		return kubeClient.CoreV1().Secrets(namespace).Get(context.TODO(), name, opts)
    	}
    	secretStore := manager.NewObjectStore(getSecret, clock.RealClock{}, getTTL, defaultTTL)
    	return &secretManager{
    		manager: manager.NewCacheBasedManager(secretStore, getSecretNames),
    	}
    }
    
    // NewWatchingSecretManager creates a manager that keeps a cache of all secrets
    // necessary for registered pods.
    // It implements the following logic:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  6. pkg/kubelet/util/manager/watch_based_manager.go

    	// TODO propagate stopCh from the higher level.
    	objectStore := NewObjectCache(listObject, watchObject, newObject, isImmutable, groupResource, clock.RealClock{}, maxIdleTime, wait.NeverStop)
    	return NewCacheBasedManager(objectStore, getReferencedObjects)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  7. pkg/kubelet/util/manager/cache_based_manager_test.go

    	podutil.VisitPodSecretNames(pod, func(name string) bool {
    		result.Insert(name)
    		return true
    	})
    	return result
    }
    
    func newCacheBasedSecretManager(store Store) Manager {
    	return NewCacheBasedManager(store, getSecretNames)
    }
    
    func TestSecretStore(t *testing.T) {
    	fakeClient := &fake.Clientset{}
    	store := newSecretStore(fakeClient, clock.RealClock{}, noObjectTTL, 0)
    	store.AddReference("ns1", "name1", "pod1")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.6K bytes
    - Viewed (0)
Back to top