epic/play-with-docker
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix failing tests

Browse Source
This commit is contained in:
Jonathan Leibiusky @xetorthio
2017-11-17 09:23:29 -03:00
parent 3481442768
commit f22bf1b3da
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
scheduler/task/check_swarm_ports_test.go
View File

@@ -44,7 +44,7 @@ func TestCheckSwarmPorts_RunWhenManager(t *testing.T) {
f.On("GetForInstance", i).Return(d, nil) f.On("GetForInstance", i).Return(d, nil)
d.On("GetDaemonInfo").Return(info, nil) d.On("GetDaemonInfo").Return(info, nil)
d.On("GetSwarmPorts").Return([]string{"aaaabbbb_node1", "aaaabbbb_node2"}, []uint16{8080, 9090}, nil) d.On("GetSwarmPorts").Return([]string{"aaaabbbb_node1", "aaaabbbb_node2"}, []uint16{8080, 9090}, nil)
e.M.On("Emit", CheckSwarmPortsEvent, "aaaabbbbcccc", []interface{}{DockerSwarmPorts{Manager: i.Name, Instances: []string{i.Name, "aaaabbbb_node2"}, Ports: []int{8080, 9090}}}).Return() e.M.On("Emit", CheckSwarmPortsEvent, "aaaabbbbcccc", []interface{}{ClusterPorts{Manager: i.Name, Instances: []string{i.Name, "aaaabbbb_node2"}, Ports: []int{8080, 9090}}}).Return()
task := NewCheckSwarmPorts(e, f) task := NewCheckSwarmPorts(e, f)
ctx := context.Background() ctx := context.Background()

8
scheduler/task/check_swarm_status_test.go
View File

@@ -41,7 +41,7 @@ func TestCheckSwarmStatus_RunWhenInactive(t *testing.T) {
f.On("GetForInstance", i).Return(d, nil) f.On("GetForInstance", i).Return(d, nil)
d.On("GetDaemonInfo").Return(infoInactive, nil) d.On("GetDaemonInfo").Return(infoInactive, nil)
e.M.On("Emit", CheckSwarmStatusEvent, "aaabbbccc", []interface{}{DockerSwarmStatus{IsManager: false, IsWorker: false, Instance: "node1"}}).Return() e.M.On("Emit", CheckSwarmStatusEvent, "aaabbbccc", []interface{}{ClusterStatus{IsManager: false, IsWorker: false, Instance: "node1"}}).Return()
task := NewCheckSwarmStatus(e, f) task := NewCheckSwarmStatus(e, f)
ctx := context.Background() ctx := context.Background()
@@ -72,7 +72,7 @@ func TestCheckSwarmStatus_RunWhenLocked(t *testing.T) {
f.On("GetForInstance", i).Return(d, nil) f.On("GetForInstance", i).Return(d, nil)
d.On("GetDaemonInfo").Return(infoLocked, nil) d.On("GetDaemonInfo").Return(infoLocked, nil)
e.M.On("Emit", CheckSwarmStatusEvent, "aaabbbccc", []interface{}{DockerSwarmStatus{IsManager: false, IsWorker: false, Instance: "node1"}}).Return() e.M.On("Emit", CheckSwarmStatusEvent, "aaabbbccc", []interface{}{ClusterStatus{IsManager: false, IsWorker: false, Instance: "node1"}}).Return()
task := NewCheckSwarmStatus(e, f) task := NewCheckSwarmStatus(e, f)
ctx := context.Background() ctx := context.Background()
@@ -104,7 +104,7 @@ func TestCheckSwarmStatus_RunWhenManager(t *testing.T) {
f.On("GetForInstance", i).Return(d, nil) f.On("GetForInstance", i).Return(d, nil)
d.On("GetDaemonInfo").Return(infoLocked, nil) d.On("GetDaemonInfo").Return(infoLocked, nil)
e.M.On("Emit", CheckSwarmStatusEvent, "aaabbbccc", []interface{}{DockerSwarmStatus{IsManager: true, IsWorker: false, Instance: "node1"}}).Return() e.M.On("Emit", CheckSwarmStatusEvent, "aaabbbccc", []interface{}{ClusterStatus{IsManager: true, IsWorker: false, Instance: "node1"}}).Return()
task := NewCheckSwarmStatus(e, f) task := NewCheckSwarmStatus(e, f)
ctx := context.Background() ctx := context.Background()
@@ -136,7 +136,7 @@ func TestCheckSwarmStatus_RunWhenWorker(t *testing.T) {
f.On("GetForInstance", i).Return(d, nil) f.On("GetForInstance", i).Return(d, nil)
d.On("GetDaemonInfo").Return(infoLocked, nil) d.On("GetDaemonInfo").Return(infoLocked, nil)
e.M.On("Emit", CheckSwarmStatusEvent, "aaabbbccc", []interface{}{DockerSwarmStatus{IsManager: false, IsWorker: true, Instance: "node1"}}).Return() e.M.On("Emit", CheckSwarmStatusEvent, "aaabbbccc", []interface{}{ClusterStatus{IsManager: false, IsWorker: true, Instance: "node1"}}).Return()
task := NewCheckSwarmStatus(e, f) task := NewCheckSwarmStatus(e, f)
ctx := context.Background() ctx := context.Background()