1
0
Fork 0
mirror of synced 2024-10-03 02:37:40 +13:00
This commit is contained in:
shimon 2022-12-06 16:17:56 +02:00
parent f44ee4ec90
commit e1368231b2
2 changed files with 5 additions and 3 deletions

View file

@ -55,6 +55,7 @@ $databaseListener = function (string $event, Document $document, Document $proje
$value = -1;
}
var_dump($document->getCollection());
switch (true) {
case $document->getCollection() === 'users':
$queueForUsage->addMetric("{$project->getId()}", "users", $value); // per project
@ -90,8 +91,8 @@ $databaseListener = function (string $event, Document $document, Document $proje
$queueForUsage->addMetric("{$project->getId()}", "functions", $value); // per project
break;
case $document->getCollection() === 'deployments':
$queueForUsage->addMetric("{$project->getId()}.{$document['functionId']}", "deployments", $value); // per function
$queueForUsage->addMetric("{$project->getId()}.{$document['functionId']}", "deployments.storage", $document->getAttribute('size') * $value); // per function
$queueForUsage->addMetric("{$project->getId()}.{$document['resourceId']}", "deployments", $value); // per function
$queueForUsage->addMetric("{$project->getId()}.{$document['resourceId']}", "deployments.storage", $document->getAttribute('size') * $value); // per function
$queueForUsage->addMetric("{$project->getId()}", "deployments", $value); // per project
$queueForUsage->addMetric("{$project->getId()}", "deployments.storage", $document->getAttribute('size') * $value); // per project
break;

View file

@ -4,6 +4,7 @@ require_once __DIR__ . '/../worker.php';
use Swoole\Table;
use Swoole\Timer;
use Utopia\App;
use Utopia\Database\Database;
use Utopia\Database\Document;
use Utopia\Database\Validator\Authorization;
@ -96,7 +97,7 @@ $server
'metric' => $metric['key'],
'value' => $metric['value'],
'type' => 0,
'region' => 'default',
'region' => App::getEnv('_APP_REGION', 'default'),
])));
} else {
$value = $document->getAttribute('value') + $metric['value'];