Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 87 for todo (0.14 sec)

  1. istioctl/pkg/writer/ztunnel/configdump/configdump.go

    func (c *ConfigWriter) PrintVersionSummary() error {
    	// TODO
    	return nil
    }
    
    // PrintPodRootCAFromDynamicSecretDump prints just pod's root ca from dynamic secret config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintPodRootCAFromDynamicSecretDump() (string, error) {
    	// TODO
    	return "", nil
    }
    
    func (c *ConfigWriter) tabwriter() *tabwriter.Writer {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  2. istioctl/pkg/checkinject/checkinject.go

    				if err != nil {
    					return err
    				}
    				pod, err := kubeClient.Kube().CoreV1().Pods(podNs).Get(context.TODO(), podName, metav1.GetOptions{})
    				if err != nil {
    					return err
    				}
    				ns, err := kubeClient.Kube().CoreV1().Namespaces().Get(context.TODO(), podNs, metav1.GetOptions{})
    				if err != nil {
    					return err
    				}
    				podLabels = pod.GetLabels()
    				nsLabels = ns.GetLabels()
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  3. istioctl/pkg/multixds/gather.go

    	labelSelector := centralOpts.XdsPodLabel
    	if labelSelector == "" {
    		labelSelector = "app=istiod"
    	}
    	pods, err := kubeClient.GetIstioPods(context.TODO(), istioNamespace, metav1.ListOptions{
    		LabelSelector: labelSelector,
    		FieldSelector: kube.RunningStatus,
    	})
    	if err != nil {
    		return nil, err
    	}
    	if len(pods) == 0 {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 08 08:38:19 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  4. istioctl/pkg/dashboard/dashboard.go

    			}
    
    			if err != nil {
    				return fmt.Errorf("failed to create k8s client: %v", err)
    			}
    
    			var podName, ns string
    			if labelSelector != "" {
    				pl, err := kubeClient.PodsForSelector(context.TODO(), ctx.NamespaceOrDefault(ctx.Namespace()), labelSelector)
    				if err != nil {
    					return fmt.Errorf("not able to locate pod with selector %s: %v", labelSelector, err)
    				}
    
    				if len(pl.Items) < 1 {
    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)
  5. cmd/format-erasure.go

    	defer disk.Delete(context.TODO(), minioMetaBucket, tmpFormat, DeleteOptions{
    		Recursive: false,
    		Immediate: false,
    	})
    
    	// write to unique file.
    	if err = disk.WriteAll(context.TODO(), minioMetaBucket, tmpFormat, formatData); err != nil {
    		return err
    	}
    
    	// Rename file `uuid.json` --> `format.json`.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  6. istioctl/pkg/proxystatus/proxystatus.go

    				}
    				var envoyDump []byte
    				if configDumpFile != "" {
    					envoyDump, err = readConfigFile(configDumpFile)
    				} else {
    					path := "config_dump"
    					envoyDump, err = kubeClient.EnvoyDo(context.TODO(), podName, ns, "GET", path)
    				}
    				if err != nil {
    					return fmt.Errorf("could not contact sidecar: %w", err)
    				}
    
    				xdsRequest := discovery.DiscoveryRequest{
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  7. src/archive/tar/stat_unix.go

    			major := uint32((dev & 0x0000ff00) >> 8)
    			minor := uint32((dev & 0x000000ff) >> 0)
    			minor |= uint32((dev & 0xffff0000) >> 8)
    			h.Devmajor, h.Devminor = int64(major), int64(minor)
    		default:
    			// TODO: Implement solaris (see https://golang.org/issue/8106)
    		}
    	}
    	return nil
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Mar 15 16:01:50 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  8. istioctl/pkg/workload/workload.go

    	"istio.io/istio/pkg/kube/labels"
    	"istio.io/istio/pkg/log"
    	netutil "istio.io/istio/pkg/util/net"
    	"istio.io/istio/pkg/util/protomarshal"
    	"istio.io/istio/pkg/util/shellescape"
    )
    
    var (
    	// TODO refactor away from package vars and add more UTs
    	tokenDuration  int64
    	name           string
    	serviceAccount string
    	filename       string
    	outputDir      string
    	clusterID      string
    	ingressIP      string
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Apr 17 20:06:41 GMT 2024
    - 25.5K bytes
    - Viewed (0)
  9. cmd/data-scanner_test.go

    	versioned := vcfg.Status == "Enabled"
    	wants := make([]ObjectInfo, 2)
    	for i, fi := range fivs[:2] {
    		wants[i] = fi.ToObjectInfo(bucket, obj, versioned)
    	}
    	gots, err := item.applyNewerNoncurrentVersionLimit(context.TODO(), objAPI, fivs, es)
    	if err != nil {
    		t.Fatalf("Failed with err: %v", err)
    	}
    	if len(gots) != len(wants) {
    		t.Fatalf("Expected %d objects but got %d", len(wants), len(gots))
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/informers_test.go

    		},
    		Spec: corev1.PodSpec{
    			NodeName: NodeName,
    		},
    		Status: corev1.PodStatus{
    			PodIP: "11.1.1.12",
    		},
    	}
    	ns := &corev1.Namespace{
    		ObjectMeta: metav1.ObjectMeta{Name: "test"},
    		// TODO: once we if the add pod bug, re-enable this and remove the patch below
    		//		Labels: map[string]string{constants.DataplaneModeLabel: constants.DataplaneModeAmbient},
    
    	}
    
    	client := kube.NewFakeClient(ns, pod)
    
    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)
Back to top