@@ -3,6 +3,7 @@ package iox
import (
"strings"
"testing"
+ "testing/iotest"
"github.com/stretchr/testify/assert"
)
@@ -22,3 +23,10 @@ func TestScanner(t *testing.T) {
}
assert.EqualValues(t, []string{"1", "2", "3", "4"}, lines)
+
+func TestBadScanner(t *testing.T) {
+ scanner := NewTextLineScanner(iotest.ErrReader(iotest.ErrTimeout))
+ assert.False(t, scanner.Scan())
+ _, err := scanner.Line()
+ assert.ErrorIs(t, err, iotest.ErrTimeout)
+}
@@ -3,6 +3,8 @@ package redis
+ "github.com/alicebob/miniredis/v2"
+ red "github.com/go-redis/redis/v8"
@@ -41,3 +43,17 @@ func TestSplitClusterAddrs(t *testing.T) {
})
+func TestGetCluster(t *testing.T) {
+ r := miniredis.RunT(t)
+ defer r.Close()
+ c, err := getCluster(&Redis{
+ Addr: r.Addr(),
+ Type: ClusterType,
+ tls: true,
+ hooks: []red.Hook{durationHook},
+ })
+ if assert.NoError(t, err) {
+ assert.NotNil(t, c)
+ }