summaryrefslogtreecommitdiff
path: root/controller_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'controller_test.go')
-rw-r--r--controller_test.go10
1 files changed, 5 insertions, 5 deletions
diff --git a/controller_test.go b/controller_test.go
index 031c2f31..d177feda 100644
--- a/controller_test.go
+++ b/controller_test.go
@@ -47,7 +47,7 @@ func Test_WatcherWatch(t *testing.T) {
})
defer rr.Stop()
- rr.Watch(&eWatcher{})
+ rr.Attach(&eWatcher{})
assert.NoError(t, rr.Start())
assert.NotNil(t, rr.pController)
@@ -76,7 +76,7 @@ func Test_WatcherReattach(t *testing.T) {
})
defer rr.Stop()
- rr.Watch(&eWatcher{})
+ rr.Attach(&eWatcher{})
assert.NoError(t, rr.Start())
assert.NotNil(t, rr.pController)
@@ -115,7 +115,7 @@ func Test_WatcherAttachDetachSequence(t *testing.T) {
var attachedPool Pool
- rr.Watch(&eWatcher{
+ rr.Attach(&eWatcher{
onAttach: func(p Pool) {
attachedPool = p
},
@@ -151,7 +151,7 @@ func Test_RemoveWorkerOnAllocation(t *testing.T) {
})
defer rr.Stop()
- rr.Watch(&eWatcher{})
+ rr.Attach(&eWatcher{})
assert.NoError(t, rr.Start())
wr := rr.Workers()[0]
@@ -186,7 +186,7 @@ func Test_RemoveWorkerAfterTask(t *testing.T) {
})
defer rr.Stop()
- rr.Watch(&eWatcher{})
+ rr.Attach(&eWatcher{})
assert.NoError(t, rr.Start())
wr := rr.Workers()[0]