Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for up (0.12 sec)

  1. internal/s3select/csv/reader.go

    // Blocks will read this much and find the first following newline.
    // 128KB appears to be a very reasonable default.
    const csvSplitSize = 128 << 10
    
    // startReaders will read the header if needed and spin up a parser
    // and a number of workers based on GOMAXPROCS.
    // If an error is returned no goroutines have been started and r.err will have been set.
    func (r *Reader) startReaders(newReader func(io.Reader) *csv.Reader) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  2. internal/etag/reader.go

    			src:      r,
    			md5:      NewUUIDHash(forceMD5),
    			checksum: etag,
    		}
    	}
    	return &Reader{
    		src:      r,
    		md5:      md5.New(),
    		checksum: etag,
    	}
    }
    
    // Read reads up to len(p) bytes from the underlying
    // io.Reader as specified by the io.Reader interface.
    func (r *Reader) Read(p []byte) (int, error) {
    	n, err := r.src.Read(p)
    	r.readN += int64(n)
    	r.md5.Write(p[:n])
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 4.8K bytes
    - Viewed (0)
Back to top