Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 187 for reader_r (0.12 sec)

  1. cmd/batch-expire.go

    	r.line, r.col = val.Line, val.Column
    	return nil
    }
    
    // Notify notifies notification endpoint if configured regarding job failure or success.
    func (r BatchJobExpire) Notify(ctx context.Context, body io.Reader) error {
    	if r.NotificationCfg.Endpoint == "" {
    		return nil
    	}
    
    	ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
    	defer cancel()
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  2. api/go1.19.txt

    pkg encoding/binary, type AppendByteOrder interface, AppendUint64([]uint8, uint64) []uint8 #50601
    pkg encoding/binary, type AppendByteOrder interface, String() string #50601
    pkg encoding/csv, method (*Reader) InputOffset() int64 #43401
    pkg encoding/xml, method (*Decoder) InputPos() (int, int) #45628
    pkg flag, func TextVar(encoding.TextUnmarshaler, string, encoding.TextMarshaler, string) #45754
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Fri Dec 02 16:29:41 UTC 2022
    - 17.9K bytes
    - Viewed (0)
  3. doc/go1.17_spec.html

    <code>T</code>’s embedded interfaces.
    </p>
    
    <pre>
    type Reader interface {
    	Read(p []byte) (n int, err error)
    	Close() error
    }
    
    type Writer interface {
    	Write(p []byte) (n int, err error)
    	Close() error
    }
    
    // ReadWriter's methods are Read, Write, and Close.
    type ReadWriter interface {
    	Reader  // includes methods of Reader in ReadWriter's method set
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Thu Oct 10 18:25:45 UTC 2024
    - 211.6K bytes
    - Viewed (0)
  4. cmd/xl-storage.go

    			file.Close()
    			return nil, err
    		}
    	}
    	return &sendFileReader{Reader: io.LimitReader(file, length), Closer: file}, nil
    }
    
    // CreateFile - creates the file.
    func (s *xlStorage) CreateFile(ctx context.Context, origvolume, volume, path string, fileSize int64, r io.Reader) (err error) {
    	if origvolume != "" {
    		origvolumeDir, err := s.getVolDir(origvolume)
    		if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (2)
  5. cmd/background-newdisks-heal-ops_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *healingTracker) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 20 15:42:49 UTC 2024
    - 24.6K bytes
    - Viewed (0)
  6. src/bufio/bufio_test.go

    type bufReader struct {
    	name string
    	fn   func(*Reader) string
    }
    
    var bufreaders = []bufReader{
    	{"1", func(b *Reader) string { return reads(b, 1) }},
    	{"2", func(b *Reader) string { return reads(b, 2) }},
    	{"3", func(b *Reader) string { return reads(b, 3) }},
    	{"4", func(b *Reader) string { return reads(b, 4) }},
    	{"5", func(b *Reader) string { return reads(b, 5) }},
    	{"7", func(b *Reader) string { return reads(b, 7) }},
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Mon Oct 28 21:04:51 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  7. internal/s3select/csv/reader_contrib_test.go

    				CommentCharacter:           defaultCommentCharacter,
    				AllowQuotedRecordDelimiter: false,
    				unmarshaled:                true,
    			}
    			if !c.header {
    				args.FileHeaderInfo = none
    			}
    			inr := io.Reader(bytes.NewReader(input))
    			if c.sendErr != nil {
    				inr = io.MultiReader(inr, errReader{c.sendErr})
    			}
    			r, _ := NewReader(io.NopCloser(inr), &args)
    			fields := 0
    			for {
    				record, err = r.Read(record)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 38.5K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool.go

    // Errors are ignored, only errors from the callback are returned.
    // For now only direct file paths are supported.
    func (z *erasureServerPools) GetRawData(ctx context.Context, volume, file string, fn func(r io.Reader, host string, disk string, filename string, info StatInfo) error) error {
    	found := 0
    	for _, s := range z.serverPools {
    		for _, set := range s.sets {
    			for _, disk := range set.getDisks() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  9. api/go1.16.txt

    pkg html/template, func ParseFS(fs.FS, ...string) (*Template, error)
    pkg html/template, method (*Template) ParseFS(fs.FS, ...string) (*Template, error)
    pkg io, func NopCloser(Reader) ReadCloser
    pkg io, func ReadAll(Reader) ([]uint8, error)
    pkg io, type ReadSeekCloser interface { Close, Read, Seek }
    pkg io, type ReadSeekCloser interface, Close() error
    pkg io, type ReadSeekCloser interface, Read([]uint8) (int, error)
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Fri Dec 02 16:30:41 UTC 2022
    - 479.2K bytes
    - Viewed (0)
  10. cmd/xl-storage-format-v2.go

    	}
    }
    
    // readXLMetaNoData will load the metadata, but skip data segments.
    // This should only be used when data is never interesting.
    // If data is not xlv2, it is returned in full.
    func readXLMetaNoData(r io.Reader, size int64) ([]byte, error) {
    	initial := size
    	hasFull := true
    	if initial > metaDataReadDefault {
    		initial = metaDataReadDefault
    		hasFull = false
    	}
    
    	buf := metaDataPoolGet()[:initial]
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 64K bytes
    - Viewed (0)
Back to top