Elgato_dark/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite synced 2026-05-24 09:28:40 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

separate cumulative metrics

Browse source
This commit is contained in:
Damodar Lohani 2022-10-10 09:13:20 +00:00
parent 8ddbde62c1
commit f41d388bf5
1 changed files with 29 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
src/Appwrite/Usage/Calculators/TimeSeries.php
View file

@ -319,6 +319,22 @@ class TimeSeries extends Calculator
], ],
]; ];
protected array $cumulativeMetrics = [
'deployments.$all.storage.size' => [
'table' => 'appwrite_usage_deployments_{scope}_storage_size',
],
'project.$all.storage.size' => [
'table' => 'appwrite_usage_project_{scope}_storage_size',
],
'files.$all.storage.size' => [
'table' => 'appwrite_usage_files_{scope}_storage_size',
],
'files.$bucketId.storage.size' => [
'table' => 'appwrite_usage_files_{scope}_storage_size',
'groupBy' => ['bucketId']
],
];
public function __construct(Database $database, InfluxDatabase $influxDB, callable $errorHandler = null) public function __construct(Database $database, InfluxDatabase $influxDB, callable $errorHandler = null)
{ {
$this->database = $database; $this->database = $database;
@ -469,5 +485,18 @@ class TimeSeries extends Calculator
} }
} }
// for cumulative metrics only get hourly metrics from timeseries
foreach ($this->cumulativeMetrics as $metric => $options) {
try {
$this->syncFromInfluxDB($metric, $options, $this->periods[0]);
} catch (\Exception $e) {
if (is_callable($this->errorHandler)) {
call_user_func($this->errorHandler, $e);
} else {
throw $e;
}
}
}
} }
} }