Skip to content

Commit 08561b2

Browse files
author
Oliver
committed
fix(listener): Fix flushing the meters
1 parent 843980f commit 08561b2

File tree

3 files changed

+10
-1
lines changed

3 files changed

+10
-1
lines changed

src/Listeners/ProcessedJobsListener.php

+2
Original file line numberDiff line numberDiff line change
@@ -30,5 +30,7 @@ public function __invoke(JobProcessed $event): void
3030
'queue' => $event->job->getQueue(),
3131
])
3232
);
33+
34+
$this->meterProvider->flush();
3335
}
3436
}

src/Listeners/ProcessedJobsPeakMemoryUsageListener.php

+2
Original file line numberDiff line numberDiff line change
@@ -35,5 +35,7 @@ public function __invoke(JobProcessed $event): void
3535
'queue' => $event->job->getQueue(),
3636
]
3737
);
38+
39+
$this->meterProvider->flush();
3840
}
3941
}

src/MeterProvider.php

+6-1
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
namespace Worksome\HorizonTelemetry;
66

77
use OpenTelemetry\API\Metrics\MeterInterface;
8-
use OpenTelemetry\API\Metrics\MeterProviderInterface;
8+
use OpenTelemetry\SDK\Metrics\MeterProviderInterface;
99
use Worksome\HorizonTelemetry\Enums\MeterName;
1010

1111
readonly class MeterProvider
@@ -21,4 +21,9 @@ public function getMeter(MeterName $meter): MeterInterface
2121
$meter->value
2222
);
2323
}
24+
25+
public function flush(): void
26+
{
27+
$this->meterProvider->forceFlush();
28+
}
2429
}

0 commit comments

Comments
 (0)