diff --git a/system_test/request_forwarding_test.go b/system_test/request_forwarding_test.go index 6a16c3b0..3c5541c7 100644 --- a/system_test/request_forwarding_test.go +++ b/system_test/request_forwarding_test.go @@ -15,6 +15,7 @@ import ( const ( shortWait = 5 * time.Second + noRetries = 0 ) var ( @@ -41,7 +42,7 @@ func Test_StoreClientSideBySide(t *testing.T) { if exp, got := "[{}]", asJSON(res); exp != got { t.Fatalf("unexpected results, exp %s, got %s", exp, got) } - res, err = client.Execute(executeRequestFromString("CREATE TABLE bar (id INTEGER NOT NULL PRIMARY KEY, name TEXT)"), leaderAddr, NO_CREDS, shortWait) + res, err = client.Execute(executeRequestFromString("CREATE TABLE bar (id INTEGER NOT NULL PRIMARY KEY, name TEXT)"), leaderAddr, NO_CREDS, shortWait, noRetries) if err != nil { t.Fatalf("failed to execute via remote: %s", err.Error()) } @@ -57,7 +58,7 @@ func Test_StoreClientSideBySide(t *testing.T) { if exp, got := `[{"last_insert_id":1,"rows_affected":1}]`, asJSON(res); exp != got { t.Fatalf("unexpected results, exp %s, got %s", exp, got) } - res, err = client.Execute(executeRequestFromString(`INSERT INTO bar(name) VALUES("fiona")`), leaderAddr, NO_CREDS, shortWait) + res, err = client.Execute(executeRequestFromString(`INSERT INTO bar(name) VALUES("fiona")`), leaderAddr, NO_CREDS, shortWait, noRetries) if err != nil { t.Fatalf("failed to execute via remote: %s", err.Error()) } @@ -87,7 +88,7 @@ func Test_StoreClientSideBySide(t *testing.T) { if exp, got := `[{"columns":["id","name"],"types":["integer","text"],"values":[[1,"fiona"]]}]`, asJSON(rows); exp != got { t.Fatalf("unexpected results, exp %s, got %s", exp, got) } - results, err = client.Request(executeQueryRequestFromString(`SELECT * FROM foo`), leaderAddr, NO_CREDS, shortWait) + results, err = client.Request(executeQueryRequestFromString(`SELECT * FROM foo`), leaderAddr, NO_CREDS, shortWait, 0) if err != nil { t.Fatalf("failed to query via remote: %s", err.Error()) } @@ -117,7 +118,7 @@ func Test_StoreClientSideBySide(t *testing.T) { if exp, got := `[{"columns":["id","name"],"types":["integer","text"],"values":[[1,"fiona"]]}]`, asJSON(rows); exp != got { t.Fatalf("unexpected results, exp %s, got %s", exp, got) } - results, err = client.Request(executeQueryRequestFromString(`SELECT * FROM bar`), leaderAddr, NO_CREDS, shortWait) + results, err = client.Request(executeQueryRequestFromString(`SELECT * FROM bar`), leaderAddr, NO_CREDS, shortWait, noRetries) if err != nil { t.Fatalf("failed to query via remote: %s", err.Error()) } @@ -147,7 +148,7 @@ func Test_StoreClientSideBySide(t *testing.T) { if exp, got := `[{"error":"no such table: qux"}]`, asJSON(rows); exp != got { t.Fatalf("unexpected results, exp %s, got %s", exp, got) } - results, err = client.Request(executeQueryRequestFromString(`SELECT * FROM qux`), leaderAddr, NO_CREDS, shortWait) + results, err = client.Request(executeQueryRequestFromString(`SELECT * FROM qux`), leaderAddr, NO_CREDS, shortWait, noRetries) if err != nil { t.Fatalf("failed to query via remote: %s", err.Error()) }