summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorWolfy-J <[email protected]>2018-06-03 13:10:20 +0300
committerWolfy-J <[email protected]>2018-06-03 13:10:20 +0300
commit6f805059d5eff80ad89ed8b2abc50bdd52fb3e4b (patch)
treee93be59249d7939e5a4f33eaa5a0fffd72cb055c
parentf363040a9a72d53b4d5f0ffbf40773a27e9bd98f (diff)
CS
-rw-r--r--http/rpc.go6
-rw-r--r--http/service.go2
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 {