1
0
Fork 0
mirror of synced 2024-09-28 07:21:35 +12:00

functions stats

This commit is contained in:
Damodar Lohani 2022-08-09 08:19:45 +00:00
parent b50863ff9f
commit 59477a9fa9
2 changed files with 30 additions and 16 deletions

View file

@ -110,19 +110,33 @@ class Aggregator extends Database {
{
$this->database->setNamespace('_' . $projectId);
$this->aggregateDailyMetric($projectId, 'functions.executions');
$this->aggregateDailyMetric($projectId, 'functions.builds');
$this->aggregateDailyMetric($projectId, 'functions.failures');
$this->aggregateMonthlyMetric($projectId, 'functions.executions');
$this->aggregateMonthlyMetric($projectId, 'functions.builds');
$this->aggregateMonthlyMetric($projectId, 'functions.failures');
$functionsGeneralMetrics = [
'project.$all.compute.total',
'project.$all.compute.time',
'executions.$all.compute.total',
'executions.$all.compute.success',
'executions.$all.compute.failure',
'executions.$all.compute.time',
'builds.$all.compute.total',
'builds.$all.compute.success',
'builds.$all.compute.failure',
'builds.$all.compute.time',
];
foreach ($functionsGeneralMetrics as $metric) {
$this->aggregateDailyMetric($projectId, $metric);
$this->aggregateMonthlyMetric($projectId, $metric);
}
$functionMetrics = [
'functions.functionId.executions',
'functions.functionId.builds',
'functions.functionId.compute',
'function.functionId.executions.failure',
'function.functionId.builds.failure',
'executions.functionId.compute.total',
'executions.functionId.compute.success',
'executions.functionId.compute.failure',
'executions.functionId.compute.time',
'builds.functionId.compute.total',
'builds.functionId.compute.success',
'builds.functionId.compute.failure',
'builds.functionId.compute.time',
];
$this->foreachDocument($projectId, 'functions', [], function (Document $function) use ($functionMetrics, $projectId) {

View file

@ -185,15 +185,15 @@ class Stats
}
if ($functionExecution >= 1) {
$this->statsd->increment('functions.executions.all' . $tags . ',functionId=' . $functionId . ',functionStatus=' . $functionStatus);
$this->statsd->count('functions.executions.time' . $tags . ',functionId=' . $functionId, $functionExecutionTime);
$this->statsd->increment('executions.compute' . $tags . ',functionId=' . $functionId . ',functionStatus=' . $functionStatus);
$this->statsd->count('executions.compute.time' . $tags . ',functionId=' . $functionId, $functionExecutionTime);
}
if ($functionBuild >= 1) {
$this->statsd->increment('functions.builds.all' . $tags . ',functionId=' . $functionId . ',functionBuildStatus=' . $functionBuildStatus);
$this->statsd->count('functions.builds.time' . $tags . ',functionId=' . $functionId, $functionExecutionTime);
$this->statsd->increment('builds.compute' . $tags . ',functionId=' . $functionId . ',functionBuildStatus=' . $functionBuildStatus);
$this->statsd->count('builds.compute.time' . $tags . ',functionId=' . $functionId, $functionExecutionTime);
}
if ($functionBuild + $functionExecution >= 1) {
$this->statsd->count('functions.compute.time' . $tags . ',functionId=' . $functionId, $functionCompute);
$this->statsd->count('compute.time' . $tags . ',functionId=' . $functionId, $functionCompute);
}
$this->reset();