blob: d9f911f4ab29d6da8902b206fadfacbdf20d94c4 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
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
//}
|
