Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for UnregisterPod (0.56 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top