summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorWolfy-J <[email protected]>2019-05-03 12:31:37 +0300
committerWolfy-J <[email protected]>2019-05-03 12:31:37 +0300
commit38847dd5152a61e18ebf52613d00c9aea095b28f (patch)
tree82ad30ac887eb8a4c3bb87aae30b69b89cd705e4
parent3454c00ac37a141d7bb8db6990d90606f1bb14b3 (diff)
added pool watcher capability
-rw-r--r--service/rpc/service_test.go2
-rw-r--r--service/watcher/watcher.go8
2 files changed, 9 insertions, 1 deletions
diff --git a/service/rpc/service_test.go b/service/rpc/service_test.go
index 41233070..ee87509a 100644
--- a/service/rpc/service_test.go
+++ b/service/rpc/service_test.go
@@ -14,7 +14,7 @@ func (ts *testService) Echo(msg string, r *string) error { *r = msg; return nil
func Test_Disabled(t *testing.T) {
s := &Service{}
- ok, err := s.Init(&Config{Enable: false}, nil)
+ ok, err := s.Init(&Config{Enable: false}, service.NewContainer(nil), nil)
assert.NoError(t, err)
assert.False(t, ok)
diff --git a/service/watcher/watcher.go b/service/watcher/watcher.go
index 8278790e..9d770135 100644
--- a/service/watcher/watcher.go
+++ b/service/watcher/watcher.go
@@ -1 +1,9 @@
package watcher
+
+import "github.com/spiral/roadrunner"
+
+// Server defines the ability to get access to underlying roadrunner server for watching capabilities.
+type Server interface {
+ // Server must return associated roadrunner serve.
+ Server() *roadrunner.Server
+}