@@ -34,14 +34,14 @@ |
||
34 | 34 | use EventsTrait; |
35 | 35 | |
36 | 36 | /** |
37 | - * Class constructor |
|
38 | - * |
|
39 | - * @param Configuration $configuration |
|
40 | - * @param LoggerInterface $logger |
|
41 | - * @param TasksTable $tasks |
|
42 | - * @param EventsManager $events |
|
43 | - * @param EntityManager $em |
|
44 | - */ |
|
37 | + * Class constructor |
|
38 | + * |
|
39 | + * @param Configuration $configuration |
|
40 | + * @param LoggerInterface $logger |
|
41 | + * @param TasksTable $tasks |
|
42 | + * @param EventsManager $events |
|
43 | + * @param EntityManager $em |
|
44 | + */ |
|
45 | 45 | public function __construct( |
46 | 46 | Configuration $configuration, |
47 | 47 | LoggerInterface $logger, |
@@ -32,8 +32,8 @@ discard block |
||
32 | 32 | $mmanager->add( |
33 | 33 | RpcMethod::create( |
34 | 34 | "scheduler.refresh", |
35 | - 'Comodojo\Extender\Socket\Commands\Scheduler\Refresh::execute', |
|
36 | - $daemon) |
|
35 | + 'Comodojo\Extender\Socket\Commands\Scheduler\Refresh::execute', |
|
36 | + $daemon) |
|
37 | 37 | ->setDescription("Refresh current scheduler's schedule") |
38 | 38 | ->setReturnType('boolean') |
39 | 39 | ); |
@@ -41,8 +41,8 @@ discard block |
||
41 | 41 | $mmanager->add( |
42 | 42 | RpcMethod::create( |
43 | 43 | "scheduler.info", |
44 | - 'Comodojo\Extender\Socket\Commands\Scheduler\Info::execute', |
|
45 | - $daemon) |
|
44 | + 'Comodojo\Extender\Socket\Commands\Scheduler\Info::execute', |
|
45 | + $daemon) |
|
46 | 46 | ->setDescription("Refresh current scheduler status") |
47 | 47 | ->setReturnType('array') |
48 | 48 | ); |
@@ -50,8 +50,8 @@ discard block |
||
50 | 50 | $mmanager->add( |
51 | 51 | RpcMethod::create( |
52 | 52 | "scheduler.add", |
53 | - 'Comodojo\Extender\Socket\Commands\Scheduler\Add::execute', |
|
54 | - $daemon) |
|
53 | + 'Comodojo\Extender\Socket\Commands\Scheduler\Add::execute', |
|
54 | + $daemon) |
|
55 | 55 | ->setDescription("Set new schedule") |
56 | 56 | ->addParameter('struct', 'schedule') |
57 | 57 | ->addParameter('struct', 'request') |
@@ -61,8 +61,8 @@ discard block |
||
61 | 61 | $mmanager->add( |
62 | 62 | RpcMethod::create( |
63 | 63 | "scheduler.list", |
64 | - 'Comodojo\Extender\Socket\Commands\Scheduler\GetList::execute', |
|
65 | - $daemon) |
|
64 | + 'Comodojo\Extender\Socket\Commands\Scheduler\GetList::execute', |
|
65 | + $daemon) |
|
66 | 66 | ->setDescription("List all installed schedules") |
67 | 67 | ->setReturnType('array') |
68 | 68 | ); |
@@ -70,8 +70,8 @@ discard block |
||
70 | 70 | $mmanager->add( |
71 | 71 | RpcMethod::create( |
72 | 72 | "scheduler.get", |
73 | - 'Comodojo\Extender\Socket\Commands\Scheduler\Get::execute', |
|
74 | - $daemon) |
|
73 | + 'Comodojo\Extender\Socket\Commands\Scheduler\Get::execute', |
|
74 | + $daemon) |
|
75 | 75 | ->setDescription("Get a schedule and related task request by id (int) or name (string)") |
76 | 76 | ->addParameter('int', 'id') |
77 | 77 | ->setReturnType('array') |
@@ -83,8 +83,8 @@ discard block |
||
83 | 83 | $mmanager->add( |
84 | 84 | RpcMethod::create( |
85 | 85 | "scheduler.edit", |
86 | - 'Comodojo\Extender\Socket\Commands\Scheduler\Edit::execute', |
|
87 | - $daemon) |
|
86 | + 'Comodojo\Extender\Socket\Commands\Scheduler\Edit::execute', |
|
87 | + $daemon) |
|
88 | 88 | ->setDescription("Edit a schedule") |
89 | 89 | ->addParameter('struct', 'schedule') |
90 | 90 | ->addParameter('struct', 'request') |
@@ -94,8 +94,8 @@ discard block |
||
94 | 94 | $mmanager->add( |
95 | 95 | RpcMethod::create( |
96 | 96 | "scheduler.disable", |
97 | - 'Comodojo\Extender\Socket\Commands\Scheduler\Disable::execute', |
|
98 | - $daemon) |
|
97 | + 'Comodojo\Extender\Socket\Commands\Scheduler\Disable::execute', |
|
98 | + $daemon) |
|
99 | 99 | ->setDescription("Disable a schedule by id (int) or name (string)") |
100 | 100 | ->addParameter('int', 'id') |
101 | 101 | ->setReturnType('boolean') |
@@ -107,8 +107,8 @@ discard block |
||
107 | 107 | $mmanager->add( |
108 | 108 | RpcMethod::create( |
109 | 109 | "scheduler.enable", |
110 | - 'Comodojo\Extender\Socket\Commands\Scheduler\Enable::execute', |
|
111 | - $daemon) |
|
110 | + 'Comodojo\Extender\Socket\Commands\Scheduler\Enable::execute', |
|
111 | + $daemon) |
|
112 | 112 | ->setDescription("Enable a schedule by id (int) or name (string)") |
113 | 113 | ->addParameter('int', 'id') |
114 | 114 | ->setReturnType('boolean') |
@@ -120,8 +120,8 @@ discard block |
||
120 | 120 | $mmanager->add( |
121 | 121 | RpcMethod::create( |
122 | 122 | "scheduler.remove", |
123 | - 'Comodojo\Extender\Socket\Commands\Scheduler\Remove::execute', |
|
124 | - $daemon) |
|
123 | + 'Comodojo\Extender\Socket\Commands\Scheduler\Remove::execute', |
|
124 | + $daemon) |
|
125 | 125 | ->setDescription("Remove a schedule by id (int) or name (string)") |
126 | 126 | ->addParameter('int', 'id') |
127 | 127 | ->setReturnType('boolean') |
@@ -137,8 +137,8 @@ discard block |
||
137 | 137 | $mmanager->add( |
138 | 138 | RpcMethod::create( |
139 | 139 | "queue.info", |
140 | - 'Comodojo\Extender\Socket\Commands\Queue\Info::execute', |
|
141 | - $daemon) |
|
140 | + 'Comodojo\Extender\Socket\Commands\Queue\Info::execute', |
|
141 | + $daemon) |
|
142 | 142 | ->setDescription("Get current queue status") |
143 | 143 | ->setReturnType('array') |
144 | 144 | ); |
@@ -146,8 +146,8 @@ discard block |
||
146 | 146 | $mmanager->add( |
147 | 147 | RpcMethod::create( |
148 | 148 | "queue.add", |
149 | - 'Comodojo\Extender\Socket\Commands\Queue\Add::execute', |
|
150 | - $daemon) |
|
149 | + 'Comodojo\Extender\Socket\Commands\Queue\Add::execute', |
|
150 | + $daemon) |
|
151 | 151 | ->setDescription("Push new request to queue") |
152 | 152 | ->addParameter('struct', 'request') |
153 | 153 | ->setReturnType('string') |
@@ -156,8 +156,8 @@ discard block |
||
156 | 156 | $mmanager->add( |
157 | 157 | RpcMethod::create( |
158 | 158 | "queue.addBulk", |
159 | - 'Comodojo\Extender\Socket\Commands\Queue\AddBulk::execute', |
|
160 | - $daemon) |
|
159 | + 'Comodojo\Extender\Socket\Commands\Queue\AddBulk::execute', |
|
160 | + $daemon) |
|
161 | 161 | ->setDescription("Push new requests to queue") |
162 | 162 | ->addParameter('array', 'requests') |
163 | 163 | ->setReturnType('array') |
@@ -170,8 +170,8 @@ discard block |
||
170 | 170 | $mmanager->add( |
171 | 171 | RpcMethod::create( |
172 | 172 | "worklog.count", |
173 | - 'Comodojo\Extender\Socket\Commands\Worklog\Count::execute', |
|
174 | - $daemon) |
|
173 | + 'Comodojo\Extender\Socket\Commands\Worklog\Count::execute', |
|
174 | + $daemon) |
|
175 | 175 | ->setDescription("Count recorded worklogs") |
176 | 176 | ->setReturnType('int') |
177 | 177 | ); |
@@ -179,8 +179,8 @@ discard block |
||
179 | 179 | $mmanager->add( |
180 | 180 | RpcMethod::create( |
181 | 181 | "worklog.list", |
182 | - 'Comodojo\Extender\Socket\Commands\Worklog\GetList::execute', |
|
183 | - $daemon) |
|
182 | + 'Comodojo\Extender\Socket\Commands\Worklog\GetList::execute', |
|
183 | + $daemon) |
|
184 | 184 | ->setDescription("Get a list of worklog according to (optional) filter") |
185 | 185 | ->setReturnType('array') |
186 | 186 | ->addSignature() |
@@ -191,8 +191,8 @@ discard block |
||
191 | 191 | $mmanager->add( |
192 | 192 | RpcMethod::create( |
193 | 193 | "worklog.byId", |
194 | - 'Comodojo\Extender\Socket\Commands\Worklog\ById::execute', |
|
195 | - $daemon) |
|
194 | + 'Comodojo\Extender\Socket\Commands\Worklog\ById::execute', |
|
195 | + $daemon) |
|
196 | 196 | ->setDescription("Get a worklog from id") |
197 | 197 | ->addParameter('int', 'id') |
198 | 198 | ->setReturnType('struct') |
@@ -201,8 +201,8 @@ discard block |
||
201 | 201 | $mmanager->add( |
202 | 202 | RpcMethod::create( |
203 | 203 | "worklog.byUid", |
204 | - 'Comodojo\Extender\Socket\Commands\Worklog\ByUid::execute', |
|
205 | - $daemon) |
|
204 | + 'Comodojo\Extender\Socket\Commands\Worklog\ByUid::execute', |
|
205 | + $daemon) |
|
206 | 206 | ->setDescription("Get a worklog from uid") |
207 | 207 | ->addParameter('string', 'uid') |
208 | 208 | ->setReturnType('struct') |
@@ -211,8 +211,8 @@ discard block |
||
211 | 211 | $mmanager->add( |
212 | 212 | RpcMethod::create( |
213 | 213 | "worklog.byJid", |
214 | - 'Comodojo\Extender\Socket\Commands\Worklog\ByJid::execute', |
|
215 | - $daemon) |
|
214 | + 'Comodojo\Extender\Socket\Commands\Worklog\ByJid::execute', |
|
215 | + $daemon) |
|
216 | 216 | ->setDescription("Get a list of worklog from job id according to (optional) filter") |
217 | 217 | ->addParameter('int', 'jid') |
218 | 218 | ->setReturnType('array') |
@@ -225,8 +225,8 @@ discard block |
||
225 | 225 | $mmanager->add( |
226 | 226 | RpcMethod::create( |
227 | 227 | "worklog.byPid", |
228 | - 'Comodojo\Extender\Socket\Commands\Worklog\ByPid::execute', |
|
229 | - $daemon) |
|
228 | + 'Comodojo\Extender\Socket\Commands\Worklog\ByPid::execute', |
|
229 | + $daemon) |
|
230 | 230 | ->setDescription("Get a list of worklog from system pid according to (optional) filter") |
231 | 231 | ->addParameter('int', 'pid') |
232 | 232 | ->setReturnType('array') |