Bug fix, overriding default realis client and then explicitly closing it was causing issues.

This commit is contained in:
Renan DelValle 2018-10-27 11:15:25 -07:00
parent 230bef03ee
commit b7c0264b60
No known key found for this signature in database
GPG key ID: 3895800E03F17676

View file

@ -91,9 +91,7 @@ func TestNonExistentEndpoint(t *testing.T) {
} }
func TestThriftBinary(t *testing.T) { func TestThriftBinary(t *testing.T) {
var err error r, err := realis.NewRealisClient(realis.SchedulerUrl("http://192.168.33.7:8081"),
r, err = realis.NewRealisClient(realis.SchedulerUrl("http://192.168.33.7:8081"),
realis.BasicAuth("aurora", "secret"), realis.BasicAuth("aurora", "secret"),
realis.TimeoutMS(20000), realis.TimeoutMS(20000),
realis.ThriftBinary()) realis.ThriftBinary())
@ -115,9 +113,7 @@ func TestThriftBinary(t *testing.T) {
} }
func TestThriftJSON(t *testing.T) { func TestThriftJSON(t *testing.T) {
var err error r, err := realis.NewRealisClient(realis.SchedulerUrl("http://192.168.33.7:8081"),
r, err = realis.NewRealisClient(realis.SchedulerUrl("http://192.168.33.7:8081"),
realis.BasicAuth("aurora", "secret"), realis.BasicAuth("aurora", "secret"),
realis.TimeoutMS(20000), realis.TimeoutMS(20000),
realis.ThriftJSON()) realis.ThriftJSON())