Delphi/delphimvcframework
1
0
Fork 0
mirror of https://github.com/danieleteti/delphimvcframework.git synced 2024-11-15 07:45:54 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Improved Prometheus Middleware

Browse Source
This commit is contained in:
Daniele Teti 2023-04-12 17:49:30 +02:00
parent d9727b481a
commit e451849768
2 changed files with 50 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
samples/prometheus/articles_crud_server_prometheus/Controllers.Articles.pas
View File

@ -70,7 +70,7 @@ procedure TArticlesController.CreateArticle(const Article: TArticle);
begin
GetArticlesService.Add(Article);
Render201Created('/articles/' + Article.id.ToString, 'Article Created');
Metrics.Inc('new_article');
Metrics.IncCounterValue('new_article');
end;
procedure TArticlesController.CreateArticles(const ArticleList: TObjectList<TArticle>);
@ -84,7 +84,7 @@ begin
GetArticlesService.Add(lArticle);
end;
GetArticlesService.Commit;
Metrics.Inc('new_article', ArticleList.Count);
Metrics.IncCounterValue('new_article', ArticleList.Count);
except
GetArticlesService.Rollback;
raise;
@ -130,7 +130,7 @@ begin
lDict := ObjectDict().Add('data', GetArticlesService.GetArticles(Search));
end;
Render(lDict);
Metrics.Inc('searches');
Metrics.IncCounterValue('searches');
except
on E: EServiceException do
begin

53
samples/prometheus/articles_crud_server_prometheus/MVCFramework.Middleware.Prometheus.pas
View File

@ -24,12 +24,19 @@ type
constructor Create(const PrometheusRoute: String = '/metrics'; const OnBeforeMetricsGet: TProc = nil);
end;
{Simplified access to the most common Prometheus metrics}
Metrics = class sealed
public
class procedure Inc(const MetricName: string; const Amount: Double = 1); overload;
class procedure Inc(const MetricName: string; const Amount: Double; const Labels: TArray<String>); overload;
// "Counter" metric
class procedure IncCounterValue(const MetricName: string; const Amount: Double = 1); overload;
class procedure IncCounterValue(const MetricName: string; const Amount: Double; const Labels: TArray<String>); overload;
// "Gauge" metric
class procedure SetGaugeValue(const MetricName: string; const Amount: Double = 1); overload;
class procedure SetGaugeValue(const MetricName: string; const Amount: Double; const Labels: TArray<String>); overload;
class procedure IncGaugeValue(const MetricName: string; const Amount: Double = 1); overload;
class procedure IncGaugeValue(const MetricName: string; const Amount: Double; const Labels: TArray<String>); overload;
class procedure DecGaugeValue(const MetricName: string; const Amount: Double = -1); overload;
class procedure DecGaugeValue(const MetricName: string; const Amount: Double; const Labels: TArray<String>); overload;
end;
@ -61,7 +68,7 @@ end;
procedure TMVCPrometheusMiddleware.OnAfterRouting(AContext: TWebContext;
const AHandled: Boolean);
begin
Metrics.Inc('http_requests_handled', 1,
Metrics.IncCounterValue('http_requests_handled', 1,
[AContext.Request.PathInfo, IntToStr(AContext.Response.StatusCode)]);
end;
@ -78,7 +85,7 @@ begin
if not SameText(AContext.Request.PathInfo, fPrometheusRoute) then
begin
// Get the metric counter and increment it.
Metrics.Inc('http_requests_count');
Metrics.IncCounterValue('http_requests_count');
end
else
begin
@ -101,7 +108,7 @@ end;
{ Metrics }
class procedure Metrics.Inc(const MetricName: string; const Amount: Double);
class procedure Metrics.IncCounterValue(const MetricName: string; const Amount: Double);
begin
TCollectorRegistry
.DefaultRegistry
@ -109,7 +116,24 @@ begin
.Inc(Amount);
end;
class procedure Metrics.Inc(const MetricName: string; const Amount: Double;
class procedure Metrics.DecGaugeValue(const MetricName: string;
const Amount: Double; const Labels: TArray<String>);
begin
TCollectorRegistry.DefaultRegistry
.GetCollector<TGauge>(MetricName)
.Labels(Labels)
.Dec(Amount);
end;
class procedure Metrics.DecGaugeValue(const MetricName: string;
const Amount: Double);
begin
TCollectorRegistry.DefaultRegistry
.GetCollector<TGauge>(MetricName)
.Dec(Amount);
end;
class procedure Metrics.IncCounterValue(const MetricName: string; const Amount: Double;
const Labels: TArray<String>);
begin
TCollectorRegistry
@ -119,6 +143,23 @@ begin
.Inc(Amount);
end;
class procedure Metrics.IncGaugeValue(const MetricName: string;
const Amount: Double);
begin
TCollectorRegistry.DefaultRegistry
.GetCollector<TGauge>(MetricName)
.Inc(Amount);
end;
class procedure Metrics.IncGaugeValue(const MetricName: string;
const Amount: Double; const Labels: TArray<String>);
begin
TCollectorRegistry.DefaultRegistry
.GetCollector<TGauge>(MetricName)
.Labels(Labels)
.Inc(Amount);
end;
class procedure Metrics.SetGaugeValue(const MetricName: string;
const Amount: Double; const Labels: TArray<String>);
begin