@@ -183,26 +183,26 @@ func (auditor *AzureAuditor) Run() {
183
183
}
184
184
}
185
185
186
- // if cronspecIsValid(auditor.Opts.Cronjobs.LogAnalytics) && auditor.config.LogAnalytics.IsEnabled() {
187
- // for key, queryConfig := range auditor.config.LogAnalytics.Queries {
188
- // queryName := key
189
- // logAnalyticsConfig := queryConfig
190
- // auditor.addCronjob(
191
- // fmt.Sprintf(ReportLogAnalytics, queryName),
192
- // auditor.Opts.Cronjobs.LogAnalytics,
193
- // func(ctx context.Context, logger *log.Entry) {
194
- // auditor.config.LogAnalytics.Queries[queryName].Reset()
195
- // },
196
- // func(ctx context.Context, logger *log.Entry, report *AzureAuditorReport, callback chan<- func()) {
197
- // contextLogger := log.WithField("configQueryName", queryName)
198
- // auditor.auditLogAnalytics(ctx, contextLogger, queryName, logAnalyticsConfig, report, callback)
199
- // },
200
- // func(ctx context.Context, logger *log.Entry) {
201
- // auditor.prometheus.logAnalytics[queryName].Reset()
202
- // },
203
- // )
204
- // }
205
- // }
186
+ if cronspecIsValid (auditor .Opts .Cronjobs .LogAnalytics ) && auditor .config .LogAnalytics .IsEnabled () {
187
+ for key , queryConfig := range auditor .config .LogAnalytics .Queries {
188
+ queryName := key
189
+ logAnalyticsConfig := queryConfig
190
+ auditor .addCronjob (
191
+ fmt .Sprintf (ReportLogAnalytics , queryName ),
192
+ auditor .Opts .Cronjobs .LogAnalytics ,
193
+ func (ctx context.Context , logger * log.Entry ) {
194
+ auditor .config .LogAnalytics .Queries [queryName ].Reset ()
195
+ },
196
+ func (ctx context.Context , logger * log.Entry , report * AzureAuditorReport , callback chan <- func ()) {
197
+ contextLogger := log .WithField ("configQueryName" , queryName )
198
+ auditor .auditLogAnalytics (ctx , contextLogger , queryName , logAnalyticsConfig , report , callback )
199
+ },
200
+ func (ctx context.Context , logger * log.Entry ) {
201
+ auditor .prometheus .logAnalytics [queryName ].Reset ()
202
+ },
203
+ )
204
+ }
205
+ }
206
206
207
207
// check if cron jobs are active
208
208
cronjobEntries := auditor .cron .Entries ()
0 commit comments