[aggregator] Split up TCP and M3Msg clients (#2964)

m3db · Dec 2, 2020 · 0342a92 · 0342a92
1 parent ae0403a
commit 0342a92
Show file tree

Hide file tree

Showing 7 changed files with 928 additions and 711 deletions.
diff --git a/src/aggregator/aggregator/options_test.go b/src/aggregator/aggregator/options_test.go
@@ -124,12 +124,9 @@ func TestSetStreamOptions(t *testing.T) {
 }
 
 func TestSetAdminClient(t *testing.T) {
-	c, err := client.NewClient(client.NewOptions())
-	require.NoError(t, err)
-	value, ok := c.(client.AdminClient)
-	require.True(t, ok)
-	o := NewOptions().SetAdminClient(value)
-	require.True(t, value == o.AdminClient())
+	var c client.AdminClient = &client.M3MsgClient{}
+	o := NewOptions().SetAdminClient(c)
+	require.True(t, c == o.AdminClient())
 }
 
 func TestSetRuntimeOptionsManager(t *testing.T) {