@@ -30,7 +30,7 @@ discard block |
||
30 | 30 | 'value' => $apcSmaInfo['avail_mem'], |
31 | 31 | ], |
32 | 32 | ]; |
33 | - foreach (new \APCuIterator('/^' . $this->config['apcu_key_prefix'] . $this->config['apcu_key_separator'] . '/') as $item) { |
|
33 | + foreach (new \APCuIterator('/^'.$this->config['apcu_key_prefix'].$this->config['apcu_key_separator'].'/') as $item) { |
|
34 | 34 | $parts = explode($this->config['apcu_key_separator'], $item['key']); |
35 | 35 | parse_str($parts[3], $labels); |
36 | 36 | if (is_array($item['value'])) { |
@@ -62,8 +62,8 @@ discard block |
||
62 | 62 | $metrics = $this->getMetrics(); |
63 | 63 | $lines = []; |
64 | 64 | foreach ($metrics as $metric) { |
65 | - $lines[] = "# HELP " . $metric['name'] . " {$metric['help']}"; |
|
66 | - $lines[] = "# TYPE " . $metric['name'] . " {$metric['type']}"; |
|
65 | + $lines[] = "# HELP ".$metric['name']." {$metric['help']}"; |
|
66 | + $lines[] = "# TYPE ".$metric['name']." {$metric['type']}"; |
|
67 | 67 | |
68 | 68 | $metricLabels = isset($metric['labels']) ? $metric['labels'] : []; |
69 | 69 | $labels = ['{']; |
@@ -73,7 +73,7 @@ discard block |
||
73 | 73 | } |
74 | 74 | $labels[] = '}'; |
75 | 75 | $labelStr = implode('', $labels); |
76 | - $lines[] = $metric['name'] . "$labelStr {$metric['value']}"; |
|
76 | + $lines[] = $metric['name']."$labelStr {$metric['value']}"; |
|
77 | 77 | } |
78 | 78 | return implode("\n", $lines); |
79 | 79 | } |
@@ -21,7 +21,7 @@ discard block |
||
21 | 21 | 'class' => static::class, |
22 | 22 | 'redirect' => false, |
23 | 23 | 'pipe' => 0, |
24 | - 'enable' => (bool)config('prometheus.enable', true), |
|
24 | + 'enable' => (bool) config('prometheus.enable', true), |
|
25 | 25 | ], |
26 | 26 | ]; |
27 | 27 | } |
@@ -38,7 +38,7 @@ discard block |
||
38 | 38 | $taskWorkerNum = isset($swoole->setting['task_worker_num']) ? $swoole->setting['task_worker_num'] : 0; |
39 | 39 | $totalNum = $workerNum + $taskWorkerNum - 1; |
40 | 40 | $workerIds = range(0, $totalNum); |
41 | - $runJob = function () use ($swoole, $workerIds, $processCollector, $swooleStatsCollector, $systemCollector) { |
|
41 | + $runJob = function() use ($swoole, $workerIds, $processCollector, $swooleStatsCollector, $systemCollector) { |
|
42 | 42 | // Collect the metrics of Swoole stats() |
43 | 43 | $swooleStatsCollector->collect(); |
44 | 44 |
@@ -21,7 +21,7 @@ discard block |
||
21 | 21 | 'class' => static::class, |
22 | 22 | 'redirect' => false, |
23 | 23 | 'pipe' => 0, |
24 | - 'enable' => (bool)getenv('ENABLE_APOLLO'), |
|
24 | + 'enable' => (bool) getenv('ENABLE_APOLLO'), |
|
25 | 25 | ], |
26 | 26 | ]; |
27 | 27 | } |
@@ -30,11 +30,11 @@ discard block |
||
30 | 30 | { |
31 | 31 | $filename = base_path('.env'); |
32 | 32 | if (isset($_ENV['_ENV'])) { |
33 | - $filename .= '.' . $_ENV['_ENV']; |
|
33 | + $filename .= '.'.$_ENV['_ENV']; |
|
34 | 34 | } |
35 | 35 | |
36 | 36 | self::$apollo = Client::createFromEnv(); |
37 | - self::$apollo->startWatchNotification(function (array $notifications) use ($process, $filename) { |
|
37 | + self::$apollo->startWatchNotification(function(array $notifications) use ($process, $filename) { |
|
38 | 38 | $configs = self::$apollo->pullAllAndSave($filename); |
39 | 39 | app('log')->info('[ApolloProcess] Pull all configurations', $configs); |
40 | 40 | Portal::runLaravelSCommand(base_path(), 'reload'); |
@@ -15,31 +15,31 @@ |
||
15 | 15 | public function boot() |
16 | 16 | { |
17 | 17 | $this->publishes([ |
18 | - __DIR__ . '/../../../config/prometheus.php' => base_path('config/prometheus.php'), |
|
18 | + __DIR__.'/../../../config/prometheus.php' => base_path('config/prometheus.php'), |
|
19 | 19 | ]); |
20 | 20 | } |
21 | 21 | |
22 | 22 | public function register() |
23 | 23 | { |
24 | 24 | $this->mergeConfigFrom( |
25 | - __DIR__ . '/../../../config/prometheus.php', 'prometheus' |
|
25 | + __DIR__.'/../../../config/prometheus.php', 'prometheus' |
|
26 | 26 | ); |
27 | - $this->app->singleton(RequestMiddleware::class, function ($app) { |
|
27 | + $this->app->singleton(RequestMiddleware::class, function($app) { |
|
28 | 28 | return new RequestMiddleware($app->make(HttpRequestCollector::class)); |
29 | 29 | }); |
30 | - $this->app->singleton(HttpRequestCollector::class, function ($app) { |
|
30 | + $this->app->singleton(HttpRequestCollector::class, function($app) { |
|
31 | 31 | return new HttpRequestCollector($app['config']->get('prometheus')); |
32 | 32 | }); |
33 | - $this->app->singleton(SwooleProcessCollector::class, function ($app) { |
|
33 | + $this->app->singleton(SwooleProcessCollector::class, function($app) { |
|
34 | 34 | return new SwooleProcessCollector($app['config']->get('prometheus')); |
35 | 35 | }); |
36 | - $this->app->singleton(SwooleStatsCollector::class, function ($app) { |
|
36 | + $this->app->singleton(SwooleStatsCollector::class, function($app) { |
|
37 | 37 | return new SwooleStatsCollector($app['config']->get('prometheus')); |
38 | 38 | }); |
39 | - $this->app->singleton(SystemCollector::class, function ($app) { |
|
39 | + $this->app->singleton(SystemCollector::class, function($app) { |
|
40 | 40 | return new SystemCollector($app['config']->get('prometheus')); |
41 | 41 | }); |
42 | - $this->app->singleton(Exporter::class, function ($app) { |
|
42 | + $this->app->singleton(Exporter::class, function($app) { |
|
43 | 43 | return new Exporter($app['config']->get('prometheus')); |
44 | 44 | }); |
45 | 45 | } |
@@ -20,26 +20,26 @@ discard block |
||
20 | 20 | if ($routes instanceof \Illuminate\Routing\RouteCollection) { // Laravel |
21 | 21 | foreach ($routes->getRoutes() as $route) { |
22 | 22 | $method = $route->methods()[0]; |
23 | - $uri = '/' . ltrim($route->uri(), '/'); |
|
24 | - $this->routes[$method . $uri] = $uri; |
|
23 | + $uri = '/'.ltrim($route->uri(), '/'); |
|
24 | + $this->routes[$method.$uri] = $uri; |
|
25 | 25 | |
26 | 26 | $action = $route->getAction(); |
27 | 27 | if (is_string($action['uses'])) { // Uses |
28 | - $this->routesByUses[$method . $action['uses']] = $uri; |
|
28 | + $this->routesByUses[$method.$action['uses']] = $uri; |
|
29 | 29 | } elseif ($action['uses'] instanceof Closure) { // Closure |
30 | 30 | $objectId = spl_object_hash($action['uses']); |
31 | - $this->routesByClosure[$method . $objectId] = $uri; |
|
31 | + $this->routesByClosure[$method.$objectId] = $uri; |
|
32 | 32 | } |
33 | 33 | } |
34 | 34 | } elseif (is_array($routes)) { // Lumen |
35 | 35 | $this->routes = $routes; |
36 | 36 | foreach ($routes as $route) { |
37 | 37 | if (isset($route['action']['uses'])) { // Uses |
38 | - $this->routesByUses[$route['method'] . $route['action']['uses']] = $route['uri']; |
|
38 | + $this->routesByUses[$route['method'].$route['action']['uses']] = $route['uri']; |
|
39 | 39 | } |
40 | 40 | if (isset($route['action'][0]) && $route['action'][0] instanceof Closure) { // Closure |
41 | 41 | $objectId = spl_object_hash($route['action'][0]); |
42 | - $this->routesByClosure[$route['method'] . $objectId] = $route['uri']; |
|
42 | + $this->routesByClosure[$route['method'].$objectId] = $route['uri']; |
|
43 | 43 | } |
44 | 44 | } |
45 | 45 | } |
@@ -82,7 +82,7 @@ discard block |
||
82 | 82 | { |
83 | 83 | $method = $request->getMethod(); |
84 | 84 | $uri = $request->getPathInfo(); |
85 | - $key = $method . $uri; |
|
85 | + $key = $method.$uri; |
|
86 | 86 | if (isset($this->routes[$key])) { |
87 | 87 | return $uri; |
88 | 88 | } |
@@ -92,12 +92,12 @@ discard block |
||
92 | 92 | $uri = $route->uri(); |
93 | 93 | } elseif (is_array($route)) { // Lumen |
94 | 94 | if (isset($route[1]['uses'])) { |
95 | - $key = $method . $route[1]['uses']; |
|
95 | + $key = $method.$route[1]['uses']; |
|
96 | 96 | if (isset($this->routesByUses[$key])) { |
97 | 97 | $uri = $this->routesByUses[$key]; |
98 | 98 | } |
99 | 99 | } elseif (isset($route[1][0]) && $route[1][0] instanceof Closure) { |
100 | - $key = $method . spl_object_hash($route[1][0]); |
|
100 | + $key = $method.spl_object_hash($route[1][0]); |
|
101 | 101 | if (isset($this->routesByClosure[$key])) { |
102 | 102 | $uri = $this->routesByClosure[$key]; |
103 | 103 | } |
@@ -28,7 +28,7 @@ discard block |
||
28 | 28 | if ($delay < 0) { |
29 | 29 | throw new \InvalidArgumentException('The delay must be greater than or equal to 0'); |
30 | 30 | } |
31 | - $this->delay = (int)$delay; |
|
31 | + $this->delay = (int) $delay; |
|
32 | 32 | return $this; |
33 | 33 | } |
34 | 34 | |
@@ -51,7 +51,7 @@ discard block |
||
51 | 51 | if ($tries < 1) { |
52 | 52 | throw new \InvalidArgumentException('The number of attempts must be greater than or equal to 1'); |
53 | 53 | } |
54 | - $this->tries = (int)$tries; |
|
54 | + $this->tries = (int) $tries; |
|
55 | 55 | return $this; |
56 | 56 | } |
57 | 57 | |
@@ -73,7 +73,7 @@ discard block |
||
73 | 73 | { |
74 | 74 | static $dispatch; |
75 | 75 | if (!$dispatch) { |
76 | - $dispatch = static function ($task) { |
|
76 | + $dispatch = static function($task) { |
|
77 | 77 | /**@var \Swoole\Http\Server $swoole */ |
78 | 78 | $swoole = app('swoole'); |
79 | 79 | // The worker_id of timer process is -1 |