Made replicated session more testable

m3db · Aug 20, 2019 · b787b74 · b787b74
1 parent 36dc2b4
commit b787b74
Show file tree

Hide file tree

Showing 6 changed files with 2,978 additions and 68 deletions.
diff --git a/src/dbnode/client/client.go b/src/dbnode/client/client.go
@@ -28,12 +28,12 @@ type client struct {
 	sync.Mutex
 
 	opts         MultiClusterOptions
-	newSessionFn newSessionFn
+	newSessionFn newReplicatedSessionFn
 	session      AdminSession // default cached session
 }
 
-// type newSessionFn func(opts MultiClusterOptions) (replicatedSession, error)
-type newSessionFn func(opts MultiClusterOptions) (clientSession, error)
+// type newReplicatedSessionFn func(MultiClusterOptions) (replicatedSession, error)
+type newReplicatedSessionFn func(MultiClusterOptions, ...replicatedSessionOption) (clientSession, error)
 
 // NewClient creates a new client
 func NewClient(opts MultiClusterOptions) (Client, error) {