rueian/rueidis

Similar blocks of code found in 12 locations. Consider refactoring.

Open

func (c TsRevrangeTotimestamp) FilterByTs(timestamp ...int64) TsRevrangeFilterByTs {
    c.cs.s = append(c.cs.s, "FILTER_BY_TS")
    for _, n := range timestamp {
        c.cs.s = append(c.cs.s, strconv.FormatInt(n, 10))
    }

• Read up
  Read up

Similar blocks of code found in 12 locations. Consider refactoring.

Open

func (c ZinterstoreKey) Weights(weight ...int64) ZinterstoreWeights {
    c.cs.s = append(c.cs.s, "WEIGHTS")
    for _, n := range weight {
        c.cs.s = append(c.cs.s, strconv.FormatInt(n, 10))
    }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func VectorString64(v []float64) string {
    b := make([]byte, len(v)*8)
    for i, e := range v {
        i := i * 8
        binary.LittleEndian.PutUint64(b[i:i+8], math.Float64bits(e))

• Read up
  Read up

Similar blocks of code found in 12 locations. Consider refactoring.

Open

func (c TsRevrangeLatest) FilterByTs(timestamp ...int64) TsRevrangeFilterByTs {
    c.cs.s = append(c.cs.s, "FILTER_BY_TS")
    for _, n := range timestamp {
        c.cs.s = append(c.cs.s, strconv.FormatInt(n, 10))
    }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func VectorString32(v []float32) string {
    b := make([]byte, len(v)*4)
    for i, e := range v {
        i := i * 4
        binary.LittleEndian.PutUint32(b[i:i+4], math.Float32bits(e))

• Read up
  Read up

Similar blocks of code found in 12 locations. Consider refactoring.

Open

func (c TsMrevrangeTotimestamp) FilterByTs(timestamp ...int64) TsMrevrangeFilterByTs {
    c.cs.s = append(c.cs.s, "FILTER_BY_TS")
    for _, n := range timestamp {
        c.cs.s = append(c.cs.s, strconv.FormatInt(n, 10))
    }

• Read up
  Read up

Similar blocks of code found in 12 locations. Consider refactoring.

Open

func (c ZinterKey) Weights(weight ...int64) ZinterWeights {
    c.cs.s = append(c.cs.s, "WEIGHTS")
    for _, n := range weight {
        c.cs.s = append(c.cs.s, strconv.FormatInt(n, 10))
    }

• Read up
  Read up

Similar blocks of code found in 12 locations. Consider refactoring.

Open

func (c TsMrangeLatest) FilterByTs(timestamp ...int64) TsMrangeFilterByTs {
    c.cs.s = append(c.cs.s, "FILTER_BY_TS")
    for _, n := range timestamp {
        c.cs.s = append(c.cs.s, strconv.FormatInt(n, 10))
    }

• Read up
  Read up

Similar blocks of code found in 12 locations. Consider refactoring.

Open

func (c TsMrevrangeLatest) FilterByTs(timestamp ...int64) TsMrevrangeFilterByTs {
    c.cs.s = append(c.cs.s, "FILTER_BY_TS")
    for _, n := range timestamp {
        c.cs.s = append(c.cs.s, strconv.FormatInt(n, 10))
    }

• Read up
  Read up

Similar blocks of code found in 12 locations. Consider refactoring.

Open

func (c ZunionKey) Weights(weight ...int64) ZunionWeights {
    c.cs.s = append(c.cs.s, "WEIGHTS")
    for _, n := range weight {
        c.cs.s = append(c.cs.s, strconv.FormatInt(n, 10))
    }

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

func (mr *DedicatedClientMockRecorder) Do(arg0, arg1 any) *gomock.Call {
    mr.mock.ctrl.T.Helper()
    return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Do", reflect.TypeOf((*DedicatedClient)(nil).Do), arg0, arg1)
}

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

func (m *DedicatedClient) Do(arg0 context.Context, arg1 rueidis.Completed) rueidis.RedisResult {
    m.ctrl.T.Helper()
    ret := m.ctrl.Call(m, "Do", arg0, arg1)
    ret0, _ := ret[0].(rueidis.RedisResult)
    return ret0

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

func (mr *ClientMockRecorder) DoStream(arg0, arg1 any) *gomock.Call {
    mr.mock.ctrl.T.Helper()
    return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DoStream", reflect.TypeOf((*Client)(nil).DoStream), arg0, arg1)
}

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

func (m *Client) DoStream(arg0 context.Context, arg1 rueidis.Completed) rueidis.RedisResultStream {
    m.ctrl.T.Helper()
    ret := m.ctrl.Call(m, "DoStream", arg0, arg1)
    ret0, _ := ret[0].(rueidis.RedisResultStream)
    return ret0

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

func (m *Client) Do(arg0 context.Context, arg1 rueidis.Completed) rueidis.RedisResult {
    m.ctrl.T.Helper()
    ret := m.ctrl.Call(m, "Do", arg0, arg1)
    ret0, _ := ret[0].(rueidis.RedisResult)
    return ret0

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

func (mr *ClientMockRecorder) Do(arg0, arg1 any) *gomock.Call {
    mr.mock.ctrl.T.Helper()
    return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Do", reflect.TypeOf((*Client)(nil).Do), arg0, arg1)
}

• Read up
  Read up

Method RedisMessage.AsXRangeEntry has 6 return statements (exceeds 4 allowed).

Open

func (m *RedisMessage) AsXRangeEntry() (XRangeEntry, error) {
    values, err := m.ToArray()
    if err != nil {
        return XRangeEntry{}, err
    }

Method pipe.handlePush has 6 return statements (exceeds 4 allowed).

Open

func (p *pipe) handlePush(values []RedisMessage) (reply bool, unsubscribe bool) {
    if len(values) < 2 {
        return
    }
    // TODO: handle other push data

Method RedisMessage.AsXRead has 6 return statements (exceeds 4 allowed).

Open

func (m *RedisMessage) AsXRead() (ret map[string][]XRangeEntry, err error) {
    if err = m.Error(); err != nil {
        return nil, err
    }
    if m.IsMap() {

Function readBlobString has 6 return statements (exceeds 4 allowed).

Open

func readBlobString(i *bufio.Reader) (m RedisMessage, err error) {
    m.string, err = readB(i)
    if err == errChunked {
        sb := strings.Builder{}
        for {