File tree Expand file tree Collapse file tree 1 file changed +11
-1
lines changed Expand file tree Collapse file tree 1 file changed +11
-1
lines changed Original file line number Diff line number Diff line change 1
1
import {
2
+ closeable ,
3
+ Closeable ,
2
4
Sequencer ,
3
5
SequencerModule ,
4
6
sequencerModule ,
@@ -32,10 +34,13 @@ export type OpenTelemetryServerConfig = {
32
34
} ;
33
35
34
36
@sequencerModule ( )
37
+ @closeable ( )
35
38
export class OpenTelemetryServer
36
39
extends SequencerModule < OpenTelemetryServerConfig >
37
- implements DependencyFactory
40
+ implements DependencyFactory , Closeable
38
41
{
42
+ private sdk ?: NodeSDK ;
43
+
39
44
public constructor (
40
45
@inject ( "Sequencer" ) private readonly sequencer : Sequencer < any >
41
46
) {
@@ -92,10 +97,15 @@ export class OpenTelemetryServer
92
97
} ) ;
93
98
94
99
sdk . start ( ) ;
100
+ this . sdk = sdk ;
95
101
96
102
// TODO Write logger to directly integrate with our logging library
97
103
diag . setLogger ( new DiagConsoleLogger ( ) , DiagLogLevel . ERROR ) ;
98
104
99
105
log . info ( "OpenTelemetryServer started" ) ;
100
106
}
107
+
108
+ public async close ( ) {
109
+ await this . sdk ?. shutdown ( ) ;
110
+ }
101
111
}
You can’t perform that action at this time.
0 commit comments