- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewObjectStore (0.12 sec)
-
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) -
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) -
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)