Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ReadAll (0.05 sec)

  1. istioctl/pkg/writer/envoy/configdump/secret_test.go

    			defer configDumpFile.Close()
    			configDump, err := io.ReadAll(configDumpFile)
    			if err != nil {
    				t.Errorf("error reading test data file: %v", err)
    			}
    
    			outFile, err := os.Open(fmt.Sprintf("testdata/secret/%s/output", tc.sds))
    			if err != nil {
    				t.Errorf("error opening test data output file: %v", err)
    			}
    			defer outFile.Close()
    			expectedOut, err := io.ReadAll(outFile)
    			if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 28 19:52:53 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  2. cmd/xl-storage-disk-id-check.go

    		return p.storage.ReadVersion(ctx, origvolume, volume, path, versionID, opts)
    	})
    }
    
    func (p *xlStorageDiskIDCheck) ReadAll(ctx context.Context, volume string, path string) (buf []byte, err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricReadAll, volume, path)
    	if err != nil {
    		return nil, err
    	}
    	var sz int
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  3. cmd/xl-storage.go

    		buf = make([]byte, sz)
    	}
    
    	// Read file...
    	_, err = io.ReadFull(f, buf)
    
    	return buf, stat.ModTime().UTC(), osErrToFileErr(err)
    }
    
    // ReadAll is a raw call, reads content at any path and returns the buffer.
    func (s *xlStorage) ReadAll(ctx context.Context, volume string, path string) (buf []byte, err error) {
    	// Specific optimization to avoid re-read from the drives for `format.json`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  4. src/bufio/bufio_test.go

    		})
    	}
    }
    
    func TestReaderReset(t *testing.T) {
    	checkAll := func(r *Reader, want string) {
    		t.Helper()
    		all, err := io.ReadAll(r)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if string(all) != want {
    			t.Errorf("ReadAll returned %q, want %q", all, want)
    		}
    	}
    
    	r := NewReader(strings.NewReader("foo foo"))
    	buf := make([]byte, 3)
    	r.Read(buf)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  5. cmd/background-newdisks-heal-ops.go

    	if disk == nil {
    		return nil, errors.New("loadHealingTracker: nil drive given")
    	}
    	diskID, err := disk.GetDiskID()
    	if err != nil {
    		return nil, err
    	}
    	b, err := disk.ReadAll(ctx, minioMetaBucket,
    		pathJoin(bucketMetaPrefix, healingTrackerFilename))
    	if err != nil {
    		return nil, err
    	}
    	var h healingTracker
    	_, err = h.UnmarshalMsg(b)
    	if err != nil {
    		return nil, err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  6. 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
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 15:53:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
Back to top