From 877af6dad99b26e7dbab9a08bda31be1a609ed4c Mon Sep 17 00:00:00 2001 From: Travis Date: Tue, 12 Jan 2021 23:30:10 -0600 Subject: [PATCH] replace a MustNewCluster with MustRunCluster --- http/client_test.go | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) diff --git a/http/client_test.go b/http/client_test.go index 1c8ed525c..317480585 100644 --- a/http/client_test.go +++ b/http/client_test.go @@ -469,17 +469,15 @@ func TestClient_ImportColumnAttrs(t *testing.T) { // Ensure client can bulk import data. func TestClient_ImportRoaring(t *testing.T) { - cluster := test.MustNewCluster(t, 2) - for _, c := range cluster.Nodes { - c.Config.Cluster.ReplicaN = 2 - } - err := cluster.Start() - if err != nil { - t.Fatalf("starting cluster: %v", err) - } + cluster := test.MustRunCluster(t, 2, + []server.CommandOption{ + server.OptCommandServerOptions(pilosa.OptServerReplicaN(2))}, + []server.CommandOption{ + server.OptCommandServerOptions(pilosa.OptServerReplicaN(2))}, + ) defer cluster.Close() - _, err = cluster.GetNode(0).API.CreateIndex(context.Background(), "i", pilosa.IndexOptions{}) + _, err := cluster.GetNode(0).API.CreateIndex(context.Background(), "i", pilosa.IndexOptions{}) if err != nil { t.Fatalf("creating index: %v", err) }