1 files changed, 59 insertions, 71 deletions
diff --git a/http/rpc.go b/http/rpc.go
index d9f911f4..2e33aad7 100644
--- a/http/rpc.go
+++ b/http/rpc.go
@@ -1,73 +1,61 @@
 package http
 
-//
-//type rpcServer struct {
-//	service *Service
-//}
-//
-//// WorkerList contains list of workers.
-//type WorkerList struct {
-//	// Workers is list of workers.
-//	Workers []utils.Worker `json:"workers"`
-//}
-//
-//// Reset resets underlying RR worker pool and restarts all of it's workers.
-//func (rpc *rpcServer) Reset(reset bool, r *string) error {
-//	if rpc.service.srv == nil {
-//		return errors.New("no http server")
-//	}
-//
-//	logrus.Info("http: restarting worker pool")
-//	*r = "OK"
-//
-//	err := rpc.service.srv.rr.Reset()
-//	if err != nil {
-//		logrus.Errorf("http: %s", err)
-//	}
-//
-//	return err
-//}
-//
-//// Workers returns list of active workers and their stats.
-//func (rpc *rpcServer) Workers(list bool, r *WorkerList) error {
-//	if rpc.service.srv == nil {
-//		return errors.New("no http server")
-//	}
-//
-//	r.Workers = utils.FetchWorkers(rpc.service.srv.rr)
-//	return nil
-//}
-//
-//// Worker provides information about specific worker.
-//type Worker struct {
-//	// Pid contains process id.
-//	Pid int `json:"pid"`
-//
-//	// Status of the worker.
-//	Status string `json:"status"`
-//
-//	// Number of worker executions.
-//	NumExecs uint64 `json:"numExecs"`
-//
-//	// Created is unix nano timestamp of worker creation time.
-//	Created int64 `json:"created"`
-//
-//	// Updated is unix nano timestamp of last worker execution.
-//	Updated int64 `json:"updated"`
-//}
-//
-//// FetchWorkers fetches list of workers from RR Server.
-//func FetchWorkers(srv *roadrunner.Server) (result []Worker) {
-//	for _, w := range srv.Workers() {
-//		state := w.State()
-//		result = append(result, Worker{
-//			Pid:      *w.Pid,
-//			Status:   state.String(),
-//			NumExecs: state.NumExecs(),
-//			Created:  w.Created.UnixNano(),
-//			Updated:  state.Updated().UnixNano(),
-//		})
-//	}
-//
-//	return
-//}
+import (
+	"github.com/pkg/errors"
+)
+
+type rpcServer struct{ svc *Service }
+
+// WorkerList contains list of workers.
+type WorkerList struct {
+	// Workers is list of workers.
+	Workers []Worker `json:"workers"`
+}
+
+// Worker provides information about specific worker.
+type Worker struct {
+	// Pid contains process id.
+	Pid int `json:"pid"`
+
+	// Status of the worker.
+	Status string `json:"status"`
+
+	// Number of worker executions.
+	NumJobs uint64 `json:"numExecs"`
+
+	// Created is unix nano timestamp of worker creation time.
+	Created int64 `json:"created"`
+
+	// Updated is unix nano timestamp of last worker execution.
+	Updated int64 `json:"updated"`
+}
+
+// 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.srv.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{
+			Pid:     *w.Pid,
+			Status:  state.String(),
+			NumJobs: state.NumExecs(),
+			Created: w.Created.UnixNano(),
+			Updated: state.Updated().UnixNano(),
+		})
+	}
+
+	return nil
+}