- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for UnregisterPod (0.56 sec)
-
pkg/kubelet/util/manager/manager.go
GetObject(namespace, name string) (runtime.Object, error) // WARNING: Register/UnregisterPod functions should be efficient, // i.e. should not block on network operations. // RegisterPod registers all objects referenced from a given pod. // // NOTE: All implementations of RegisterPod should be idempotent. RegisterPod(pod *v1.Pod) // UnregisterPod unregisters objects referenced from a given pod that are not
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 10 02:22:52 UTC 2023 - 2.3K bytes - Viewed (0) -
pkg/kubelet/configmap/configmap_manager.go
// WARNING: Register/UnregisterPod functions should be efficient, // i.e. should not block on network operations. // RegisterPod registers all configmaps from a given pod. RegisterPod(pod *v1.Pod) // UnregisterPod unregisters configmaps from a given pod that are not // used by any other registered pod. UnregisterPod(pod *v1.Pod) }
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
// WARNING: Register/UnregisterPod functions should be efficient, // i.e. should not block on network operations. // RegisterPod registers all secrets from a given pod. RegisterPod(pod *v1.Pod) // UnregisterPod unregisters secrets from a given pod that are not // used by any other registered pod. UnregisterPod(pod *v1.Pod) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 5.3K bytes - Viewed (0) -
pkg/kubelet/secret/fake_manager.go
} // RegisterPod implements the RegisterPod method for testing purposes. func (s *fakeManager) RegisterPod(pod *v1.Pod) { } // UnregisterPod implements the UnregisterPod method for testing purposes. func (s *fakeManager) UnregisterPod(pod *v1.Pod) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 11 09:33:14 UTC 2023 - 1.8K bytes - Viewed (0) -
pkg/kubelet/util/manager/cache_based_manager_test.go
manager.RegisterPod(podWithSecrets("ns1", "name2", s1)) assert.Equal(t, 2, refs("ns1", "s1")) manager.UnregisterPod(podWithSecrets("ns1", "name1", s1)) assert.Equal(t, 1, refs("ns1", "s1")) manager.UnregisterPod(podWithSecrets("ns1", "name1", s1)) assert.Equal(t, 1, refs("ns1", "s1")) manager.UnregisterPod(podWithSecrets("ns1", "name2", s1)) assert.Equal(t, 0, refs("ns1", "s1")) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.6K bytes - Viewed (0) -
pkg/kubelet/configmap/fake_manager.go
} func (s *fakeManager) GetConfigMap(namespace, name string) (*v1.ConfigMap, error) { return nil, nil } func (s *fakeManager) RegisterPod(pod *v1.Pod) { } func (s *fakeManager) UnregisterPod(pod *v1.Pod) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Aug 03 19:07:12 UTC 2019 - 1K bytes - Viewed (0) -
pkg/kubelet/secret/secret_manager_test.go
containerEnvSecrets: []envSecrets{ {envVarNames: []string{"s6"}}, {envFromNames: []string{"s60"}}, }, } manager.RegisterPod(podWithSecrets("ns3", "name", s3)) manager.UnregisterPod(podWithSecrets("ns3", "name", s3)) // We should have only: s1, s3 and s4 secrets in namespaces: ns1 and ns2. for _, ns := range []string{"ns1", "ns2", "ns3"} {
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
containerEnvConfigMaps: []envConfigMaps{ {envVarNames: []string{"s6"}}, {envFromNames: []string{"s60"}}, }, } manager.RegisterPod(podWithConfigMaps("ns3", "name", s3)) manager.UnregisterPod(podWithConfigMaps("ns3", "name", s3)) existingMaps := map[string][]string{ "ns1": {"s1", "s2", "s20"}, "ns2": {"s3", "s4", "s40"}, } shouldExist := func(ns, configMap string) bool {
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/util/manager/cache_based_manager.go
for prevName := range prevNames { if !names.Has(prevName) { c.objectStore.DeleteReference(pod.Namespace, prevName, pod.UID) } } } } func (c *cacheBasedManager) UnregisterPod(pod *v1.Pod) { var prev *v1.Pod key := objectKey{namespace: pod.Namespace, name: pod.Name, uid: pod.UID} c.lock.Lock() defer c.lock.Unlock() prev = c.registeredPods[key] delete(c.registeredPods, key)
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/kubelet.go
// After volume unmount is complete, let the secret and configmap managers know we're done with this pod if kl.secretManager != nil { kl.secretManager.UnregisterPod(pod) } if kl.configMapManager != nil { kl.configMapManager.UnregisterPod(pod) } // Note: we leave pod containers to be reclaimed in the background since dockershim requires the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0)