diff --git a/internal/proto/reader.go b/internal/proto/reader.go index a98ddb6..84f1488 100644 --- a/internal/proto/reader.go +++ b/internal/proto/reader.go @@ -77,7 +77,7 @@ func (p *Reader) ReadReply(m MultiBulkParse) (interface{}, error) { case IntReply: return parseIntValue(line) case StringReply: - return p.parseBytesValue(line) + return p.readBytesValue(line) case ArrayReply: n, err := parseArrayLen(line) if err != nil { @@ -112,7 +112,7 @@ func (p *Reader) ReadBytesReply() ([]byte, error) { case ErrorReply: return nil, parseErrorValue(line) case StringReply: - return p.parseBytesValue(line) + return p.readBytesValue(line) case StatusReply: return parseStatusValue(line) default: @@ -206,7 +206,7 @@ func (p *Reader) ReadScanReply() ([]string, uint64, error) { return keys, cursor, err } -func (p *Reader) parseBytesValue(line []byte) ([]byte, error) { +func (p *Reader) readBytesValue(line []byte) ([]byte, error) { if isNilReply(line) { return nil, internal.Nil } diff --git a/parser.go b/parser.go index 578dbc9..10580ab 100644 --- a/parser.go +++ b/parser.go @@ -406,5 +406,5 @@ func timeParser(rd *proto.Reader, n int64) (interface{}, error) { return nil, err } - return time.Unix(sec, microsec*100), nil + return time.Unix(sec, microsec*1000), nil }