Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for read_all (0.2 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/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)
  4. cni/pkg/plugin/cnieventclient_test.go

    	testServer := httptest.NewServer(http.HandlerFunc(func(res http.ResponseWriter, req *http.Request) {
    		defer req.Body.Close()
    		data, err := io.ReadAll(req.Body)
    		assert.NoError(t, err)
    
    		var msg nodeagent.CNIPluginAddEvent
    		err = json.Unmarshal(data, &msg)
    		assert.NoError(t, err)
    		assert.Equal(t, msg.PodName, testPod)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/cni-watcher.go

    	if req.Body == nil {
    		log.Error("empty request body")
    		http.Error(w, "empty request body", http.StatusBadRequest)
    		return
    	}
    	defer req.Body.Close()
    	data, err := io.ReadAll(req.Body)
    	if err != nil {
    		log.Errorf("Failed to read event report from cni plugin: %v", err)
    		http.Error(w, err.Error(), http.StatusInternalServerError)
    		return
    	}
    	msg, err := processAddEvent(data)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 18:52:24 GMT 2024
    - 6.1K bytes
    - Viewed (0)
Back to top