@@ -42,6 +42,7 @@ export interface ExporterConfig {
4242
4343export class PrometheusExporter extends MetricReader {
4444 private readonly _abortController : AbortController ;
45+ private readonly _server : Deno . HttpServer ;
4546
4647 // This will be required when histogram is implemented. Leaving here so it is not forgotten
4748 // Histogram cannot have a attribute named 'le'
@@ -68,29 +69,32 @@ export class PrometheusExporter extends MetricReader {
6869 this . _abortController = new AbortController ( ) ;
6970 const { signal } = this . _abortController ;
7071
71- Deno . serve ( { hostname, port, signal, onError } , async ( request ) => {
72- if ( new URL ( request . url ) . pathname !== "/metrics" ) {
73- return new Response ( "not found" , { status : 404 } ) ;
74- }
75-
76- try {
77- const { resourceMetrics, errors } = await this . collect ( ) ;
78- if ( errors . length ) {
79- amLogger . trace (
80- "PrometheusExporter: metrics collection errors" ,
81- ...errors ,
82- ) ;
72+ this . _server = Deno . serve (
73+ { hostname, port, signal, onError } ,
74+ async ( request ) => {
75+ if ( new URL ( request . url ) . pathname !== "/metrics" ) {
76+ return new Response ( "not found" , { status : 404 } ) ;
8377 }
8478
85- return new Response ( serializer . serialize ( resourceMetrics ) , {
86- headers : HEADERS ,
87- } ) ;
88- } catch ( error ) {
89- return new Response ( `# failed to export metrics: ${ error } , {
90- headers : HEADERS ,
91- } ) ;
92- }
93- } ) ;
79+ try {
80+ const { resourceMetrics, errors } = await this . collect ( ) ;
81+ if ( errors . length ) {
82+ amLogger . trace (
83+ "PrometheusExporter: metrics collection errors" ,
84+ ...errors ,
85+ ) ;
86+ }
87+
88+ return new Response ( serializer . serialize ( resourceMetrics ) , {
89+ headers : HEADERS ,
90+ } ) ;
91+ } catch ( error ) {
92+ return new Response ( `# failed to export metrics: ${ error } , {
93+ headers : HEADERS ,
94+ } ) ;
95+ }
96+ } ,
97+ ) ;
9498
9599 amLogger . debug (
96100 `Prometheus exporter server started: ${ hostname } ${ port } ,
@@ -113,6 +117,6 @@ export class PrometheusExporter extends MetricReader {
113117 */
114118 stopServer ( ) : Promise < void > {
115119 this . _abortController . abort ( ) ;
116- return Promise . resolve ( ) ;
120+ return this . _server . finished ;
117121 }
118122}
0 commit comments