modify plugin name

This commit is contained in:
2022-07-11 14:46:46 +08:00
parent 531b54edb2
commit db97de7e40
+6 -7
View File
@@ -89,27 +89,26 @@ class DatabasesProviders extends Providers
*/ */
public function check(OnTaskerStart|OnWorkerStart $start): void public function check(OnTaskerStart|OnWorkerStart $start): void
{ {
Timer::after(60000, fn() => DatabasesProviders::filter($start)); Timer::after(60000, [$this, 'filter']);
} }
/** /**
* @param OnTaskerStart|OnWorkerStart $start
* @return void * @return void
* @throws ConfigException * @throws ConfigException
*/ */
public static function filter(OnTaskerStart|OnWorkerStart $start): void public function filter(): void
{ {
$valid = $count = 0; $valid = $count = 0;
$logger = Kiri::getDi()->get(LoggerInterface::class); $logger = Kiri::getDi()->get(LoggerInterface::class);
$databases = Config::get('databases.connections', []); $databases = Config::get('databases.connections', []);
if (!empty($databases)) { if (!empty($databases)) {
[$valid, $count] = DatabasesProviders::each($databases, $logger); [$valid, $count] = $this->each($databases, $logger);
} }
$const = 'Worker %d db client has %d, valid %d'; $const = 'Worker %d db client has %d, valid %d';
$logger->alert(sprintf($const, $start->workerId, $count, $valid)); $logger->alert(sprintf($const, env('environmental_workerId'), $count, $valid));
Timer::after(60000, fn() => DatabasesProviders::filter($start)); Timer::after(60000, [$this, 'filter']);
} }
@@ -118,7 +117,7 @@ class DatabasesProviders extends Providers
* @param LoggerInterface $logger * @param LoggerInterface $logger
* @return array * @return array
*/ */
public static function each($databases, LoggerInterface $logger): array public function each($databases, LoggerInterface $logger): array
{ {
$connection = Kiri::getDi()->get(PoolConnection::class); $connection = Kiri::getDi()->get(PoolConnection::class);
$valid = $count = 0; $valid = $count = 0;