blob: 478d3227a118d7fef28bfda301b8f51074746919 (
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
|
package informer
import (
"github.com/spiral/roadrunner/v2/pkg/state/job"
"github.com/spiral/roadrunner/v2/pkg/state/process"
)
type rpc struct {
srv *Plugin
}
// WorkerList contains list of workers.
type WorkerList struct {
// Workers are list of workers.
Workers []*process.State `json:"workers"`
}
// List all resettable services.
func (rpc *rpc) List(_ bool, list *[]string) error {
*list = make([]string, 0, len(rpc.srv.withWorkers))
// append all plugin names to the output result
for name := range rpc.srv.available {
*list = append(*list, name)
}
return nil
}
// Workers state of a given service.
func (rpc *rpc) Workers(service string, list *WorkerList) error {
workers := rpc.srv.Workers(service)
if workers == nil {
return nil
}
// write actual processes
list.Workers = workers
return nil
}
func (rpc *rpc) Jobs(service string, out *[]*job.State) error {
*out = rpc.srv.Jobs(service)
return nil
}
// sort.Sort
func (w *WorkerList) Len() int {
return len(w.Workers)
}
func (w *WorkerList) Less(i, j int) bool {
return w.Workers[i].Pid < w.Workers[j].Pid
}
func (w *WorkerList) Swap(i, j int) {
w.Workers[i], w.Workers[j] = w.Workers[j], w.Workers[i]
}
|
