- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 791 for readArg (0.13 sec)
-
src/internal/trace/raw/textreader.go
} spec := r.specs[ev] args, err := readArgs(line, spec.Args) if err != nil { return Event{}, fmt.Errorf("reading args for %s: %v", evStr, err) } if spec.IsStack { len := int(args[1]) for i := 0; i < len; i++ { line, err := r.nextLine() if err == io.EOF { return Event{}, fmt.Errorf("unexpected EOF while reading stack: args=%v", args) } if err != nil { return Event{}, err
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 4.9K bytes - Viewed (0) -
src/internal/trace/raw/reader.go
"fmt" "io" "internal/trace/event" "internal/trace/version" ) // Reader parses trace bytes with only very basic validation // into an event stream. type Reader struct { r *bufio.Reader v version.Version specs []event.Spec } // NewReader creates a new reader for the trace wire format. func NewReader(r io.Reader) (*Reader, error) { br := bufio.NewReader(r) v, err := version.ReadHeader(br)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.2K bytes - Viewed (0) -
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: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 8.9K bytes - Viewed (0) -
src/strings/reader.go
import ( "errors" "io" "unicode/utf8" ) // A Reader implements the [io.Reader], [io.ReaderAt], [io.ByteReader], [io.ByteScanner], // [io.RuneReader], [io.RuneScanner], [io.Seeker], and [io.WriterTo] interfaces by reading // from a string. // The zero value for Reader operates like a Reader of an empty string. type Reader struct { s string i int64 // current reading index prevRune int // index of previous rune; or < 0 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 17:10:31 UTC 2023 - 3.9K bytes - Viewed (0) -
src/compress/zlib/reader.go
} // Calling Close does not close the wrapped [io.Reader] originally passed to [NewReader]. // In order for the ZLIB checksum to be verified, the reader must be // fully consumed until the [io.EOF]. func (z *reader) Close() error { if z.err != nil && z.err != io.EOF { return z.err } z.err = z.decompressor.Close() return z.err } func (z *reader) Reset(r io.Reader, dict []byte) error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 23:20:03 UTC 2023 - 4.7K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
} r.readerWg.Done() } // We cannot reuse as we are sending parsed objects elsewhere. simdjson.ParseNDStream(readCloser, r.input, nil) r.readerWg.Add(1) go r.startReader() return &r } // NewElementReader - creates new JSON reader using readCloser. func NewElementReader(ch chan simdjson.Object, err *error, args *json.ReaderArgs) *Reader { return &Reader{ args: args,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 30 17:02:22 UTC 2023 - 4.9K bytes - Viewed (0) -
src/compress/lzw/reader.go
// is a *[Reader]. func NewReader(r io.Reader, order Order, litWidth int) io.ReadCloser { return newReader(r, order, litWidth) } func newReader(src io.Reader, order Order, litWidth int) *Reader { r := new(Reader) r.init(src, order, litWidth) return r } func (r *Reader) init(src io.Reader, order Order, litWidth int) { switch order { case LSB:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 12 14:39:39 UTC 2023 - 8K bytes - Viewed (0) -
test/typeswitch2.go
package main import "io" func whatis(x interface{}) string { switch x.(type) { case int: return "int" case int: // ERROR "duplicate" return "int8" case io.Reader: return "Reader1" case io.Reader: // ERROR "duplicate" return "Reader2" case interface { r() w() }: return "rw" case interface { // ERROR "duplicate" w() r() }: return "wr" } return ""
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 11 23:33:11 UTC 2019 - 655 bytes - Viewed (0) -
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 Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 14 13:54:47 UTC 2022 - 4.5K bytes - Viewed (0) -
src/mime/quotedprintable/reader.go
import ( "bufio" "bytes" "fmt" "io" ) // Reader is a quoted-printable decoder. type Reader struct { br *bufio.Reader rerr error // last read error line []byte // to be consumed before more of br } // NewReader returns a quoted-printable reader, decoding from r. func NewReader(r io.Reader) *Reader { return &Reader{ br: bufio.NewReader(r), } } func fromHex(b byte) (byte, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 27 17:00:08 UTC 2018 - 3.6K bytes - Viewed (0)