Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 401 for readFn (0.29 sec)

  1. 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])
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  2. internal/s3select/simdj/reader.go

    	return &Reader{
    		args:       args,
    		decoded:    ch,
    		err:        err,
    		readCloser: nil,
    	}
    }
    
    // safeCloser will wrap a Reader as a ReadCloser.
    // It is safe to call Close while the reader is being used.
    type safeCloser struct {
    	closed uint32
    	r      io.Reader
    }
    
    func (s *safeCloser) Read(p []byte) (n int, err error) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  3. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  4. docs/metrics/README.md

    - Liveness probe available at `/minio/health/live`
    - Cluster probe available at `/minio/health/cluster`
    
    Read more on how to use these endpoints in [MinIO healthcheck guide](https://github.com/minio/minio/blob/master/docs/metrics/healthcheck/README.md).
    
    ## Prometheus Probe
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Feb 29 18:35:20 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  5. internal/s3select/csv/reader.go

    func (r *Reader) startReaders(newReader func(io.Reader) *csv.Reader) error {
    	if r.args.FileHeaderInfo != none {
    		// Read column names
    		// Get one line.
    		b, err := r.nextSplit(0, nil)
    		if err != nil {
    			r.err = err
    			return err
    		}
    		if !utf8.Valid(b) {
    			return errInvalidTextEncodingError()
    		}
    		reader := newReader(bytes.NewReader(b))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  6. 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 n, err
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  7. README.md

    ### Translations
    
    - [日本語 (Japanese)](docs/ja/README.md)
    - [简体中文 (Simplified Chinese)](docs/zh-CN/README.md)
    - [Español (Spanish)](docs/es/README.md)
    - [Português (Brazilian Portuguese)](docs/pt-BR/README.md)
    - [Français (French)](docs/fr/README.md)
    - [Deutsch (German)](docs/de/README.md)
    - [한국어 (Korean)](docs/ko/README.md)
    
    ## Powered By
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Dec 20 00:28:33 UTC 2025
    - 7.8K bytes
    - Viewed (2)
  8. docs/fr/README.md

    ### Traductions
    
    - [English](../../README.md)
    - [日本語 (Japanese)](../ja/README.md)
    - [简体中文 (Simplified Chinese)](../zh-CN/README.md)
    - [Español (Spanish)](../es/README.md)
    - [Português (Brazilian Portuguese)](../pt-BR/README.md)
    - [Deutsch (German)](../de/README.md)
    - [한국어 (Korean)](../ko/README.md)
    
    ## Alimenté par
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Tue Nov 11 22:42:32 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  9. docs/pt-BR/README.md

    Aceitamos pull requests para o seu idioma.
    
    ### Traduções
    
    - [English](../../README.md)
    - [日本語 (Japanese)](../ja/README.md)
    - [简体中文 (Simplified Chinese)](../zh-CN/README.md)
    - [Español (Spanish)](../es/README.md)
    - [Français (French)](../fr/README.md)
    - [Deutsch (German)](../de/README.md)
    - [한국어 (Korean)](../ko/README.md)
    
    ## Desenvolvido por
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Tue Nov 11 22:42:32 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  10. docs/metrics/prometheus/README.md

    ```
    
    ### 3. Configuring Prometheus
    
    #### 3.1 Authenticated Prometheus config
    
    > If MinIO is configured to expose metrics without authentication, you don't need to use `mc` to generate prometheus config. You can skip reading further and move to 3.2 section.
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 7.1K bytes
    - Viewed (0)
Back to top