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

Adding test for NOOP Logger.

Browse source
This commit is contained in:
Renan DelValle 2018-10-26 17:45:41 -07:00
parent eee9a87113
commit 230bef03ee
No known key found for this signature in database
GPG key ID: C240AD6D6F443EC9
1 changed files with 28 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

34
realis_e2e_test.go
View file

@ -93,7 +93,6 @@ func TestNonExistentEndpoint(t *testing.T) {
func TestThriftBinary(t *testing.T) { func TestThriftBinary(t *testing.T) {
var err error var err error
// New configuration to connect to docker container
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),
@ -103,7 +102,7 @@ func TestThriftBinary(t *testing.T) {
role := "all" role := "all"
taskQ := &aurora.TaskQuery{ taskQ := &aurora.TaskQuery{
Role: &role, Role: &role,
} }
// Perform a simple API call to test Thrift Binary // Perform a simple API call to test Thrift Binary
@ -118,7 +117,6 @@ func TestThriftBinary(t *testing.T) {
func TestThriftJSON(t *testing.T) { func TestThriftJSON(t *testing.T) {
var err error var err error
// New configuration to connect to docker container
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),
@ -128,7 +126,7 @@ func TestThriftJSON(t *testing.T) {
role := "all" role := "all"
taskQ := &aurora.TaskQuery{ taskQ := &aurora.TaskQuery{
Role: &role, Role: &role,
} }
// Perform a simple API call to test Thrift Binary // Perform a simple API call to test Thrift Binary
@ -140,6 +138,26 @@ func TestThriftJSON(t *testing.T) {
} }
func TestNoopLogger(t *testing.T) {
r, err := realis.NewRealisClient(realis.SchedulerUrl("http://192.168.33.7:8081"),
realis.BasicAuth("aurora", "secret"),
realis.SetLogger(realis.NoopLogger{}))
assert.NoError(t, err)
role := "all"
taskQ := &aurora.TaskQuery{
Role: &role,
}
// Perform a simple API call to test Thrift Binary
_, err = r.GetTasksWithoutConfigs(taskQ)
assert.NoError(t, err)
r.Close()
}
func TestLeaderFromZK(t *testing.T) { func TestLeaderFromZK(t *testing.T) {
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)
@ -172,11 +190,11 @@ func TestRealisClient_CreateJob_Thermos(t *testing.T) {
Name("create_thermos_job_test"). Name("create_thermos_job_test").
ExecutorName(aurora.AURORA_EXECUTOR_NAME). ExecutorName(aurora.AURORA_EXECUTOR_NAME).
ExecutorData(string(thermosPayload)). ExecutorData(string(thermosPayload)).
CPU(1). CPU(.5).
RAM(64). RAM(64).
Disk(100). Disk(100).
IsService(true). IsService(true).
InstanceCount(1). InstanceCount(2).
AddPorts(1) AddPorts(1)
resp, err := r.CreateJob(job) resp, err := r.CreateJob(job)
@ -213,6 +231,10 @@ func TestRealisClient_CreateJob_Thermos(t *testing.T) {
assert.NoError(t, err) assert.NoError(t, err)
assert.Equal(t, aurora.ResponseCode_OK, resp.ResponseCode) assert.Equal(t, aurora.ResponseCode_OK, resp.ResponseCode)
success, err := monitor.Instances(job.JobKey(), 0, 1, 50)
assert.True(t, success)
assert.NoError(t, err)
}) })
} }