summaryrefslogtreecommitdiff
path: root/vendor/github.com/go-pg/pg/v10/internal/pool/reader_bytes.go
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/github.com/go-pg/pg/v10/internal/pool/reader_bytes.go')
-rw-r--r--vendor/github.com/go-pg/pg/v10/internal/pool/reader_bytes.go121
1 files changed, 0 insertions, 121 deletions
diff --git a/vendor/github.com/go-pg/pg/v10/internal/pool/reader_bytes.go b/vendor/github.com/go-pg/pg/v10/internal/pool/reader_bytes.go
deleted file mode 100644
index 93646b1da..000000000
--- a/vendor/github.com/go-pg/pg/v10/internal/pool/reader_bytes.go
+++ /dev/null
@@ -1,121 +0,0 @@
-// Copyright 2012 The Go Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style
-// license that can be found in the LICENSE file.
-
-package pool
-
-import (
- "bytes"
- "errors"
- "io"
-)
-
-type BytesReader struct {
- s []byte
- i int
-}
-
-func NewBytesReader(b []byte) *BytesReader {
- return &BytesReader{
- s: b,
- }
-}
-
-func (r *BytesReader) Reset(b []byte) {
- r.s = b
- r.i = 0
-}
-
-func (r *BytesReader) Buffered() int {
- return len(r.s) - r.i
-}
-
-func (r *BytesReader) Bytes() []byte {
- return r.s[r.i:]
-}
-
-func (r *BytesReader) Read(b []byte) (n int, err error) {
- if r.i >= len(r.s) {
- return 0, io.EOF
- }
- n = copy(b, r.s[r.i:])
- r.i += n
- return
-}
-
-func (r *BytesReader) ReadByte() (byte, error) {
- if r.i >= len(r.s) {
- return 0, io.EOF
- }
- b := r.s[r.i]
- r.i++
- return b, nil
-}
-
-func (r *BytesReader) UnreadByte() error {
- if r.i <= 0 {
- return errors.New("UnreadByte: at beginning of slice")
- }
- r.i--
- return nil
-}
-
-func (r *BytesReader) ReadSlice(delim byte) ([]byte, error) {
- if i := bytes.IndexByte(r.s[r.i:], delim); i >= 0 {
- i++
- line := r.s[r.i : r.i+i]
- r.i += i
- return line, nil
- }
-
- line := r.s[r.i:]
- r.i = len(r.s)
- return line, io.EOF
-}
-
-func (r *BytesReader) ReadBytes(fn func(byte) bool) ([]byte, error) {
- for i, c := range r.s[r.i:] {
- if !fn(c) {
- i++
- line := r.s[r.i : r.i+i]
- r.i += i
- return line, nil
- }
- }
-
- line := r.s[r.i:]
- r.i = len(r.s)
- return line, io.EOF
-}
-
-func (r *BytesReader) Discard(n int) (int, error) {
- b, err := r.ReadN(n)
- return len(b), err
-}
-
-func (r *BytesReader) ReadN(n int) ([]byte, error) {
- nn := n
- if nn > len(r.s) {
- nn = len(r.s)
- }
-
- b := r.s[r.i : r.i+nn]
- r.i += nn
- if n > nn {
- return b, io.EOF
- }
- return b, nil
-}
-
-func (r *BytesReader) ReadFull() ([]byte, error) {
- b := make([]byte, len(r.s)-r.i)
- copy(b, r.s[r.i:])
- r.i = len(r.s)
- return b, nil
-}
-
-func (r *BytesReader) ReadFullTemp() ([]byte, error) {
- b := r.s[r.i:]
- r.i = len(r.s)
- return b, nil
-}