Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 75 for pod (0.15 sec)

  1. cni/pkg/repair/netns.go

    // This rules out two possible methods:
    // * use crictl to inspect the pod; this returns the bind-mounted network namespace file.
    // * /var/lib/cni/results shows the outputs of CNI plugins; this containers the bind-mounted network namespace file.
    //
    // Instead, we traverse the procfs. Comments on this method are inline.
    func getPodNetNs(pod *corev1.Pod) (string, error) {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Dec 20 22:14:13 GMT 2023
    - 4.8K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/informers_test.go

    	mt.Assert(EventTotals.Name(), map[string]string{"type": "update"}, monitortest.AtLeast(4))
    
    	waitForMockCalls()
    
    	assertPodNotAnnotated(t, client, pod)
    
    	// patch a test label to emulate a POD update event
    	_, err = client.Kube().CoreV1().Pods(pod.Namespace).Patch(ctx, pod.Name,
    		types.MergePatchType, []byte(`{"metadata":{"labels":{"test":"update"}}}`), metav1.PatchOptions{})
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/net_test.go

    	}
    	pod := &corev1.Pod{ObjectMeta: podMeta}
    
    	fixture.ipsetDeps.On("listEntriesByIP",
    		"foo-v4",
    	).Return([]netip.Addr{}, nil)
    
    	err := netServer.ConstructInitialSnapshot([]*corev1.Pod{pod})
    	assert.NoError(t, err)
    	if fixture.podNsMap.Get("863b91d4-4b68-4efa-917f-4b560e3e86aa") == nil {
    		t.Fatal("expected pod to be in cache")
    	}
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 16.4K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/ztunnelserver.go

    	PodDeleted(ctx context.Context, uid string) error
    	PodAdded(ctx context.Context, pod *v1.Pod, netns Netns) error
    	Close() error
    }
    
    /*
    To clean up stale ztunnels
    
    	we may need to ztunnel to send its (uid, bootid / boot time) to us
    	so that we can remove stale entries when the ztunnel pod is deleted
    	or when the ztunnel pod is restarted in the same pod (remove old entries when the same uid connects again, but with different boot id?)
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  5. istioctl/pkg/dashboard/dashboard.go

      istioctl dashboard proxy productpage-123-456.default
    
      # Open envoy admin dashboard for one pod under a deployment
      istioctl dashboard proxy deployment/productpage-v1
    
      # Open dashboard for the ztunnel-bwh89.istio-system pod
      istioctl dashboard proxy ztunnel-bwh89.istio-system
    
      # Open dashboard for a waypoint pod
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Apr 15 01:29:35 GMT 2024
    - 20.5K bytes
    - Viewed (0)
  6. istioctl/pkg/util/handlers/handlers_test.go

    				return nil, fmt.Errorf("unexpected request")
    			}
    		}),
    	}
    	getFirstPodFunc = func(client corev1client.PodsGetter, namespace string, selector string, timeout time.Duration, sortBy func([]*corev1.Pod) sort.Interface) (
    		*corev1.Pod, int, error,
    	) {
    		return attachPod(namespace), 1, nil
    	}
    	for _, tt := range tests {
    		t.Run(strings.Split(tt.name, ".")[0], func(t *testing.T) {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jun 09 18:17:49 GMT 2023
    - 6.6K bytes
    - Viewed (0)
  7. istioctl/pkg/util/ambient/util.go

    	isZtunnel := strings.HasPrefix(podName, "ztunnel")
    	if client == nil {
    		return isZtunnel
    	}
    	pod, err := client.Kube().CoreV1().Pods(podNamespace).Get(context.Background(), podName, metav1.GetOptions{})
    	if err != nil {
    		return isZtunnel
    	}
    	if v, ok := pod.Labels["app"]; ok {
    		return v == "ztunnel"
    	}
    	return isZtunnel
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu May 02 21:29:40 GMT 2024
    - 1.7K bytes
    - Viewed (0)
  8. cni/pkg/iptables/iptables.go

    	// redetect for each pod anyway.
    	//
    	// Extreme corner case:
    	// If for some reason your host had both binaries, and you were injecting out-of-band
    	// iptables rules within a pod context into `legacy` tables, but your host context preferred
    	// `nft`, we would still inject our rules in-pod into nft tables, which is a bit wonky.
    	//
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue May 07 19:54:50 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  9. istioctl/pkg/clioptions/central.go

    		"XDS Endpoint certificate directory")
    	cmd.PersistentFlags().StringVar(&o.XdsPodLabel, "xds-label", "",
    		"Istiod pod label selector")
    	cmd.PersistentFlags().IntVar(&o.XdsPodPort, "xds-port", viper.GetInt("XDS-PORT"),
    		"Istiod pod port")
    	cmd.PersistentFlags().DurationVar(&o.Timeout, "timeout", time.Second*30,
    		"The duration to wait before failing")
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Jun 06 03:39:27 GMT 2022
    - 3.2K bytes
    - Viewed (0)
  10. istioctl/pkg/checkinject/checkinject_test.go

    )
    
    func Test_analyzeRunningWebhooks(t *testing.T) {
    	cases := []struct {
    		name             string
    		pod              *corev1.Pod
    		ns               *corev1.Namespace
    		expectedMessages []webhookAnalysis
    	}{
    		{
    			name: "no inj because of no match labels",
    			pod:  podTestObject("test1", "test1", "", ""),
    			ns:   nsTestObject("test1", "", ""),
    			expectedMessages: []webhookAnalysis{
    				{
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Jun 15 15:02:17 GMT 2023
    - 10.6K bytes
    - Viewed (0)
Back to top