type github.com/go-redis/redis/v8/internal/proto.Reader

94 uses

	github.com/go-redis/redis/v8/internal/proto (current package)
		reader.go#L31: type MultiBulkParse func(*Reader, int64) (interface{}, error)
		reader.go#L33: type Reader struct {
		reader.go#L38: func NewReader(rd io.Reader) *Reader {
		reader.go#L39: 	return &Reader{
		reader.go#L45: func (r *Reader) Buffered() int {
		reader.go#L49: func (r *Reader) Peek(n int) ([]byte, error) {
		reader.go#L53: func (r *Reader) Reset(rd io.Reader) {
		reader.go#L57: func (r *Reader) ReadLine() ([]byte, error) {
		reader.go#L71: func (r *Reader) readLine() ([]byte, error) {
		reader.go#L83: func (r *Reader) ReadReply(m MultiBulkParse) (interface{}, error) {
		reader.go#L112: func (r *Reader) ReadIntReply() (int64, error) {
		reader.go#L127: func (r *Reader) ReadString() (string, error) {
		reader.go#L146: func (r *Reader) readStringReply(line []byte) (string, error) {
		reader.go#L165: func (r *Reader) ReadArrayReply(m MultiBulkParse) (interface{}, error) {
		reader.go#L184: func (r *Reader) ReadArrayLen() (int64, error) {
		reader.go#L199: func (r *Reader) ReadScanReply() ([]string, uint64, error) {
		reader.go#L230: func (r *Reader) ReadInt() (int64, error) {
		reader.go#L238: func (r *Reader) ReadUint() (uint64, error) {
		reader.go#L246: func (r *Reader) ReadFloatReply() (float64, error) {
		reader.go#L254: func (r *Reader) readTmpBytesReply() ([]byte, error) {
		reader.go#L271: func (r *Reader) _readTmpBytesReply(line []byte) ([]byte, error) {
		reader.go#L290: func (r *Reader) buf(n int) []byte {

	github.com/go-redis/redis/v8/internal/pool
		conn.go#L20: 	rd *proto.Reader
		conn.go#L64: func (cn *Conn) WithReader(ctx context.Context, timeout time.Duration, fn func(rd *proto.Reader) error) error {

	github.com/go-redis/redis/v8
		cluster.go#L1184: 			return cn.WithReader(ctx, c.opt.ReadTimeout, func(rd *proto.Reader) error {
		cluster.go#L1194: 	rd *proto.Reader,
		cluster.go#L1342: 			return cn.WithReader(ctx, c.opt.ReadTimeout, func(rd *proto.Reader) error {
		cluster.go#L1364: 	rd *proto.Reader,
		command.go#L23: 	readReply(rd *proto.Reader) error
		command.go#L302: func (cmd *Cmd) readReply(rd *proto.Reader) error {
		command.go#L308: func sliceParser(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L359: func (cmd *SliceCmd) readReply(rd *proto.Reader) error {
		command.go#L400: func (cmd *StatusCmd) readReply(rd *proto.Reader) error {
		command.go#L440: func (cmd *IntCmd) readReply(rd *proto.Reader) error {
		command.go#L476: func (cmd *IntSliceCmd) readReply(rd *proto.Reader) error {
		command.go#L477: 	_, cmd.err = rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L524: func (cmd *DurationCmd) readReply(rd *proto.Reader) error {
		command.go#L572: func (cmd *TimeCmd) readReply(rd *proto.Reader) error {
		command.go#L573: 	_, cmd.err = rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L625: func (cmd *BoolCmd) readReply(rd *proto.Reader) error {
		command.go#L739: func (cmd *StringCmd) readReply(rd *proto.Reader) error {
		command.go#L775: func (cmd *FloatCmd) readReply(rd *proto.Reader) error {
		command.go#L815: func (cmd *StringSliceCmd) readReply(rd *proto.Reader) error {
		command.go#L816: 	_, cmd.err = rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L864: func (cmd *BoolSliceCmd) readReply(rd *proto.Reader) error {
		command.go#L865: 	_, cmd.err = rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L910: func (cmd *StringStringMapCmd) readReply(rd *proto.Reader) error {
		command.go#L911: 	_, cmd.err = rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L962: func (cmd *StringIntMapCmd) readReply(rd *proto.Reader) error {
		command.go#L963: 	_, cmd.err = rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1014: func (cmd *StringStructMapCmd) readReply(rd *proto.Reader) error {
		command.go#L1015: 	_, cmd.err = rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1065: func (cmd *XMessageSliceCmd) readReply(rd *proto.Reader) error {
		command.go#L1076: func xMessageSliceParser(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1080: 		_, err := rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1111: func stringInterfaceMapParser(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1165: func (cmd *XStreamSliceCmd) readReply(rd *proto.Reader) error {
		command.go#L1166: 	_, cmd.err = rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1170: 			_, err := rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1237: func (cmd *XPendingCmd) readReply(rd *proto.Reader) error {
		command.go#L1238: 	_, cmd.err = rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1263: 		_, err = rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1265: 				_, err = rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1339: func (cmd *XPendingExtCmd) readReply(rd *proto.Reader) error {
		command.go#L1340: 	_, cmd.err = rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1343: 			_, err := rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1422: func (cmd *XInfoGroupsCmd) readReply(rd *proto.Reader) error {
		command.go#L1424: 		func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1437: func xGroupInfoParser(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1509: func (cmd *ZSliceCmd) readReply(rd *proto.Reader) error {
		command.go#L1510: 	_, cmd.err = rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1564: func (cmd *ZWithKeyCmd) readReply(rd *proto.Reader) error {
		command.go#L1565: 	_, cmd.err = rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1628: func (cmd *ScanCmd) readReply(rd *proto.Reader) error {
		command.go#L1682: func (cmd *ClusterSlotsCmd) readReply(rd *proto.Reader) error {
		command.go#L1683: 	_, cmd.err = rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1836: func (cmd *GeoLocationCmd) readReply(rd *proto.Reader) error {
		command.go#L1847: 	return func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1871: 	return func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1949: func (cmd *GeoPosCmd) readReply(rd *proto.Reader) error {
		command.go#L1950: 	_, cmd.err = rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L1954: 			_, err := rd.ReadReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L2026: func (cmd *CommandsInfoCmd) readReply(rd *proto.Reader) error {
		command.go#L2027: 	_, cmd.err = rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L2042: func commandInfoParser(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L2067: 	_, err = rd.ReadReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L2114: 	_, err = rd.ReadReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		command.go#L2213: func (cmd *SlowLogCmd) readReply(rd *proto.Reader) error {
		command.go#L2214: 	_, cmd.err = rd.ReadArrayReply(func(rd *proto.Reader, n int64) (interface{}, error) {
		pubsub.go#L378: 	err = cn.WithReader(ctx, timeout, func(rd *proto.Reader) error {
		redis.go#L429: 	err = cn.WithReader(ctx, c.opt.ReadTimeout, func(rd *proto.Reader) error {
		redis.go#L435: func pipelineReadCmds(rd *proto.Reader, cmds []Cmder) error {
		redis.go#L455: 	err = cn.WithReader(ctx, c.opt.ReadTimeout, func(rd *proto.Reader) error {
		redis.go#L481: func txPipelineReadQueued(rd *proto.Reader, statusCmd *StatusCmd, cmds []Cmder) error {