- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for NewObjectStore (0.27 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/secret/secret_manager_test.go
} pod.Spec.Containers = append(pod.Spec.Containers, container) } return pod } 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.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 10 10:20:09 UTC 2021 - 4.5K bytes - Viewed (0) -
pkg/kubelet/configmap/configmap_manager_test.go
VolumeSource: v1.VolumeSource{ ConfigMap: volume, }, }) } return pod } func TestCacheBasedConfigMapManager(t *testing.T) { 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.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 10 10:20:09 UTC 2021 - 4.8K 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)