summaryrefslogtreecommitdiff
path: root/service/http/rpc.go
diff options
context:
space:
mode:
authorWolfy-J <[email protected]>2018-06-13 22:29:28 +0300
committerWolfy-J <[email protected]>2018-06-13 22:29:28 +0300
commit72562187f3802bd0910d6ba0ac73cd1819e5cc19 (patch)
treeb332a1f091aacd58099d858d7d14a819a08d2de5 /service/http/rpc.go
parentaf6869588e3128b502d308fc630f9853db2ec24b (diff)
more tests + rpc tests
Diffstat (limited to 'service/http/rpc.go')
-rw-r--r--service/http/rpc.go12
1 files changed, 0 insertions, 12 deletions
diff --git a/service/http/rpc.go b/service/http/rpc.go
index aebc5903..38aea2cf 100644
--- a/service/http/rpc.go
+++ b/service/http/rpc.go
@@ -1,9 +1,5 @@
package http
-import (
- "github.com/pkg/errors"
-)
-
type rpcServer struct{ svc *Service }
// WorkerList contains list of workers.
@@ -29,20 +25,12 @@ type Worker struct {
// Reset resets underlying RR worker pool and restarts all of it's workers.
func (rpc *rpcServer) Reset(reset bool, r *string) error {
- if rpc.svc.srv == nil {
- return errors.New("http server is not running")
- }
-
*r = "OK"
return rpc.svc.rr.Reset()
}
// Workers returns list of active workers and their stats.
func (rpc *rpcServer) Workers(list bool, r *WorkerList) error {
- if rpc.svc.srv == nil {
- return errors.New("http server is not running")
- }
-
for _, w := range rpc.svc.rr.Workers() {
state := w.State()
r.Workers = append(r.Workers, Worker{