diff options
Diffstat (limited to 'test/system/MetricsCollectorTest.ts')
-rw-r--r-- | test/system/MetricsCollectorTest.ts | 26 |
1 files changed, 17 insertions, 9 deletions
diff --git a/test/system/MetricsCollectorTest.ts b/test/system/MetricsCollectorTest.ts index 07867a8..eafc77d 100644 --- a/test/system/MetricsCollectorTest.ts +++ b/test/system/MetricsCollectorTest.ts @@ -19,13 +19,15 @@ * along with this program. If not, see <http://www.gnu.org/licenses/>. */ -import { PrometheusFactory } from '../../src/system/PrometheusFactory'; +import { + PrometheusFactory, + PrometheusConfig, +} from '../../src/system/PrometheusFactory'; import { Histogram, Pushgateway, Counter, Gauge } from 'prom-client'; import { EventEmitter } from 'events'; import { expect } from 'chai'; import { MetricsCollector as Sut, - PrometheusConfig, MetricTimer, } from '../../src/system/MetricsCollector'; @@ -35,8 +37,8 @@ describe( 'system.MetricsCollector captures events and pushes metrics', () => { it( 'process-complete event is hooked', () => { - let histogram_called = false; - let counter_called = false; + let histogram_called = false; + let counter_called = false; const emitter = new EventEmitter(); const conf = createMockConfig(); @@ -46,18 +48,20 @@ describe( 'system.MetricsCollector captures events and pushes metrics', () => counter_cb: () => { counter_called = true }, } ); - new Sut( factory, conf, emitter, timer ); + const sut = new Sut( factory, conf, emitter, timer ); emitter.emit( 'delta-process-end' ); expect( histogram_called ).to.be.true; expect( counter_called ).to.be.true; + + sut.stop(); } ); it( 'process-error event is hooked', () => { - let counter_called = false; + let counter_called = false; const emitter = new EventEmitter(); const conf = createMockConfig(); @@ -66,11 +70,13 @@ describe( 'system.MetricsCollector captures events and pushes metrics', () => counter_cb: () => { counter_called = true }, } ); - new Sut( factory, conf, emitter, timer ); + const sut = new Sut( factory, conf, emitter, timer ); emitter.emit( 'delta-process-error' ); expect( counter_called ).to.be.true; + + sut.stop(); } ); @@ -80,7 +86,7 @@ describe( 'system.MetricsCollector captures events and pushes metrics', () => const uid = 'foo'; const start_time_ns = 1234; const end_time_ns = 5678; - const expected_ms = ( end_time_ns - start_time_ns ) / 1000; + const expected_ms = ( end_time_ns - start_time_ns ) / 1000000; const emitter = new EventEmitter(); const conf = createMockConfig(); const timer = createMockTimer( start_time_ns, end_time_ns ); @@ -88,12 +94,14 @@ describe( 'system.MetricsCollector captures events and pushes metrics', () => histogram_cb: ( n: number ) => { actual_ms = n }, } ); - new Sut( factory, conf, emitter, timer ); + const sut = new Sut( factory, conf, emitter, timer ); emitter.emit( 'delta-process-start', uid ); emitter.emit( 'delta-process-end', uid ); expect( actual_ms ).to.be.equal( expected_ms ); + + sut.stop(); } ); } ); |