- Sort Score
- Num 10 results
- Language All
Results 21 - 29 of 29 for read_bytes (0.07 seconds)
-
internal/s3select/csv/reader.go
// ReadFull returns ErrUnexpectedEOF. return dst[:n], err } dst = dst[:n] if err == io.ErrUnexpectedEOF { return dst, io.EOF } } // Read until next line. in, err := r.buf.ReadBytes('\n') dst = append(dst, in...) return dst, err } // csvSplitSize is the size of each block. // Blocks will read this much and find the first following newline.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 8.8K bytes - Click Count (0) -
internal/ringbuffer/ring_buffer.go
c2 := n - c1 copy(p[c1:], r.buf[0:c2]) } r.r = (r.r + n) % r.size r.isFull = false return n, r.readErr(true) } // ReadByte reads and returns the next byte from the input or ErrIsEmpty. func (r *RingBuffer) ReadByte() (b byte, err error) { r.mu.Lock() defer r.mu.Unlock() if err = r.readErr(true); err != nil { return 0, err } for r.w == r.r && !r.isFull {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 13.3K bytes - Click Count (0) -
cmd/xl-storage-format-v2_gen.go
s = msgp.Uint8Size return } // DecodeMsg implements msgp.Decodable func (z *xlMetaBuf) DecodeMsg(dc *msgp.Reader) (err error) { { var zb0001 []byte zb0001, err = dc.ReadBytes([]byte((*z))) if err != nil { err = msgp.WrapError(err) return } (*z) = xlMetaBuf(zb0001) } return } // EncodeMsg implements msgp.Encodable
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 55.8K bytes - Click Count (0) -
cmd/xl-storage-format-v1_gen.go
zb0002, err = dc.ReadUint() if err != nil { err = msgp.WrapError(err, "Algorithm") return } z.Algorithm = BitrotAlgorithm(zb0002) } case "Hash": z.Hash, err = dc.ReadBytes(z.Hash) if err != nil { err = msgp.WrapError(err, "Hash") return } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 41.2K bytes - Click Count (0) -
cmd/storage-datatypes_gen.go
return } if dc.IsNil() { err = dc.ReadNil() if err != nil { err = msgp.WrapError(err) return } z.Data = nil } else { z.Data, err = dc.ReadBytes(z.Data) if err != nil { err = msgp.WrapError(err, "Data") return } if z.Data == nil { z.Data = make([]byte, 0) } } z.NumVersions, err = dc.ReadInt() if err != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 151.7K bytes - Click Count (0) -
src/bytes/example_test.go
fmt.Println(string(rdbuf)) // Output: // 1 // bcde // a } func ExampleBuffer_ReadByte() { var b bytes.Buffer b.Grow(64) b.Write([]byte("abcde")) c, err := b.ReadByte() if err != nil { panic(err) } fmt.Println(c) fmt.Println(b.String()) // Output: // 97 // bcde } func ExampleClone() { b := []byte("abc") clone := bytes.Clone(b)
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon May 12 16:07:54 GMT 2025 - 16.5K bytes - Click Count (0) -
internal/grid/msg_gen.go
} { var zb0004 uint8 zb0004, err = dc.ReadUint8() if err != nil { err = msgp.WrapError(err, "Flags") return } z.Flags = Flags(zb0004) } z.Payload, err = dc.ReadBytes(z.Payload) if err != nil { err = msgp.WrapError(err, "Payload") return } return } // EncodeMsg implements msgp.Encodable func (z *message) EncodeMsg(en *msgp.Writer) (err error) {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 22.4K bytes - Click Count (0) -
cmd/storage-rest-server.go
// has been used. // The returned reader contains the payload. func waitForHTTPResponse(respBody io.Reader) (io.Reader, error) { reader := bufio.NewReader(respBody) for { b, err := reader.ReadByte() if err != nil { return nil, err } // Check if we have a response ready or a filler byte. switch b { case 0: return reader, nil case 1: errorText, err := io.ReadAll(reader)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 45.7K bytes - Click Count (0) -
api/go1.txt
pkg io, method (*SectionReader) Size() int64 pkg io, type ByteReader interface { ReadByte } pkg io, type ByteReader interface, ReadByte() (uint8, error) pkg io, type ByteScanner interface { ReadByte, UnreadByte } pkg io, type ByteScanner interface, ReadByte() (uint8, error) pkg io, type ByteScanner interface, UnreadByte() error pkg io, type Closer interface { Close }
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Wed Aug 14 18:58:28 GMT 2013 - 1.7M bytes - Click Count (0)