Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 70 for Buffer (0.19 sec)

  1. cni/pkg/util/executil.go

    	return &ExecList{
    		Cmd:  cmd,
    		Args: args,
    	}
    }
    
    func ExecuteOutput(cmd string, args ...string) (string, error) {
    	externalCommand := exec.Command(cmd, args...)
    	stdout := &bytes.Buffer{}
    	stderr := &bytes.Buffer{}
    	externalCommand.Stdout = stdout
    	externalCommand.Stderr = stderr
    
    	err := externalCommand.Run()
    
    	if err != nil || len(stderr.Bytes()) != 0 {
    		return stderr.String(), err
    	}
    
    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. istioctl/pkg/writer/envoy/configdump/configdump_test.go

    		},
    		{
    			name:    "errors if config dump is not primed",
    			wantErr: true,
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			gotOut := &bytes.Buffer{}
    			cw := &ConfigWriter{Stdout: gotOut}
    			cd, _ := os.ReadFile("testdata/configdump.json")
    			if tt.callPrime {
    				cw.Prime(cd)
    			}
    			err := cw.PrintBootstrapDump("json")
    			if tt.wantOutputFile != "" {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Jan 03 23:08:06 GMT 2024
    - 3.5K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/pilot/status_test.go

    	tests := []struct {
    		name    string
    		input   map[string]*discovery.DiscoveryResponse
    		want    string
    		wantErr bool
    	}{
    		{
    			name: "prints multiple istiod inputs to buffer in alphabetical order by pod name",
    			input: map[string]*discovery.DiscoveryResponse{
    				"istiod1": xdsResponseInput("istiod1", []clientConfigInput{
    					{
    						proxyID:        "proxy1",
    						clusterID:      "cluster1",
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 08 08:38:19 GMT 2024
    - 6.5K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/compare/cluster.go

    	"istio.io/istio/pkg/util/protomarshal"
    )
    
    // ClusterDiff prints a diff between Istiod and Envoy clusters to the passed writer
    func (c *Comparator) ClusterDiff() error {
    	envoyBytes, istiodBytes := &bytes.Buffer{}, &bytes.Buffer{}
    	envoyClusterDump, err := c.envoy.GetDynamicClusterDump(true)
    	if err != nil {
    		envoyBytes.WriteString(err.Error())
    	} else {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Mar 12 10:02:09 GMT 2024
    - 1.9K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/compare/listener.go

    	"istio.io/istio/pkg/util/protomarshal"
    )
    
    // ListenerDiff prints a diff between Istiod and Envoy listeners to the passed writer
    func (c *Comparator) ListenerDiff() error {
    	envoyBytes, istiodBytes := &bytes.Buffer{}, &bytes.Buffer{}
    	envoyListenerDump, err := c.envoy.GetDynamicListenerDump(true)
    	if err != nil {
    		envoyBytes.WriteString(err.Error())
    	} else {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 04 20:29:08 GMT 2024
    - 2K bytes
    - Viewed (0)
  6. istioctl/pkg/util/testutil/util.go

    	WantException bool
    }
    
    func VerifyOutput(t *testing.T, cmd *cobra.Command, c TestCase) {
    	t.Helper()
    
    	cmd.SetArgs(c.Args)
    
    	var out bytes.Buffer
    	cmd.SetOut(&out)
    	cmd.SetErr(&out)
    	cmd.SilenceUsage = true
    
    	fErr := cmd.Execute()
    	output := out.String()
    
    	if c.ExpectedOutput != "" && c.ExpectedOutput != output {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Jun 15 15:02:17 GMT 2023
    - 2K bytes
    - Viewed (0)
  7. istioctl/pkg/authz/analyzer_test.go

    					},
    					LastUpdated: timestamppb.Now(),
    				},
    				ClientStatus: 453,
    			},
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			var buf bytes.Buffer
    			a.Print(&buf)
    			expectedOutput := "ACTION   AuthorizationPolicy   RULES\n"
    			actualOutput := buf.String()
    			if !reflect.DeepEqual(expectedOutput, actualOutput) {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  8. istioctl/pkg/writer/ztunnel/configdump/configdump_test.go

    			configNamespace:    "default",
    			wantOutputWorkload: "testdata/workloadsummary_default.txt",
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			gotOut := &bytes.Buffer{}
    			cw := &ConfigWriter{Stdout: gotOut}
    			cd, _ := os.ReadFile("testdata/dump.json")
    			if tt.callPrime {
    				cw.Prime(cd)
    			}
    			if tt.wantOutputSecret != "" {
    				err := cw.PrintSecretSummary()
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Feb 02 18:21:48 GMT 2024
    - 3.6K bytes
    - Viewed (0)
  9. istioctl/pkg/writer/envoy/configdump/route_test.go

    		},
    		{
    			name: "istio-gateway-http-route-prefix",
    		},
    		{
    			name: "k8s-gateway-http-route-path-prefix",
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			gotOut := &bytes.Buffer{}
    			cw := &ConfigWriter{Stdout: gotOut}
    			cd, _ := os.ReadFile(fmt.Sprintf("testdata/routes/%s/configdump.json", tt.name))
    			if err := cw.Prime(cd); err != nil {
    				t.Errorf("failed to parse config dump: %s", err)
    			}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 12:37:14 GMT 2023
    - 2.8K bytes
    - Viewed (0)
  10. istioctl/pkg/tag/tag_test.go

    					},
    				},
    			},
    			outputMatches: []string{"test", "revision", "dependent"},
    			error:         "",
    		},
    	}
    
    	for _, tc := range tcs {
    		t.Run(tc.name, func(t *testing.T) {
    			var out bytes.Buffer
    			client := fake.NewSimpleClientset(tc.webhooks.DeepCopyObject(), tc.namespaces.DeepCopyObject())
    			outputFormat = util.JSONFormat
    			err := listTags(context.Background(), client, &out)
    			if tc.error == "" && err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Nov 17 22:41:06 GMT 2023
    - 8.7K bytes
    - Viewed (0)
Back to top