Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 197 for if (0.13 sec)

  1. cni/pkg/util/executil.go

    	stdout := &bytes.Buffer{}
    	stderr := &bytes.Buffer{}
    	externalCommand.Stdout = stdout
    	externalCommand.Stderr = stderr
    
    	err := externalCommand.Run()
    
    	if len(stdout.String()) != 0 {
    		log.Debugf("Command output: \n%v", stdout.String())
    	}
    
    	if err != nil || len(stderr.Bytes()) != 0 {
    		log.Debugf("Command error output: \n%v", stderr.String())
    		return errors.New(stderr.String())
    	}
    
    	return nil
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/podcgroupns_test.go

    	}}
    	podUIDNetns, err := n.FindNetnsForPods(map[types.UID]*corev1.Pod{
    		pod.UID: pod,
    	})
    	if err != nil {
    		panic(err)
    	}
    	defer podUIDNetns.Close()
    
    	if len(podUIDNetns) == 0 {
    		t.Fatal("expected to find pod netns")
    	}
    
    	expectedUID := "863b91d4-4b68-4efa-917f-4b560e3e86aa"
    	if podUIDNetns[expectedUID] == (WorkloadInfo{}) {
    		t.Fatal("expected to find pod netns under pod uid")
    	}
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  3. cni/pkg/log/uds_test.go

    	gotLogs := strings.Split(
    		strings.TrimSuffix(string(out), "\n"), "\n")
    	if want, got := len(wantLevels), len(gotLogs); want != got {
    		t.Fatalf("Number of logs want %v, got %v logs: %v", want, got, gotLogs)
    	}
    
    	for i, l := range gotLogs {
    		// For each line, there should be two level string, e.g.
    		// "2021-07-09T03:26:08.984951Z	debug	debug log"
    		if got, want := strings.Count(l, wantLevels[i]), 2; want != got {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Mar 16 00:20:01 GMT 2024
    - 2.5K bytes
    - Viewed (0)
  4. istioctl/pkg/clioptions/central.go

    }
    
    // ValidateControlPlaneFlags checks arguments for valid values and combinations
    func (o *CentralControlPlaneOptions) ValidateControlPlaneFlags() error {
    	if o.Xds != "" && o.XdsPodLabel != "" {
    		return fmt.Errorf("either --xds-address or --xds-label, not both")
    	}
    	if o.Plaintext && o.CertDir != "" {
    		return fmt.Errorf("either --plaintext or --cert-dir, not both")
    	}
    	return nil
    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)
  5. istioctl/cmd/istioctl/main.go

    	"istio.io/istio/istioctl/cmd"
    	"istio.io/istio/pkg/log"
    )
    
    func main() {
    	if err := cmd.ConfigAndEnvProcessing(); err != nil {
    		fmt.Fprintf(os.Stderr, "Could not initialize: %v\n", err)
    		exitCode := cmd.GetExitCode(err)
    		os.Exit(exitCode)
    	}
    
    	rootCmd := cmd.GetRootCmd(os.Args[1:])
    
    	log.EnableKlogWithCobra()
    
    	if err := rootCmd.Execute(); err != nil {
    		exitCode := cmd.GetExitCode(err)
    		os.Exit(exitCode)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue May 23 17:08:31 GMT 2023
    - 1.1K bytes
    - Viewed (0)
  6. istioctl/cmd/options.go

    		// (Currently the only global options we show are help options)
    		rootCmd.PersistentFlags().VisitAll(func(flag *pflag.Flag) {
    			if _, ok := helpFlags[flag.Name]; ok {
    				// Currently every flag.Shorthand is "", so there is no point in showing shorthands
    				shorthand := "   "
    				if flag.Shorthand != "" {
    					shorthand = "-" + flag.Shorthand + ","
    				}
    				c.Printf("  %s --%s: %s\n", shorthand, flag.Name, flag.Usage)
    			}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Jun 15 15:02:17 GMT 2023
    - 1.8K bytes
    - Viewed (0)
  7. cni/pkg/plugin/sidecar_iptables_linux.go

    	cfg.RedirectDNS = rdrct.dnsRedirect
    	cfg.CaptureAllDNS = rdrct.dnsRedirect
    	cfg.DropInvalid = rdrct.invalidDrop
    	cfg.DualStack = rdrct.dualStack
    	if err := cfg.FillConfigFromEnvironment(); err != nil {
    		return err
    	}
    
    	netNs, err := getNs(netns)
    	if err != nil {
    		err = fmt.Errorf("failed to open netns %q: %s", netns, err)
    		return err
    	}
    	defer netNs.Close()
    
    	return netNs.Do(func(_ ns.NetNS) error {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 18 17:36:41 GMT 2024
    - 2.5K bytes
    - Viewed (0)
  8. istioctl/pkg/util/handlers/handlers_test.go

    			wantNamespace: "istio-system",
    		},
    	}
    	for _, tt := range tests {
    		t.Run(strings.Split(tt.proxyName, ".")[0], func(t *testing.T) {
    			gotPodName, gotNamespace := InferPodInfo(tt.proxyName, tt.namespace)
    			if gotPodName != tt.wantPodName || gotNamespace != tt.wantNamespace {
    				t.Errorf("unexpected podName and namespace: wanted %v %v got %v %v", tt.wantPodName, tt.wantNamespace, gotPodName, gotNamespace)
    			}
    		})
    	}
    }
    
    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)
  9. istioctl/pkg/util/configdump/wrapper.go

    	*protoregistry.Types
    }
    
    var nonStrictResolver = &resolver{protoregistry.GlobalTypes}
    
    func (r *resolver) FindMessageByURL(url string) (protoreflect.MessageType, error) {
    	typ, err := r.Types.FindMessageByURL(url)
    	if err != nil {
    		// Here we ignore the error since we want istioctl to ignore unknown types due to the Envoy version change
    		msg := exprpb.Type{TypeKind: &exprpb.Type_Dyn{Dyn: &emptypb.Empty{}}}
    		return msg.ProtoReflect().Type(), nil
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  10. istioctl/pkg/completion/completion.go

    	client, err := ctx.CLIClient()
    	if err != nil {
    		return nil, err
    	}
    	ns := ctx.NamespaceOrDefault(ctx.Namespace())
    	podList, err := client.Kube().CoreV1().Pods(ns).List(context.Background(), metav1.ListOptions{})
    	if err != nil {
    		return nil, err
    	}
    
    	var podsName []string
    	for _, pod := range podList.Items {
    		if toComplete == "" || strings.HasPrefix(pod.Name, toComplete) {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 4.9K bytes
    - Viewed (0)
Back to top