Code Coverage |
||||||||||
Lines |
Functions and Methods |
Classes and Traits |
||||||||
Total | n/a |
0 / 0 |
n/a |
0 / 0 |
CRAP | n/a |
0 / 0 |
|||
AbstractAdapter | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | n/a |
0 / 0 |
|||
hasJob | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
getJob | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
updateJob | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
hasJobs | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
getJobs | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
hasCompletedJob | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
hasCompletedJobs | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
getCompletedJob | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
getCompletedJobs | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
hasFailedJob | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
getFailedJob | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
hasFailedJobs | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
getFailedJobs | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
push | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
failed | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
pop | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
clear | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
clearFailed | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
flush | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
flushFailed | n/a |
0 / 0 |
n/a |
0 / 0 |
0 | |||||
flushAll | n/a |
0 / 0 |
n/a |
0 / 0 |
0 |
1 | <?php |
2 | /** |
3 | * Pop PHP Framework (http://www.popphp.org/) |
4 | * |
5 | * @link https://github.com/popphp/popphp-framework |
6 | * @author Nick Sagona, III <dev@nolainteractive.com> |
7 | * @copyright Copyright (c) 2009-2023 NOLA Interactive, LLC. (http://www.nolainteractive.com) |
8 | * @license http://www.popphp.org/license New BSD License |
9 | */ |
10 | |
11 | /** |
12 | * @namespace |
13 | */ |
14 | namespace Pop\Queue\Adapter; |
15 | |
16 | use Pop\Queue\Processor\Jobs\AbstractJob; |
17 | use Pop\Queue\Queue; |
18 | |
19 | /** |
20 | * Queue adapter abstract class |
21 | * |
22 | * @category Pop |
23 | * @package Pop\Queue |
24 | * @author Nick Sagona, III <dev@nolainteractive.com> |
25 | * @copyright Copyright (c) 2009-2023 NOLA Interactive, LLC. (http://www.nolainteractive.com) |
26 | * @license http://www.popphp.org/license New BSD License |
27 | * @version 1.2.0 |
28 | */ |
29 | abstract class AbstractAdapter implements AdapterInterface |
30 | { |
31 | |
32 | /** |
33 | * Check if queue stack has job |
34 | * |
35 | * @param mixed $jobId |
36 | * @return boolean |
37 | */ |
38 | abstract public function hasJob($jobId); |
39 | |
40 | /** |
41 | * Get job from queue stack by job ID |
42 | * |
43 | * @param mixed $jobId |
44 | * @param boolean $unserialize |
45 | * @return array |
46 | */ |
47 | abstract public function getJob($jobId, $unserialize = true); |
48 | |
49 | /** |
50 | * Update job from queue stack by job ID |
51 | * |
52 | * @param mixed $jobId |
53 | * @param mixed $completed |
54 | * @param mixed $increment |
55 | * @return void |
56 | */ |
57 | abstract public function updateJob($jobId, $completed = false, $increment = false); |
58 | |
59 | /** |
60 | * Check if queue adapter has jobs |
61 | * |
62 | * @param mixed $queue |
63 | * @return boolean |
64 | */ |
65 | abstract public function hasJobs($queue); |
66 | |
67 | /** |
68 | * Get queue jobs |
69 | * |
70 | * @param mixed $queue |
71 | * @param boolean $unserialize |
72 | * @return array |
73 | */ |
74 | abstract public function getJobs($queue, $unserialize = true); |
75 | |
76 | /** |
77 | * Check if queue stack has completed job |
78 | * |
79 | * @param mixed $jobId |
80 | * @return boolean |
81 | */ |
82 | abstract public function hasCompletedJob($jobId); |
83 | |
84 | /** |
85 | * Check if queue adapter has completed jobs |
86 | * |
87 | * @param mixed $queue |
88 | * @return boolean |
89 | */ |
90 | abstract public function hasCompletedJobs($queue); |
91 | |
92 | /** |
93 | * Get queue completed job |
94 | * |
95 | * @param mixed $jobId |
96 | * @param boolean $unserialize |
97 | * @return array |
98 | */ |
99 | abstract public function getCompletedJob($jobId, $unserialize = true); |
100 | |
101 | /** |
102 | * Get queue completed jobs |
103 | * |
104 | * @param mixed $queue |
105 | * @param boolean $unserialize |
106 | * @return array |
107 | */ |
108 | abstract public function getCompletedJobs($queue, $unserialize = true); |
109 | |
110 | /** |
111 | * Check if queue stack has failed job |
112 | * |
113 | * @param mixed $jobId |
114 | * @return boolean |
115 | */ |
116 | abstract public function hasFailedJob($jobId); |
117 | |
118 | /** |
119 | * Get failed job from queue stack by job ID |
120 | * |
121 | * @param mixed $jobId |
122 | * @param boolean $unserialize |
123 | * @return array |
124 | */ |
125 | abstract public function getFailedJob($jobId, $unserialize = true); |
126 | |
127 | /** |
128 | * Check if queue adapter has failed jobs |
129 | * |
130 | * @param mixed $queue |
131 | * @return boolean |
132 | */ |
133 | abstract public function hasFailedJobs($queue); |
134 | |
135 | /** |
136 | * Get queue failed jobs |
137 | * |
138 | * @param mixed $queue |
139 | * @param boolean $unserialize |
140 | * @return array |
141 | */ |
142 | abstract public function getFailedJobs($queue, $unserialize = true); |
143 | |
144 | /** |
145 | * Push job onto queue stack |
146 | * |
147 | * @param mixed $queue |
148 | * @param mixed $job |
149 | * @param mixed $priority |
150 | * @return string |
151 | */ |
152 | abstract public function push($queue, $job, $priority = null); |
153 | |
154 | /** |
155 | * Move failed job to failed queue stack |
156 | * |
157 | * @param mixed $queue |
158 | * @param mixed $failedJob |
159 | * @param \Exception $exception |
160 | * @return void |
161 | */ |
162 | abstract public function failed($queue, $failedJob, \Exception $exception = null); |
163 | |
164 | /** |
165 | * Pop job off of queue stack |
166 | * |
167 | * @param mixed $jobId |
168 | * @return void |
169 | */ |
170 | abstract public function pop($jobId); |
171 | |
172 | /** |
173 | * Clear completed jobs off of the queue stack |
174 | * |
175 | * @param mixed $queue |
176 | * @param boolean $all |
177 | * @return void |
178 | */ |
179 | abstract public function clear($queue, $all = false); |
180 | |
181 | /** |
182 | * Clear failed jobs off of the queue stack |
183 | * |
184 | * @param mixed $queue |
185 | * @return void |
186 | */ |
187 | abstract public function clearFailed($queue); |
188 | |
189 | /** |
190 | * Flush all jobs off of the queue stack |
191 | * |
192 | * @param boolean $all |
193 | * @return void |
194 | */ |
195 | abstract public function flush($all = false); |
196 | |
197 | /** |
198 | * Flush all failed jobs off of the queue stack |
199 | * |
200 | * @return void |
201 | */ |
202 | abstract public function flushFailed(); |
203 | |
204 | /** |
205 | * Flush all pop queue items |
206 | * |
207 | * @return void |
208 | */ |
209 | abstract public function flushAll(); |
210 | |
211 | } |