Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewCacheBasedManager (0.16 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/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)
  3. 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)
Back to top