Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for CoreV1 (0.08 sec)

  1. istioctl/pkg/injector/injector-list.go

    func getNamespaces(ctx context.Context, client kube.CLIClient, istioNamespace string) ([]corev1.Namespace, error) {
    	nsList, err := client.Kube().CoreV1().Namespaces().List(ctx, metav1.ListOptions{})
    	if err != nil {
    		return []corev1.Namespace{}, err
    	}
    	filtered := filterSystemNamespaces(nsList.Items, istioNamespace)
    	filtered = slices.Filter(filtered, func(namespace corev1.Namespace) bool {
    		return !ambient.InAmbient(&namespace)
    	})
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Oct 18 11:39:52 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/net_test.go

    				},
    			},
    		},
    		StartupProbe: &corev1.Probe{
    			ProbeHandler: corev1.ProbeHandler{
    				HTTPGet: &corev1.HTTPGetAction{
    					Port: intstr.FromInt(7777),
    				},
    			},
    		},
    	}
    
    	containers := []corev1.Container{app1}
    
    	var podStatus corev1.PodStatus
    	if v6IP {
    		podStatus = corev1.PodStatus{
    			PodIP:  "e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3164",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 25 16:13:38 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  3. istioctl/pkg/describe/describe_test.go

    							{
    								Name:       "http",
    								Port:       80,
    								TargetPort: intstr.FromInt32(80),
    								Protocol:   corev1.ProtocolTCP,
    							},
    						},
    					},
    					Status: corev1.ServiceStatus{
    						LoadBalancer: corev1.LoadBalancerStatus{Ingress: []corev1.LoadBalancerIngress{
    							{
    								IP: "2.2.2.2",
    							},
    						}},
    					},
    				},
    				&corev1.Service{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 20:04:20 UTC 2024
    - 30.8K bytes
    - Viewed (0)
  4. cni/pkg/repair/repair_test.go

    	makeDetectPod := func(name string, terminationMessage string, exitCode int) *corev1.Pod {
    		return makePod(makePodArgs{
    			PodName:     name,
    			Annotations: map[string]string{"sidecar.istio.io/status": "something"},
    			InitContainerStatus: &corev1.ContainerStatus{
    				Name: constants.ValidationContainerName,
    				State: corev1.ContainerState{
    					Waiting: &corev1.ContainerStateWaiting{
    						Reason:  "CrashLoopBackOff",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 24 03:31:28 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  5. cni/pkg/repair/repaircontroller.go

    		UID:             &pod.UID,
    		ResourceVersion: &pod.ResourceVersion,
    	}
    	err := c.client.Kube().CoreV1().Pods(pod.Namespace).Delete(context.Background(), pod.Name, metav1.DeleteOptions{
    		Preconditions: preconditions,
    	})
    	if err != nil {
    		c.events.Write(pod, corev1.EventTypeWarning, ReasonDeleteBrokenPod, "pod detected as broken, but failed to delete: %v", err)
    		m.With(resultLabel.Value(resultFail)).Increment()
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Feb 10 00:31:55 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/informers_test.go

    	defer cancel()
    
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    			Namespace: "test",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: NodeName,
    		},
    		Status: corev1.PodStatus{
    			PodIPs: []corev1.PodIP{
    				{
    					IP: "11.1.1.12",
    				},
    			},
    		},
    	}
    	ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "test"}}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  7. istioctl/pkg/checkinject/checkinject_test.go

    	admitv1 "k8s.io/api/admissionregistration/v1"
    	corev1 "k8s.io/api/core/v1"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"sigs.k8s.io/yaml"
    
    	"istio.io/api/annotation"
    	"istio.io/api/label"
    	"istio.io/istio/pkg/test/util/assert"
    )
    
    func Test_analyzeRunningWebhooks(t *testing.T) {
    	cases := []struct {
    		name             string
    		pod              *corev1.Pod
    		ns               *corev1.Namespace
    		expectedMessages []webhookAnalysis
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/server_test.go

    	fakeIPSetDeps.On("clearEntriesWithIP",
    		"foo-v4",
    		netip.MustParseAddr("6.6.6.6"),
    	).Return(nil)
    
    	err := m.syncHostIPSets([]*corev1.Pod{pod})
    	assert.NoError(t, err)
    	fakeIPSetDeps.AssertExpectations(t)
    }
    
    func podWithAnnotation() *corev1.Pod {
    	return &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    			Namespace: "test",
    			UID:       types.UID("test"),
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  9. cni/pkg/plugin/plugin_test.go

    		"eth0",
    		testSandboxDirectory,
    		"", // unused here
    		ambientEnabled,
    		"mock",
    	)
    }
    
    func buildFakePodAndNSForClient() (*corev1.Pod, *corev1.Namespace) {
    	proxy := corev1.Container{Name: "mockContainer"}
    	app := corev1.Container{Name: "foo-init"}
    	fakePod := &corev1.Pod{
    		TypeMeta: metav1.TypeMeta{
    			APIVersion: "core/v1",
    			Kind:       "Pod",
    		},
    		ObjectMeta: metav1.ObjectMeta{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/informers.go

    	GetPodIfAmbient(podName, podNamespace string) (*corev1.Pod, error)
    	GetActiveAmbientPodSnapshot() []*corev1.Pod
    	Start()
    }
    
    type InformerHandlers struct {
    	ctx             context.Context
    	dataplane       MeshDataplane
    	systemNamespace string
    
    	queue      controllers.Queue
    	pods       kclient.Client[*corev1.Pod]
    	namespaces kclient.Client[*corev1.Namespace]
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 11.7K bytes
    - Viewed (0)
Back to top