File tree Expand file tree Collapse file tree 1 file changed +17
-16
lines changed Expand file tree Collapse file tree 1 file changed +17
-16
lines changed Original file line number Diff line number Diff line change @@ -60,6 +60,22 @@ async function monitor(): Promise<void> {
6060 }
6161}
6262
63+ async function setupSysdigIntegration ( ) : Promise < void > {
64+ if ( ! config . SYSDIG_ENDPOINT || ! config . SYSDIG_TOKEN ) {
65+ logger . info ( { } , 'Sysdig integration not detected' ) ;
66+ return ;
67+ }
68+
69+ const interval : number = 4 * 60 * 60 * 1000 ; // 4 hours in milliseconds
70+ setInterval ( async ( ) => {
71+ try {
72+ await scrapeData ( ) ;
73+ } catch ( error ) {
74+ logger . error ( { error } , 'an error occurred while scraping runtime data' ) ;
75+ }
76+ } , interval ) . unref ( ) ;
77+ }
78+
6379SourceMapSupport . install ( ) ;
6480cleanUpTempStorage ( ) ;
6581
@@ -69,20 +85,5 @@ setImmediate(async function setUpAndMonitor(): Promise<void> {
6985 await sendClusterMetadata ( ) ;
7086 await loadAndSendWorkloadEventsPolicy ( ) ;
7187 await monitor ( ) ;
72-
73- const interval : number = 4 * 60 * 60 * 1000 ; // 4 hours in milliseconds
74- if ( config . SYSDIG_ENDPOINT && config . SYSDIG_TOKEN ) {
75- setInterval ( async ( ) => {
76- try {
77- await scrapeData ( ) ;
78- } catch ( error ) {
79- logger . error (
80- { error } ,
81- 'an error occurred while scraping runtime data' ,
82- ) ;
83- }
84- } , interval ) . unref ( ) ;
85- } else {
86- logger . info ( { } , 'Sysdig integration not detected' ) ;
87- }
88+ await setupSysdigIntegration ( ) ;
8889} ) ;
You can’t perform that action at this time.
0 commit comments