File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 99class FailedQsBatches implements Exporter {
1010 protected $ gauge ;
1111
12- public function metrics (CollectorRegistry $ collectorRegistry ) {
12+ public function metrics (CollectorRegistry $ collectorRegistry ): void {
1313 $ this ->gauge = $ collectorRegistry ->getOrRegisterGauge (
1414 config ('horizon-exporter.namespace ' ),
1515 'qs_batches_failed_batches ' ,
1616 'The number of QueryService batches marked as failed ' ,
1717 );
1818 }
1919
20- public function collect () {
20+ public function collect (): void {
2121 $ numBatches = QsBatch::has ('wiki ' )->where ([
2222 'failed ' => 1 ,
2323 ])->count ();
Original file line number Diff line number Diff line change 99class PendingQsBatches implements Exporter {
1010 protected $ gauge ;
1111
12- public function metrics (CollectorRegistry $ collectorRegistry ) {
12+ public function metrics (CollectorRegistry $ collectorRegistry ): void {
1313 $ this ->gauge = $ collectorRegistry ->getOrRegisterGauge (
1414 config ('horizon-exporter.namespace ' ),
1515 'qs_batches_pending_batches ' ,
1616 'The number of QueryService batches waiting to be processed ' ,
1717 );
1818 }
1919
20- public function collect () {
20+ public function collect (): void {
2121 $ numBatches = QsBatch::has ('wiki ' )->where ([
2222 'done ' => 0 ,
2323 'failed ' => 0 ,
Original file line number Diff line number Diff line change 1010class WikiEntityImports implements Exporter {
1111 protected $ pending ;
1212
13- public function metrics (CollectorRegistry $ collectorRegistry ) {
13+ public function metrics (CollectorRegistry $ collectorRegistry ): void {
1414 $ this ->pending = $ collectorRegistry ->getOrRegisterGauge (
1515 config ('horizon-exporter.namespace ' ),
1616 'wiki_entity_imports_pending ' ,
1717 'The number of pending Entity imports currently being processed. ' ,
1818 );
1919 }
2020
21- public function collect () {
21+ public function collect (): void {
2222 // counters for failed / success are incremented in the HTTP controller
2323 $ this ->pending ->set (
2424 WikiEntityImport::where (['status ' => WikiEntityImportStatus::Pending])->count ()
Original file line number Diff line number Diff line change 44use App \Metrics \PendingQsBatches ;
55use App \Metrics \WikiEntityImports ;
66use LKDevelopment \HorizonPrometheusExporter \Exporter \CurrentMasterSupervisors ;
7- use LKDevelopment \HorizonPrometheusExporter \Exporter \CurrentProccesesPerQueue ;
7+ use LKDevelopment \HorizonPrometheusExporter \Exporter \CurrentProcessesPerQueue ;
88use LKDevelopment \HorizonPrometheusExporter \Exporter \CurrentWorkload ;
99use LKDevelopment \HorizonPrometheusExporter \Exporter \FailedJobsPerHour ;
1010use LKDevelopment \HorizonPrometheusExporter \Exporter \HorizonStatus ;
3030 CurrentMasterSupervisors::class,
3131 JobsPerMinute::class,
3232 CurrentWorkload::class,
33- CurrentProccesesPerQueue ::class,
33+ CurrentProcessesPerQueue ::class,
3434 FailedJobsPerHour::class,
3535 HorizonStatus::class,
3636 RecentJobs::class,
You can’t perform that action at this time.
0 commit comments