diff options
author | Wolfy-J <[email protected]> | 2018-06-03 13:10:20 +0300 |
---|---|---|
committer | Wolfy-J <[email protected]> | 2018-06-03 13:10:20 +0300 |
commit | 6f805059d5eff80ad89ed8b2abc50bdd52fb3e4b (patch) | |
tree | e93be59249d7939e5a4f33eaa5a0fffd72cb055c | |
parent | f363040a9a72d53b4d5f0ffbf40773a27e9bd98f (diff) |
CS
-rw-r--r-- | http/rpc.go | 6 | ||||
-rw-r--r-- | http/service.go | 2 |
2 files changed, 4 insertions, 4 deletions
diff --git a/http/rpc.go b/http/rpc.go index c096ff77..c065432c 100644 --- a/http/rpc.go +++ b/http/rpc.go @@ -4,7 +4,7 @@ import ( "github.com/sirupsen/logrus" ) -type RPCServer struct { +type rpcServer struct { Service *Service } @@ -33,7 +33,7 @@ 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 { +func (rpc *rpcServer) Reset(reset bool, r *string) error { logrus.Info("resetting worker pool") *r = "OK" @@ -41,7 +41,7 @@ func (rpc *RPCServer) Reset(reset bool, r *string) error { } // Workers returns list of active workers and their stats. -func (rpc *RPCServer) Workers(list bool, r *WorkerList) error { +func (rpc *rpcServer) Workers(list bool, r *WorkerList) error { for _, w := range rpc.Service.srv.rr.Workers() { state := w.State() r.Workers = append(r.Workers, Worker{ diff --git a/http/service.go b/http/service.go index 7f4261d0..554b79e3 100644 --- a/http/service.go +++ b/http/service.go @@ -36,7 +36,7 @@ func (s *Service) Configure(cfg service.Config) (bool, error) { } func (s *Service) RPC() interface{} { - return &RPCServer{s} + return &rpcServer{s} } func (s *Service) Serve() error { |