modify plugin name

This commit is contained in:
2022-07-11 14:26:49 +08:00
parent c946eed53f
commit 56fdf310c8
+22 -9
View File
@@ -89,19 +89,32 @@ class DatabasesProviders extends Providers
*/ */
public function check(OnTaskerStart|OnWorkerStart $start): void public function check(OnTaskerStart|OnWorkerStart $start): void
{ {
Timer::tick(60000, static function () use ($start) { Timer::after(60000, static function () use ($start) {
$valid = $count = 0; DatabasesProviders::filter($start);
$logger = Kiri::getDi()->get(LoggerInterface::class);
$databases = Config::get('databases.connections', []);
if (!empty($databases)) {
DatabasesProviders::each($databases, $logger, $count, $valid);
}
$const = 'Worker %d db client has %d, valid %d';
$logger->alert(sprintf($const, $start->workerId, $count, $valid));
}); });
} }
/**
* @param OnTaskerStart|OnWorkerStart $start
* @return void
* @throws ConfigException
*/
public static function filter(OnTaskerStart|OnWorkerStart $start): void
{
$valid = $count = 0;
$logger = Kiri::getDi()->get(LoggerInterface::class);
$databases = Config::get('databases.connections', []);
if (!empty($databases)) {
DatabasesProviders::each($databases, $logger, $count, $valid);
}
$const = 'Worker %d db client has %d, valid %d';
$logger->alert(sprintf($const, $start->workerId, $count, $valid));
Timer::after(60000, fn() => DatabasesProviders::filter($start));
}
/** /**
* @param $databases * @param $databases
* @param LoggerInterface $logger * @param LoggerInterface $logger