1 files changed, 73 insertions, 0 deletions
diff --git a/http/rpc.go b/http/rpc.go
new file mode 100644
index 00000000..d9f911f4
--- /dev/null
+++ b/http/rpc.go
@@ -0,0 +1,73 @@
+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
+//}