as2252258/kiri-databases
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

modify plugin name

Browse Source
This commit is contained in:
向林
2022-07-11 16:26:51 +08:00
parent e33776314b
commit 49cd130c81
1 changed files with 13 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files
DatabasesProviders.php
+13 -24
View File
@@ -93,30 +93,19 @@ class DatabasesProviders extends Providers
*/ */
public function check(OnTaskerStart|OnWorkerStart $start): void public function check(OnTaskerStart|OnWorkerStart $start): void
{ {
Timer::tick(10000, [$this, 'filter']); Timer::tick(10000, function ($timerId) {
} $valid = $count = 0;
$logger = Kiri::getDi()->get(LoggerInterface::class);
$databases = Config::get('databases.connections', []);
/** if (!empty($databases)) {
* @param $timerId [$valid, $count] = $this->each($databases, $logger);
* @return void }
* @throws ConfigException $const = 'Worker %d db client has %d, valid %d';
* @throws ContainerExceptionInterface $logger->alert(sprintf($const, env('environmental_workerId'), $count, $valid));
* @throws NotFoundExceptionInterface if ($this->container->get(WorkerStatus::class)->is(StatusEnum::EXIT)) {
*/ Timer::clear($timerId);
public function filter($timerId): void }
{ });
$valid = $count = 0;
$logger = Kiri::getDi()->get(LoggerInterface::class);
$databases = Config::get('databases.connections', []);
if (!empty($databases)) {
[$valid, $count] = $this->each($databases, $logger);
}
$const = 'Worker %d db client has %d, valid %d';
$logger->alert(sprintf($const, env('environmental_workerId'), $count, $valid));
if ($this->container->get(WorkerStatus::class)->is(StatusEnum::EXIT)) {
Timer::clear($timerId);
}
} }