Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewObjectStore (0.12 sec)

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

    	clock     clock.Clock
    
    	lock  sync.Mutex
    	items map[objectKey]*objectStoreItem
    
    	defaultTTL time.Duration
    	getTTL     GetObjectTTLFunc
    }
    
    // NewObjectStore returns a new ttl-based instance of Store interface.
    func NewObjectStore(getObject GetObjectFunc, clock clock.Clock, getTTL GetObjectTTLFunc, ttl time.Duration) Store {
    	return &objectStore{
    		getObject:  getObject,
    		clock:      clock,
    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/configmap/configmap_manager.go

    	getConfigMap := func(namespace, name string, opts metav1.GetOptions) (runtime.Object, error) {
    		return kubeClient.CoreV1().ConfigMaps(namespace).Get(context.TODO(), name, opts)
    	}
    	configMapStore := manager.NewObjectStore(getConfigMap, clock.RealClock{}, getTTL, defaultTTL)
    	return &configMapManager{
    		manager: manager.NewCacheBasedManager(configMapStore, 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

    	getSecret := func(namespace, name string, opts metav1.GetOptions) (runtime.Object, error) {
    		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),
    	}
    }
    
    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