|
1
|
|
|
<?php |
|
2
|
|
|
/** |
|
3
|
|
|
* @package: chapi |
|
4
|
|
|
* |
|
5
|
|
|
* @author: bthapaliya |
|
6
|
|
|
* @since: 2016-10-16 |
|
7
|
|
|
* |
|
8
|
|
|
*/ |
|
9
|
|
|
|
|
10
|
|
|
namespace Chapi\Entity\Marathon; |
|
11
|
|
|
|
|
12
|
|
|
use Chapi\Entity\JobEntityInterface; |
|
13
|
|
|
use Chapi\Entity\Marathon\AppEntity\Container; |
|
14
|
|
|
use Chapi\Entity\Marathon\AppEntity\DockerPortMapping; |
|
15
|
|
|
use Chapi\Entity\Marathon\AppEntity\HealthCheck; |
|
16
|
|
|
use Chapi\Entity\Marathon\AppEntity\IpAddress; |
|
17
|
|
|
use Chapi\Entity\Marathon\AppEntity\PortDefinition; |
|
18
|
|
|
use Chapi\Entity\Marathon\AppEntity\UpgradeStrategy; |
|
19
|
|
|
use Symfony\Component\Config\Definition\Exception\Exception; |
|
20
|
|
|
|
|
21
|
|
|
class MarathonAppEntity implements JobEntityInterface |
|
22
|
|
|
{ |
|
23
|
|
|
public $id = ''; |
|
24
|
|
|
|
|
25
|
|
|
public $cmd = null; |
|
26
|
|
|
|
|
27
|
|
|
public $cpus = 0; |
|
28
|
|
|
|
|
29
|
|
|
public $mem = 0; |
|
30
|
|
|
|
|
31
|
|
|
public $args = null; |
|
32
|
|
|
|
|
33
|
|
|
/** |
|
34
|
|
|
* @var PortDefinition[] |
|
35
|
|
|
*/ |
|
36
|
|
|
public $portDefinitions = null; |
|
37
|
|
|
|
|
38
|
|
|
public $requirePorts = false; |
|
39
|
|
|
|
|
40
|
|
|
public $instances = 0; |
|
41
|
|
|
|
|
42
|
|
|
public $executor = ''; |
|
43
|
|
|
|
|
44
|
|
|
/** |
|
45
|
|
|
* @var Container |
|
46
|
|
|
*/ |
|
47
|
|
|
public $container = null; |
|
48
|
|
|
|
|
49
|
|
|
public $env = null; |
|
50
|
|
|
|
|
51
|
|
|
/** |
|
52
|
|
|
* @var array |
|
53
|
|
|
*/ |
|
54
|
|
|
public $constraints = []; |
|
55
|
|
|
|
|
56
|
|
|
|
|
57
|
|
|
public $acceptedResourceRoles = null; |
|
58
|
|
|
|
|
59
|
|
|
public $labels = null; |
|
60
|
|
|
|
|
61
|
|
|
public $uris = []; |
|
62
|
|
|
|
|
63
|
|
|
public $dependencies = []; |
|
64
|
|
|
|
|
65
|
|
|
/** |
|
66
|
|
|
* @var HealthCheck[] |
|
67
|
|
|
*/ |
|
68
|
|
|
public $healthChecks = null; |
|
69
|
|
|
|
|
70
|
|
|
public $backoffSeconds = 1; |
|
71
|
|
|
|
|
72
|
|
|
public $backoffFactor = 1.15; |
|
73
|
|
|
|
|
74
|
|
|
public $maxLaunchDelaySeconds = 3600; |
|
75
|
|
|
|
|
76
|
|
|
public $taskKillGracePeriodSeconds = 0; |
|
77
|
|
|
|
|
78
|
|
|
/** |
|
79
|
|
|
* @var UpgradeStrategy |
|
80
|
|
|
*/ |
|
81
|
|
|
public $upgradeStrategy = null; |
|
82
|
|
|
|
|
83
|
|
|
|
|
84
|
|
|
/** |
|
85
|
|
|
* @var IpAddress |
|
86
|
|
|
*/ |
|
87
|
|
|
public $ipAddress = null; |
|
88
|
|
|
|
|
89
|
46 |
|
public function __construct($mData = null) |
|
90
|
|
|
{ |
|
91
|
46 |
|
if (!$mData) |
|
92
|
|
|
{ |
|
93
|
|
|
// initialized with default values |
|
94
|
34 |
|
return; |
|
95
|
|
|
} |
|
96
|
|
|
|
|
97
|
|
|
// make sure data is array |
|
98
|
18 |
|
$aData = (array) $mData; |
|
99
|
|
|
|
|
100
|
18 |
|
MarathonEntityUtils::setAllPossibleProperties($aData, $this); |
|
101
|
|
|
|
|
102
|
18 |
|
if (isset($aData['portDefinitions'])) |
|
103
|
|
|
{ |
|
104
|
|
|
foreach ($aData['portDefinitions'] as $portDefinition) |
|
105
|
|
|
{ |
|
106
|
|
|
$this->portDefinitions[] = new PortDefinition((array)$portDefinition); |
|
107
|
|
|
} |
|
108
|
|
|
} |
|
109
|
|
|
|
|
110
|
18 |
|
if (isset($aData['container'])) |
|
111
|
|
|
{ |
|
112
|
|
|
$this->container = new Container((array)$aData['container']); |
|
113
|
|
|
} |
|
114
|
|
|
|
|
115
|
18 |
|
if (isset($aData['healthChecks'])) |
|
116
|
|
|
{ |
|
117
|
|
|
foreach($aData['healthChecks'] as $healthCheck) |
|
118
|
|
|
{ |
|
119
|
|
|
$this->healthChecks[] = new HealthCheck((array)$healthCheck); |
|
120
|
|
|
} |
|
121
|
|
|
} |
|
122
|
|
|
|
|
123
|
18 |
|
if (isset($aData['upgradeStrategy'])) |
|
124
|
|
|
{ |
|
125
|
1 |
|
$this->upgradeStrategy = new UpgradeStrategy((array)$aData['upgradeStrategy']); |
|
126
|
|
|
} else { |
|
127
|
18 |
|
$this->upgradeStrategy = new UpgradeStrategy(); |
|
128
|
|
|
} |
|
129
|
|
|
|
|
130
|
18 |
|
if (isset($aData['ipAddress'])) |
|
131
|
|
|
{ |
|
132
|
|
|
$this->ipAddress = new IpAddress((array)$aData['ipAddress']); |
|
133
|
|
|
} |
|
134
|
|
|
|
|
135
|
18 |
View Code Duplication |
if (isset($aData['env'])) |
|
|
|
|
|
|
136
|
|
|
{ |
|
137
|
1 |
|
$this->env = (object) $aData['env']; |
|
138
|
|
|
} else { |
|
139
|
18 |
|
$this->env = (object)[]; |
|
140
|
|
|
} |
|
141
|
|
|
|
|
142
|
18 |
View Code Duplication |
if (isset($aData['labels'])) |
|
|
|
|
|
|
143
|
|
|
{ |
|
144
|
6 |
|
$this->labels = (object) $aData['labels']; |
|
145
|
|
|
} else { |
|
146
|
13 |
|
$this->labels = (object)[]; |
|
147
|
|
|
} |
|
148
|
18 |
|
MarathonEntityUtils::setPropertyIfExist($aData, $this, 'constraints'); |
|
149
|
18 |
|
MarathonEntityUtils::setPropertyIfExist($aData, $this, 'args'); |
|
150
|
18 |
|
MarathonEntityUtils::setPropertyIfExist($aData, $this, 'uris'); |
|
151
|
18 |
|
MarathonEntityUtils::setPropertyIfExist($aData, $this, 'acceptedResourceRoles'); |
|
152
|
18 |
|
MarathonEntityUtils::setPropertyIfExist($aData, $this, 'dependencies'); |
|
153
|
18 |
|
} |
|
154
|
|
|
|
|
155
|
|
|
/** |
|
156
|
|
|
* @inheritdoc |
|
157
|
|
|
* @return array |
|
158
|
|
|
*/ |
|
159
|
4 |
View Code Duplication |
public function jsonSerialize() |
|
|
|
|
|
|
160
|
|
|
{ |
|
161
|
4 |
|
$_aRet = (array) $this; |
|
162
|
4 |
|
$_aRet = array_filter($_aRet, function($v, $k) { |
|
|
|
|
|
|
163
|
4 |
|
return !is_null($v) || empty($v); |
|
164
|
4 |
|
}, ARRAY_FILTER_USE_BOTH ); |
|
165
|
4 |
|
return $_aRet; |
|
166
|
|
|
} |
|
167
|
|
|
|
|
168
|
|
|
/** |
|
169
|
|
|
* @inheritdoc |
|
170
|
|
|
* @return \ArrayIterator |
|
171
|
|
|
*/ |
|
172
|
2 |
|
public function getIterator() |
|
173
|
|
|
{ |
|
174
|
2 |
|
return new \ArrayIterator($this); |
|
175
|
|
|
} |
|
176
|
|
|
|
|
177
|
|
|
/** |
|
178
|
|
|
* @inheritdoc |
|
179
|
|
|
* @return array |
|
180
|
|
|
*/ |
|
181
|
2 |
View Code Duplication |
public function getSimpleArrayCopy() |
|
|
|
|
|
|
182
|
|
|
{ |
|
183
|
2 |
|
$_aReturn = []; |
|
184
|
|
|
|
|
185
|
2 |
|
foreach ($this as $_sProperty => $mValue) |
|
186
|
|
|
{ |
|
187
|
2 |
|
$_aReturn[$_sProperty] = (is_array($mValue) || is_object($mValue)) ? json_encode($mValue) : $mValue; |
|
188
|
|
|
} |
|
189
|
|
|
|
|
190
|
2 |
|
return $_aReturn; |
|
191
|
|
|
} |
|
192
|
|
|
|
|
193
|
|
|
/** |
|
194
|
|
|
* @inheritdoc |
|
195
|
|
|
* @return bool |
|
196
|
|
|
*/ |
|
197
|
|
|
public function isSchedulingJob() |
|
198
|
|
|
{ |
|
199
|
|
|
return false; |
|
200
|
|
|
} |
|
201
|
|
|
|
|
202
|
|
|
/** |
|
203
|
|
|
* @inheritdoc |
|
204
|
|
|
* @return bool |
|
205
|
|
|
*/ |
|
206
|
5 |
|
public function isDependencyJob() |
|
207
|
|
|
{ |
|
208
|
5 |
|
return count($this->dependencies) ? true : false; |
|
209
|
|
|
} |
|
210
|
|
|
|
|
211
|
|
|
/** |
|
212
|
|
|
* @return string |
|
213
|
|
|
*/ |
|
214
|
5 |
|
public function getEntityType() |
|
215
|
|
|
{ |
|
216
|
5 |
|
return JobEntityInterface::MARATHON_TYPE; |
|
217
|
|
|
} |
|
218
|
|
|
|
|
219
|
|
|
/** |
|
220
|
|
|
* @return string |
|
221
|
|
|
*/ |
|
222
|
24 |
|
public function getKey() |
|
223
|
|
|
{ |
|
224
|
24 |
|
return $this->id; |
|
225
|
|
|
} |
|
226
|
|
|
} |
trivago /
chapi
Loading history...
Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation.
You can also find more detailed suggestions in the “Code” section of your repository.