@@ -12,7 +12,7 @@ const {
1212} = require ( '@opentelemetry/semantic-conventions' ) ;
1313const os = require ( 'os' ) ;
1414const { v4 : uuidv4 } = require ( 'uuid' ) ;
15-
15+ const metricPrefix = process . env . METRIC_PREFIX
1616const workflowIDCount = parseInt ( process . env . WORKFLOW_ID_COUNT ) ;
1717const customerIDCount = parseInt ( process . env . CUSTOMER_ID_COUNT ) ;
1818const otlpEndpoint = process . env . OTLP_ENDPOINT ;
@@ -49,19 +49,19 @@ meterProvider.addMetricReader(new PeriodicExportingMetricReader({
4949const meter = meterProvider . getMeter ( otelMeterName ) ;
5050
5151// Create Observable Gauges
52- const memoryUsageGauge = meter . createObservableGauge ( 'memory_usage' , {
52+ const memoryUsageGauge = meter . createObservableGauge ( ` ${ metricPrefix } _memory_usage` , {
5353 description : 'Tracks the memory usage of the application' , valueType : ValueType . DOUBLE
5454} ) ;
5555
56- const concurrencyGauge = meter . createObservableGauge ( 'concurrency' , {
56+ const concurrencyGauge = meter . createObservableGauge ( ` ${ metricPrefix } _concurrency` , {
5757 description : 'Current concurrency level' , valueType : ValueType . INT
5858} ) ;
5959
60- const cpuUsageGauge = meter . createObservableGauge ( 'cpu_usage' , {
60+ const cpuUsageGauge = meter . createObservableGauge ( ` ${ metricPrefix } _cpu_usage` , {
6161 description : 'CPU usage percentage' , valueType : ValueType . DOUBLE
6262} ) ;
6363
64- const runInTimeGauge = meter . createObservableGauge ( 'run_in_time' , {
64+ const runInTimeGauge = meter . createObservableGauge ( ` ${ metricPrefix } _run_time` , {
6565 description : 'Run time in seconds' , valueType : ValueType . INT
6666} ) ;
6767
@@ -94,8 +94,8 @@ cpuUsageGauge.addCallback((observableResult) => {
9494runInTimeGauge . addCallback ( ( observableResult ) => {
9595 workflowIDs . forEach ( workflow_id => {
9696 customerIDs . forEach ( customer_id => {
97- let run_in_time = Math . floor ( Math . random ( ) * 60 ) ;
98- observableResult . observe ( run_in_time , {
97+ let run_time = Math . floor ( Math . random ( ) * 60 ) ;
98+ observableResult . observe ( run_time , {
9999 ...attributes , 'workflow_id' : workflow_id , 'customer_id' : customer_id
100100 } ) ;
101101 } ) ;
0 commit comments