rueian/rueidis

Method sentinelClient._switchTarget has 6 return statements (exceeds 4 allowed).

Open

func (c *sentinelClient) _switchTarget(addr string) (err error) {
    var target conn
    if atomic.LoadUint32(&c.stop) == 1 {
        return nil
    }

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

Open

func NewBloomFilter(
    client rueidis.Client,
    name string,
    expectedNumberOfItems uint,
    falsePositiveRate float64,

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

Open

func NewClient(option ClientOption) (client Client, err error) {
    if option.ReadBufferEachConn < 32 { // the buffer should be able to hold an int64 string at least
        option.ReadBufferEachConn = DefaultReadBuffer
    }
    if option.WriteBufferEachConn < 32 {

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

Function newMux has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func newMux(dst string, option *ClientOption, init, dead wire, wireFn wireFn, wireNoBgFn wireFn) *mux {

Function startSpan has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func startSpan(tracer trace.Tracer, ctx context.Context, op string, size int, attrs trace.SpanStartEventOption) (context.Context, trace.Span) {

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

Open

    case "message":
        if len(values) >= 3 {
            m := PubSubMessage{Channel: values[1].string, Message: values[2].string}
            p.nsubs.Publish(values[1].string, m)
            p.pshks.Load().(*pshks).hooks.OnMessage(m)

• Read up
  Read up

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

Open

    case "smessage":
        if len(values) >= 3 {
            m := PubSubMessage{Channel: values[1].string, Message: values[2].string}
            p.ssubs.Publish(values[1].string, m)
            p.pshks.Load().(*pshks).hooks.OnMessage(m)

• Read up
  Read up

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

Open

func (c ZunionWeights) 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 8 locations. Consider refactoring.

Open

func (c TsRangeFilterByTs) FilterByTs(timestamp ...int64) TsRangeFilterByTs {
    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 8 locations. Consider refactoring.

Open

func (c ZinterWeights) 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 8 locations. Consider refactoring.

Open

func (c TsMrevrangeFilterByTs) 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 8 locations. Consider refactoring.

Open

func (c TsRevrangeFilterByTs) 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 8 locations. Consider refactoring.

Open

func (c ZinterstoreWeights) 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 8 locations. Consider refactoring.

Open

func (c ZunionstoreWeights) Weights(weight ...int64) ZunionstoreWeights {
    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 8 locations. Consider refactoring.

Open

func (c TsMrangeFilterByTs) 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

Method bloomFilter.ExistsMulti has 5 return statements (exceeds 4 allowed).

Open

func (c *bloomFilter) ExistsMulti(ctx context.Context, keys []string) ([]bool, error) {
    if len(keys) == 0 {
        return nil, nil
    }

Method locker.waitgate has 5 return statements (exceeds 4 allowed).

Open

func (m *locker) waitgate(ctx context.Context, name string) (g *gate, err error) {
    m.mu.Lock()
    g, ok := m.gates[name]
    if !ok {
        if m.gates == nil {

Method RedisMessage.AsZScores has 5 return statements (exceeds 4 allowed).

Open

func (m *RedisMessage) AsZScores() ([]ZScore, error) {
    arr, err := m.ToArray()
    if err != nil {
        return nil, err
    }