Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for read_all (0.22 sec)

  1. cni/pkg/log/uds_test.go

    	_ = log.Sync()
    
    	// Restore os stdout.
    	os.Stdout = stdout
    	assert.NoError(t, log.Configure(loggingOptions))
    
    	assert.NoError(t, w.Close())
    	out, err := io.ReadAll(r)
    	assert.NoError(t, err)
    
    	// For each level, there should be two lines, one from direct log,
    	// the other one from UDS server
    	wantLevels := []string{"debug", "info", "warn", "error", "debug", "info", "warn", "error"}
    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)
  2. istioctl/pkg/proxystatus/proxystatus.go

    		if err != nil {
    			return nil, err
    		}
    	}
    	defer func() {
    		if err := file.Close(); err != nil {
    			log.Errorf("failed to close %s: %s", filename, err)
    		}
    	}()
    	data, err := io.ReadAll(file)
    	if err != nil {
    		return nil, err
    	}
    	return data, nil
    }
    
    func StableXdsStatusCommand(ctx cli.Context) *cobra.Command {
    	cmd := XdsStatusCommand(ctx)
    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)
  3. istioctl/pkg/kubeinject/kubeinject.go

    	if err != nil {
    		return nil, err
    	}
    	resp, err := client.Post(address, "application/json", bytes.NewBuffer(revBytes))
    	if err != nil {
    		return nil, err
    	}
    	defer resp.Body.Close()
    	body, err := io.ReadAll(resp.Body)
    	if err != nil {
    		return nil, err
    	}
    	var obj runtime.Object
    	var ar *kube.AdmissionReview
    	out, _, err := deserializer.Decode(body, nil, obj)
    	if err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 29 02:29:02 GMT 2024
    - 21.6K bytes
    - Viewed (0)
  4. istioctl/pkg/proxyconfig/proxyconfig.go

    		if err != nil {
    			return nil, err
    		}
    	}
    	defer func() {
    		if err := file.Close(); err != nil {
    			log.Errorf("failed to close %s: %s", filename, err)
    		}
    	}()
    	return io.ReadAll(file)
    }
    
    func setupFileConfigdumpWriter(filename string, out io.Writer) (*configdump.ConfigWriter, error) {
    	data, err := readFile(filename)
    	if err != nil {
    		return nil, err
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 16 03:28:36 GMT 2024
    - 48K bytes
    - Viewed (0)
  5. istioctl/pkg/authz/authz.go

    	if err != nil {
    		return nil, err
    	}
    	defer func() {
    		if err := file.Close(); err != nil {
    			log.Errorf("failed to close %s: %s", filename, err)
    		}
    	}()
    	data, err := io.ReadAll(file)
    	if err != nil {
    		return nil, err
    	}
    
    	envoyConfig := &configdump.Wrapper{}
    	if err := envoyConfig.UnmarshalJSON(data); err != nil {
    		return nil, fmt.Errorf("failed to unmarshal proxy config: %s", err)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 5K bytes
    - Viewed (0)
  6. istioctl/pkg/ztunnelconfig/ztunnelconfig.go

    		if err != nil {
    			return nil, err
    		}
    	}
    	defer func() {
    		if err := file.Close(); err != nil {
    			log.Errorf("failed to close %s: %s", filename, err)
    		}
    	}()
    	return io.ReadAll(file)
    }
    
    func extractZtunnelConfigDump(kubeClient kube.CLIClient, podName, podNamespace string) ([]byte, error) {
    	path := "config_dump"
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 01 13:11:40 GMT 2024
    - 22.2K bytes
    - Viewed (0)
Back to top