Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NewObjectStore (0.16 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/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)
  3. 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)
  4. 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)
  5. 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