diff --git a/src/Command/CommandMetrics.php b/src/Command/CommandMetrics.php index 2cc801c..49d498e 100644 --- a/src/Command/CommandMetrics.php +++ b/src/Command/CommandMetrics.php @@ -16,8 +16,8 @@ public static function write(CommandFinished $event): void $labels = CommandLabels::extractFromTask($event); - app()->terminating(fn() => Prometheus::update('command_runs_total', 1, $labels)); - app()->terminating(fn() => Prometheus::update('command_run_seconds_total', Helper::duration(), $labels)); + app()->terminating(fn () => Prometheus::update('command_runs_total', 1, $labels)); + app()->terminating(fn () => Prometheus::update('command_run_seconds_total', Helper::duration(), $labels)); } protected static function needToIgnoreCommand(?string $command): bool diff --git a/src/Guzzle/GuzzleMiddleware.php b/src/Guzzle/GuzzleMiddleware.php index 7741e24..a724d04 100644 --- a/src/Guzzle/GuzzleMiddleware.php +++ b/src/Guzzle/GuzzleMiddleware.php @@ -47,8 +47,8 @@ public static function handleResponse(string $type, $start, string $host): void $labels = [$host]; - app()->terminating(fn() => Prometheus::update('http_client_seconds_total', $end - $start, $labels)); + app()->terminating(fn () => Prometheus::update('http_client_seconds_total', $end - $start, $labels)); - app()->terminating(fn() => Prometheus::update('http_client_requests_total', 1, $labels)); + app()->terminating(fn () => Prometheus::update('http_client_requests_total', 1, $labels)); } } diff --git a/src/Job/JobMiddleware.php b/src/Job/JobMiddleware.php index 97ea836..a970888 100644 --- a/src/Job/JobMiddleware.php +++ b/src/Job/JobMiddleware.php @@ -14,7 +14,7 @@ public function handle($job, $next) $next($job); $duration = microtime(true) - $start; - app()->terminating(fn() => Prometheus::update('queue_job_runs_total', 1, $labels)); - app()->terminating(fn() => Prometheus::update('queue_job_run_seconds_total', $duration, $labels)); + app()->terminating(fn () => Prometheus::update('queue_job_runs_total', 1, $labels)); + app()->terminating(fn () => Prometheus::update('queue_job_run_seconds_total', $duration, $labels)); } } diff --git a/src/Kafka/KafkaMetricsMiddleware.php b/src/Kafka/KafkaMetricsMiddleware.php index c47decb..01ac4f1 100644 --- a/src/Kafka/KafkaMetricsMiddleware.php +++ b/src/Kafka/KafkaMetricsMiddleware.php @@ -30,7 +30,7 @@ private function writeMetrics(Message $message, float $startKafka, KafkaResponse $duration = microtime(true) - $startKafka; $labels = KafkaLabels::extractFromMessage($message, $status->value); - app()->terminating(fn() => Prometheus::update('kafka_runs_total', 1, $labels)); - app()->terminating(fn() => Prometheus::update('kafka_run_seconds_total', $duration, $labels)); + app()->terminating(fn () => Prometheus::update('kafka_runs_total', 1, $labels)); + app()->terminating(fn () => Prometheus::update('kafka_run_seconds_total', $duration, $labels)); } } diff --git a/src/MetricsServiceProvider.php b/src/MetricsServiceProvider.php index f446b94..9578d38 100644 --- a/src/MetricsServiceProvider.php +++ b/src/MetricsServiceProvider.php @@ -103,15 +103,15 @@ private function registerEventListeners(): void }); Event::listen(MessageLogged::class, function (MessageLogged $event) { - app()->terminating(fn() => Prometheus::update('log_messages_count', 1, [$event->level])); + app()->terminating(fn () => Prometheus::update('log_messages_count', 1, [$event->level])); }); Event::listen(JobFailed::class, function (JobFailed $event) { - app()->terminating(fn() => Prometheus::update('queue_job_failed_total', 1, JobLabels::extractFromJob($event->job))); + app()->terminating(fn () => Prometheus::update('queue_job_failed_total', 1, JobLabels::extractFromJob($event->job))); }); Event::listen(JobQueued::class, function (JobQueued $event) { - app()->terminating(fn() => Prometheus::update('queue_job_dispatched_total', 1, JobLabels::extractFromJob($event->job))); + app()->terminating(fn () => Prometheus::update('queue_job_dispatched_total', 1, JobLabels::extractFromJob($event->job))); }); Bus::pipeThrough([ @@ -119,8 +119,8 @@ private function registerEventListeners(): void ]); Event::listen(ScheduledTaskFinished::class, function (ScheduledTaskFinished $event) { - app()->terminating(fn() => Prometheus::update('task_runs_total', 1, TaskLabels::extractFromTask($event->task))); - app()->terminating(fn() => Prometheus::update('task_run_seconds_total', $event->runtime, TaskLabels::extractFromTask($event->task))); + app()->terminating(fn () => Prometheus::update('task_runs_total', 1, TaskLabels::extractFromTask($event->task))); + app()->terminating(fn () => Prometheus::update('task_run_seconds_total', $event->runtime, TaskLabels::extractFromTask($event->task))); }); Event::listen(CommandFinished::class, function (CommandFinished $event) { diff --git a/src/Workers/WorkerUsage.php b/src/Workers/WorkerUsage.php index 6697af2..e9e4fde 100644 --- a/src/Workers/WorkerUsage.php +++ b/src/Workers/WorkerUsage.php @@ -20,8 +20,8 @@ public function register(MetricsBag $metricsBag): void public function update(MetricsBag $metricsBag): void { if ($this->hasSwoole()) { - app()->terminating(fn() => Prometheus::update('workers_total', $this->getTotal())); - app()->terminating(fn() => Prometheus::update('workers_idle', $this->getIdle())); + app()->terminating(fn () => Prometheus::update('workers_total', $this->getTotal())); + app()->terminating(fn () => Prometheus::update('workers_idle', $this->getIdle())); } }