From 232aa8f3c20a060e556ab431467f4f7b3f83bfbf Mon Sep 17 00:00:00 2001
From: Wolfy-J <wolfy.jd@gmail.com>
Date: Sun, 10 Jun 2018 17:06:06 +0300
Subject: http service

---
 service/http/rpc.go | 78 -----------------------------------------------------
 1 file changed, 78 deletions(-)
 delete mode 100644 service/http/rpc.go

(limited to 'service/http/rpc.go')

diff --git a/service/http/rpc.go b/service/http/rpc.go
deleted file mode 100644
index 673ff2bb..00000000
--- a/service/http/rpc.go
+++ /dev/null
@@ -1,78 +0,0 @@
-package http
-
-import (
-	"github.com/sirupsen/logrus"
-	"github.com/spiral/roadrunner/_____/utils"
-	"github.com/pkg/errors"
-)
-
-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
-}
\ No newline at end of file
-- 
cgit v1.2.3