Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 465 for readOp (0.08 sec)

  1. src/bytes/buffer.go

    type readOp int8
    
    // Don't use iota for these, as the values need to correspond with the
    // names and comments, which is easier to see when being explicit.
    const (
    	opRead      readOp = -1 // Any other read operation.
    	opInvalid   readOp = 0  // Non-read operation.
    	opReadRune1 readOp = 1  // Read rune of size 1.
    	opReadRune2 readOp = 2  // Read rune of size 2.
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Jul 16 18:17:37 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  2. src/bytes/reader.go

    func (r *Reader) Read(b []byte) (n int, err error) {
    	if r.i >= int64(len(r.s)) {
    		return 0, io.EOF
    	}
    	r.prevRune = -1
    	n = copy(b, r.s[r.i:])
    	r.i += int64(n)
    	return
    }
    
    // ReadAt implements the [io.ReaderAt] interface.
    func (r *Reader) ReadAt(b []byte, off int64) (n int, err error) {
    	// cannot modify state - see io.ReaderAt
    	if off < 0 {
    		return 0, errors.New("bytes.Reader.ReadAt: negative offset")
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Jul 16 18:17:37 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  3. internal/bucket/bandwidth/reader.go

    }
    
    // MonitorReaderOptions provides configurable options for monitor reader implementation.
    type MonitorReaderOptions struct {
    	BucketOptions
    	HeaderSize int
    }
    
    // Read implements a throttled read
    func (r *MonitoredReader) Read(buf []byte) (n int, err error) {
    	if r.throttle == nil {
    		return r.r.Read(buf)
    	}
    	if r.lastErr != nil {
    		err = r.lastErr
    		return
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 12 14:57:31 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  4. src/archive/zip/reader.go

    // the [ErrInsecurePath] error and use the returned reader.
    func NewReader(r io.ReaderAt, size int64) (*Reader, error) {
    	if size < 0 {
    		return nil, errors.New("zip: size cannot be negative")
    	}
    	zr := new(Reader)
    	var err error
    	if err = zr.init(r, size); err != nil && err != ErrInsecurePath {
    		return nil, err
    	}
    	return zr, err
    }
    
    func (r *Reader) init(rdr io.ReaderAt, size int64) error {
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Sat Aug 03 01:05:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  5. internal/s3select/json/reader.go

    const maxDocumentSize = 10 << 20
    
    // Reader - JSON record reader for S3Select.
    type Reader struct {
    	args       *ReaderArgs
    	decoder    *jstream.Decoder
    	valueCh    chan *jstream.MetaValue
    	readCloser io.ReadCloser
    }
    
    // Read - reads single record.
    func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    	v, ok := <-r.valueCh
    	if !ok {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  6. internal/hash/reader.go

    )
    
    // A Reader wraps an io.Reader and computes the MD5 checksum
    // of the read content as ETag. Optionally, it also computes
    // the SHA256 checksum of the content.
    //
    // If the reference values for the ETag and content SHA26
    // are not empty then it will check whether the computed
    // match the reference values.
    type Reader struct {
    	src         io.Reader
    	bytesRead   int64
    	expectedMin int64
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  7. internal/s3select/parquet/reader.go

    	"github.com/minio/minio/internal/s3select/sql"
    )
    
    // Reader implements reading records from parquet input.
    type Reader struct {
    	io.Closer
    	r *parquetgo.FileReader
    }
    
    // NewParquetReader creates a Reader2 from a io.ReadSeekCloser.
    func NewParquetReader(rsc io.ReadSeekCloser, _ *ReaderArgs) (r *Reader, err error) {
    	fr, err := parquetgo.NewFileReader(rsc)
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  8. internal/ringbuffer/README.md

    Regular Reads will block until data is available, but not wait for a full buffer. 
    Writes will block until there is space available and writes bigger than the buffer will wait for reads to make space.
    
    `TryRead` and `TryWrite` are still available for non-blocking reads and writes.
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  9. docs/config/README.md

    By default, parity for objects with standard storage class is set to `N/2`, and parity for objects with reduced redundancy storage class objects is set to `2`. Read more about storage class support in MinIO server [here](https://github.com/minio/minio/blob/master/docs/erasure/storage-class/README.md).
    
    ```
    KEY:
    storage_class  define object level redundancy
    
    ARGS:
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  10. README.md

    <summary>About the command <code>fastapi dev main.py</code>...</summary>
    
    The command `fastapi dev` reads your `main.py` file, detects the **FastAPI** app in it, and starts a server using <a href="https://www.uvicorn.org" class="external-link" target="_blank">Uvicorn</a>.
    
    By default, `fastapi dev` will start with auto-reload enabled for local development.
    
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Sun Oct 20 19:20:23 UTC 2024
    - 23.4K bytes
    - Viewed (0)
Back to top