Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for FindContainer (0.13 sec)

  1. pkg/kube/inject/app_probe.go

    func FindContainerFromPod(name string, pod *corev1.Pod) *corev1.Container {
    	if c := FindContainer(name, pod.Spec.Containers); c != nil {
    		return c
    	}
    	return FindContainer(name, pod.Spec.InitContainers)
    }
    
    // FindContainer returns the pointer to the first container whose name matches.
    func FindContainer(name string, containers []corev1.Container) *corev1.Container {
    	for i := range containers {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Aug 04 15:06:24 UTC 2023
    - 8.4K bytes
    - Viewed (0)
  2. pkg/kube/inject/webhook.go

    		// env variables like ISTIO_META_APP_CONTAINERS and ISTIO_META_POD_PORTS.
    		if match := FindContainer(c.Name, parsedInjectedStatus.Containers); match != nil {
    			continue
    		}
    		match := FindContainer(c.Name, existingOverrides.Containers)
    		if match == nil {
    			match = FindContainer(c.Name, originalPod.Spec.Containers)
    		}
    		if match == nil {
    			continue
    		}
    		overlay := *match.DeepCopy()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 17:59:39 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  3. pkg/kube/inject/inject.go

    		// move the container.
    		if features.EnableNativeSidecars.Get() &&
    			FindContainer(ProxyContainerName, templatePod.Spec.InitContainers) != nil &&
    			FindContainer(ProxyContainerName, mergedPod.Spec.Containers) != nil {
    			mergedPod = mergedPod.DeepCopy()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 20:35:11 UTC 2024
    - 28.8K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_pods.go

    	// TODO: allowlist logs we are willing to serve
    	kl.logServer.ServeHTTP(w, req)
    }
    
    // findContainer finds and returns the container with the given pod ID, full name, and container name.
    // It returns nil if not found.
    func (kl *Kubelet) findContainer(ctx context.Context, podFullName string, podUID types.UID, containerName string) (*kubecontainer.Container, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  5. pkg/kubelet/kuberuntime/kuberuntime_manager.go

    	// the same name, because one of them have not been fully terminated yet.
    	// To avoid unexpected behavior on container name based search (for example
    	// by calling *Kubelet.findContainer() without specifying a pod ID), we now
    	// return the list of pods ordered by their creation time.
    	sort.SliceStable(result, func(i, j int) bool {
    		return result[i].CreatedAt > result[j].CreatedAt
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet.go

    func (kl *Kubelet) CheckpointContainer(
    	ctx context.Context,
    	podUID types.UID,
    	podFullName,
    	containerName string,
    	options *runtimeapi.CheckpointContainerRequest,
    ) error {
    	container, err := kl.findContainer(ctx, podFullName, podUID, containerName)
    	if err != nil {
    		return err
    	}
    	if container == nil {
    		return fmt.Errorf("container %v not found", containerName)
    	}
    
    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