55 "context"
66 "crypto/rand"
77 "fmt"
8+ "github.com/k3s-io/kine/pkg/tls"
89 "github.com/stretchr/testify/assert"
910 "go.etcd.io/etcd/api/v3/v3rpc/rpctypes"
1011 "golang.org/x/sync/errgroup"
@@ -36,7 +37,7 @@ func TestMain(m *testing.M) {
3637func TestFDB (t * testing.T ) {
3738 n := 4
3839 sameKeyN := 3
39- f := NewFdbStructured (connectionString ,, "dir1" )
40+ f := NewFdbStructured (connectionString , tls. Config {} , "dir1" )
4041 ctx , cancelCtx := context .WithTimeout (context .Background (), time .Duration (60 )* time .Second )
4142 err := f .Start (ctx )
4243 require .NoError (t , err )
@@ -45,7 +46,7 @@ func TestFDB(t *testing.T) {
4546
4647 forceRetryTransaction = func (i int ) bool { return i < 2 }
4748
48- f = NewFdbStructured (connectionString ,, "dir2" )
49+ f = NewFdbStructured (connectionString , tls. Config {} , "dir2" )
4950 ctx , cancelCtx = context .WithTimeout (context .Background (), time .Duration (60 )* time .Second )
5051 defer cancelCtx ()
5152 err = f .Start (ctx )
@@ -255,7 +256,7 @@ func TestFDB(t *testing.T) {
255256func TestFDBLargeRecords (t * testing.T ) {
256257 forceRetryTransaction = func (i int ) bool { return i < 1 }
257258
258- f := NewFdbStructured (connectionString ,, "dir1" )
259+ f := NewFdbStructured (connectionString , tls. Config {} , "dir1" )
259260 ctx , cancelCtx := context .WithTimeout (context .Background (), time .Duration (100 )* time .Second )
260261 defer cancelCtx ()
261262
@@ -341,7 +342,7 @@ func TestCompaction(t *testing.T) {
341342 newValue := []byte ("newVal123" )
342343 updatedLease := int64 (123 )
343344
344- f := NewFdbStructured (connectionString ,, "dir1" )
345+ f := NewFdbStructured (connectionString , tls. Config {} , "dir1" )
345346 ctx , cancelCtx := context .WithTimeout (context .Background (), time .Duration (20 )* time .Second )
346347 defer cancelCtx ()
347348
@@ -472,7 +473,7 @@ func TestWatchAll(t *testing.T) {
472473 maxBatchSize = 10
473474 recordsCount := 53
474475
475- f := NewFdbStructured (connectionString ,, "dir1" )
476+ f := NewFdbStructured (connectionString , tls. Config {} , "dir1" )
476477 ctx , cancelCtx := context .WithTimeout (context .Background (), time .Duration (3 )* time .Second )
477478 defer cancelCtx ()
478479
@@ -502,7 +503,7 @@ func TestExceedSizeLarge(t *testing.T) {
502503 _ , err := rand .Read (value )
503504 require .NoError (t , err )
504505
505- f := NewFdbStructured (connectionString ,, "dir1" )
506+ f := NewFdbStructured (connectionString , tls. Config {} , "dir1" )
506507 ctx , cancelCtx := context .WithTimeout (context .Background (), time .Duration (3 )* time .Second )
507508 defer cancelCtx ()
508509
0 commit comments