ridv/gorealis-v2
1
0
Fork 0
Code Issues Pull requests Projects Releases 13 Packages Wiki Activity Actions

Removing t.Parallel to remove another possible cause of issues for now

Browse source
This commit is contained in:
Renán Del Valle 2021-10-15 15:50:34 -07:00
parent ba0a13b0f0
commit 239c9ccd8f
No known key found for this signature in database
GPG key ID: C240AD6D6F443EC9
1 changed files with 0 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

18
realis_e2e_test.go
View file

@ -54,8 +54,6 @@ func TestMain(m *testing.M) {
} }
func TestNonExistentEndpoint(t *testing.T) { func TestNonExistentEndpoint(t *testing.T) {
t.Parallel()
backoff := realis.Backoff{ // Reduce penalties for this test to make it quick backoff := realis.Backoff{ // Reduce penalties for this test to make it quick
Steps: 5, Steps: 5,
Duration: 1 * time.Second, Duration: 1 * time.Second,
@ -86,8 +84,6 @@ func TestNonExistentEndpoint(t *testing.T) {
} }
func TestBadCredentials(t *testing.T) { func TestBadCredentials(t *testing.T) {
t.Parallel()
r, err := realis.NewClient(realis.SchedulerUrl("http://192.168.33.7:8081"), r, err := realis.NewClient(realis.SchedulerUrl("http://192.168.33.7:8081"),
realis.BasicAuth("incorrect", "password"), realis.BasicAuth("incorrect", "password"),
realis.Debug()) realis.Debug())
@ -114,8 +110,6 @@ func TestBadCredentials(t *testing.T) {
} }
func TestThriftBinary(t *testing.T) { func TestThriftBinary(t *testing.T) {
t.Parallel()
r, err := realis.NewClient(realis.SchedulerUrl("http://192.168.33.7:8081"), r, err := realis.NewClient(realis.SchedulerUrl("http://192.168.33.7:8081"),
realis.BasicAuth("aurora", "secret"), realis.BasicAuth("aurora", "secret"),
realis.Timeout(20*time.Second), realis.Timeout(20*time.Second),
@ -137,8 +131,6 @@ func TestThriftBinary(t *testing.T) {
} }
func TestThriftJSON(t *testing.T) { func TestThriftJSON(t *testing.T) {
t.Parallel()
r, err := realis.NewClient(realis.SchedulerUrl("http://192.168.33.7:8081"), r, err := realis.NewClient(realis.SchedulerUrl("http://192.168.33.7:8081"),
realis.BasicAuth("aurora", "secret"), realis.BasicAuth("aurora", "secret"),
realis.Timeout(20*time.Second), realis.Timeout(20*time.Second),
@ -161,8 +153,6 @@ func TestThriftJSON(t *testing.T) {
} }
func TestNoopLogger(t *testing.T) { func TestNoopLogger(t *testing.T) {
t.Parallel()
r, err := realis.NewClient(realis.SchedulerUrl("http://192.168.33.7:8081"), r, err := realis.NewClient(realis.SchedulerUrl("http://192.168.33.7:8081"),
realis.BasicAuth("aurora", "secret"), realis.BasicAuth("aurora", "secret"),
realis.SetLogger(realis.NoopLogger{})) realis.SetLogger(realis.NoopLogger{}))
@ -183,8 +173,6 @@ func TestNoopLogger(t *testing.T) {
} }
func TestLeaderFromZK(t *testing.T) { func TestLeaderFromZK(t *testing.T) {
t.Parallel()
cluster := realis.GetDefaultClusterFromZKUrl("192.168.33.2:2181") cluster := realis.GetDefaultClusterFromZKUrl("192.168.33.2:2181")
url, err := realis.LeaderFromZK(*cluster) url, err := realis.LeaderFromZK(*cluster)
@ -193,8 +181,6 @@ func TestLeaderFromZK(t *testing.T) {
} }
func TestInvalidAuroraURL(t *testing.T) { func TestInvalidAuroraURL(t *testing.T) {
t.Parallel()
for _, url := range []string{ for _, url := range []string{
"http://doesntexist.com:8081/apitest", "http://doesntexist.com:8081/apitest",
"test://doesntexist.com:8081", "test://doesntexist.com:8081",
@ -207,8 +193,6 @@ func TestInvalidAuroraURL(t *testing.T) {
} }
func TestValidAuroraURL(t *testing.T) { func TestValidAuroraURL(t *testing.T) {
t.Parallel()
for _, url := range []string{ for _, url := range []string{
"http://domain.com:8081/api", "http://domain.com:8081/api",
"https://domain.com:8081/api", "https://domain.com:8081/api",
@ -232,8 +216,6 @@ func TestRealisClient_ReestablishConn(t *testing.T) {
} }
func TestGetCACerts(t *testing.T) { func TestGetCACerts(t *testing.T) {
t.Parallel()
certs, err := realis.GetCerts("./examples/certs") certs, err := realis.GetCerts("./examples/certs")
assert.NoError(t, err) assert.NoError(t, err)
assert.Equal(t, len(certs.Subjects()), 2) assert.Equal(t, len(certs.Subjects()), 2)