Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 577 for renamer (0.05 sec)

  1. internal/bucket/bandwidth/reader.go

    // NewMonitoredReader returns reference to a monitored reader that throttles reads to configured bandwidth for the
    // bucket.
    func NewMonitoredReader(ctx context.Context, m *Monitor, r io.Reader, opts *MonitorReaderOptions) *MonitoredReader {
    	reader := MonitoredReader{
    		r:        r,
    		throttle: m.throttle(opts.BucketOptions),
    		m:        m,
    		opts:     opts,
    		ctx:      ctx,
    	}
    	reader.m.init(opts.BucketOptions)
    	return &reader
    Registered: 2024-11-03 19:28
    - Last Modified: 2024-07-12 14:57
    - 3.2K bytes
    - Viewed (0)
  2. 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: 2024-11-03 19:28
    - Last Modified: 2024-09-23 19:35
    - 3.2K bytes
    - Viewed (0)
  3. internal/s3select/csv/reader.go

    	"runtime"
    	"sync"
    	"unicode/utf8"
    
    	csv "github.com/minio/csvparser"
    	"github.com/minio/minio/internal/s3select/sql"
    )
    
    // Reader - CSV record reader for S3Select.
    type Reader struct {
    	args         *ReaderArgs
    	readCloser   io.ReadCloser    // raw input
    	buf          *bufio.Reader    // input to the splitter
    	columnNames  []string         // names of columns
    	nameIndexMap map[string]int64 // name to column index
    Registered: 2024-11-03 19:28
    - Last Modified: 2024-02-22 06:26
    - 8.9K 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: 2024-11-05 11:13
    - Last Modified: 2024-08-03 01:05
    - 28.1K bytes
    - Viewed (0)
  5. src/test/java/jcifs/tests/FileOperationsTest.java

                f.createNewFile();
                boolean renamed = false;
                try {
                    f.renameTo(f2);
                    try {
                        assertTrue(f2.exists());
                        renamed = true;
                    }
                    finally {
                        f2.delete();
                    }
                }
                finally {
                    if ( !renamed && f.exists() ) {
                        f.delete();
    Registered: 2024-11-03 00:10
    - Last Modified: 2023-01-05 13:17
    - 16.3K bytes
    - Viewed (0)
  6. src/archive/tar/reader.go

    	"strconv"
    	"strings"
    	"time"
    )
    
    // Reader provides sequential access to the contents of a tar archive.
    // Reader.Next advances to the next file in the archive (including the first),
    // and then Reader can be treated as an io.Reader to access the file's data.
    type Reader struct {
    	r    io.Reader
    	pad  int64      // Amount of padding (ignored) after current file entry
    	curr fileReader // Reader for current file entry
    Registered: 2024-11-05 11:13
    - Last Modified: 2024-03-08 01:59
    - 26.8K bytes
    - Viewed (0)
  7. docs/en/docs/img/sponsors/render.svg

    render.svg...
    Registered: 2024-11-03 07:19
    - Last Modified: 2024-10-31 09:13
    - 12.5K bytes
    - Viewed (0)
  8. src/bytes/reader.go

    import (
    	"errors"
    	"io"
    	"unicode/utf8"
    )
    
    // A Reader implements the [io.Reader], [io.ReaderAt], [io.WriterTo], [io.Seeker],
    // [io.ByteScanner], and [io.RuneScanner] interfaces by reading from
    // a byte slice.
    // Unlike a [Buffer], a Reader is read-only and supports seeking.
    // The zero value for Reader operates like a Reader of an empty slice.
    type Reader struct {
    	s        []byte
    	i        int64 // current reading index
    Registered: 2024-11-05 11:13
    - Last Modified: 2024-07-16 18:17
    - 3.9K bytes
    - Viewed (0)
  9. internal/etag/reader.go

    //
    //	// Now, we need an io.Reader that can access
    //	// the ETag computed over the content.
    //	reader := etag.Wrap(encryptedContent, content)
    func Wrap(wrapped, content io.Reader) io.Reader {
    	if t, ok := content.(Tagger); ok {
    		return wrapReader{
    			Reader: wrapped,
    			Tagger: t,
    		}
    	}
    	return wrapReader{
    		Reader: wrapped,
    	}
    }
    
    // A Reader wraps an io.Reader and computes the
    Registered: 2024-11-03 19:28
    - Last Modified: 2024-01-18 07:03
    - 4.8K bytes
    - Viewed (0)
  10. 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: 2024-11-03 19:28
    - Last Modified: 2024-09-19 12:59
    - 10.9K bytes
    - Viewed (0)
Back to top