Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for forthy (0.4 sec)

  1. istioctl/pkg/kubeinject/kubeinject.go

    func GetFirstPod(client v1.CoreV1Interface, namespace string, selector string) (*corev1.Pod, error) {
    	options := metav1.ListOptions{LabelSelector: selector}
    
    	sortBy := func(pods []*corev1.Pod) sort.Interface { return sort.Reverse(podutils.ActivePods(pods)) }
    	podList, err := client.Pods(namespace).List(context.TODO(), options)
    	if err != nil {
    		return nil, err
    	}
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Mar 29 02:29:02 GMT 2024
    - 21.6K bytes
    - Viewed (0)
  2. cni/pkg/repair/repair_test.go

    			go c.Run(stop)
    			kube.WaitForCacheSync("test", stop, c.queue.HasSynced)
    
    			assert.EventuallyEqual(t, func() map[string]string {
    				havePods := c.pods.List(metav1.NamespaceAll, klabels.Everything())
    				slices.SortBy(havePods, func(a *corev1.Pod) string {
    					return a.Name
    				})
    				return makePodLabelMap(havePods)
    			}, tt.wantLabels)
    			if tt.wantCount > 0 {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Tue Oct 24 03:31:28 GMT 2023
    - 10.6K bytes
    - Viewed (0)
  3. istioctl/pkg/util/handlers/handlers.go

    	}
    	// We need to pass in a sorter, and the one used by `kubectl logs` is good enough.
    	sortBy := func(pods []*corev1.Pod) sort.Interface { return podutils.ByLogging(pods) }
    	timeout := 2 * time.Second
    	if getFirstPodFunc == nil {
    		getFirstPodFunc = polymorphichelpers.GetFirstPod
    	}
    	pod, _, err := getFirstPodFunc(client, namespace, selector, timeout, sortBy)
    	if err != nil {
    		return "", "", fmt.Errorf("no pods match %q", resname)
    	}
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Tue Feb 06 15:01:41 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  4. 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 Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Jun 09 18:17:49 GMT 2023
    - 6.6K bytes
    - Viewed (0)
  5. Makefile.core.mk

    # disable_pgv: disables protoc-gen-validation. This is not used buts adds many MB to Envoy protos
    # not set vtprotobuf: this adds some performance improvement, but at a binary cost increase that is not worth it for the agent
    AGENT_TAGS=agent,disable_pgv
    # disable_pgv: disables protoc-gen-validation. This is not used buts adds many MB to Envoy protos
    # vtprotobuf: enables optimized protobuf marshalling.
    Plain Text
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 19 19:41:41 GMT 2024
    - 22.5K bytes
    - Viewed (0)
  6. istioctl/pkg/ztunnelconfig/ztunnelconfig.go

    	}
    	pods := slices.Reference(podsr.Items)
    	if len(pods) > 0 {
    		// We need to pass in a sorter, and the one used by `kubectl logs` is good enough.
    		sortBy := func(pods []*corev1.Pod) sort.Interface { return podutils.ByLogging(pods) }
    		sort.Sort(sortBy(pods))
    		return config.NamespacedName(pods[0]), nil
    	}
    	return types.NamespacedName{}, fmt.Errorf("no pods found")
    }
    
    type commonFlags struct {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Mon Apr 22 15:39:28 GMT 2024
    - 22.2K bytes
    - Viewed (0)
Back to top