blob: 3925ef640d20cbaa85e931268722110b1c1f7254 (
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
|
package informer
import (
"github.com/spiral/roadrunner/v2/pkg/process"
)
type rpc struct {
srv *Plugin
}
// WorkerList contains list of workers.
type WorkerList struct {
// Workers is 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 {
list = nil
return nil
}
// write actual processes
list.Workers = workers
return nil
}
|
