diff --git a/internal/metricstore/checkpoint.go b/internal/metricstore/checkpoint.go index fb72fc6e..b5511221 100644 --- a/internal/metricstore/checkpoint.go +++ b/internal/metricstore/checkpoint.go @@ -408,7 +408,6 @@ func (m *MemoryStore) FromCheckpointFiles(dir string, from int64) (int, error) { return m.FromCheckpoint(dir, from, altFormat) } - cclog.Info("[METRICSTORE]> No valid checkpoint files found") return 0, nil } diff --git a/internal/taskmanager/ldapSyncService.go b/internal/taskmanager/ldapSyncService.go index 9e99a261..55a99bab 100644 --- a/internal/taskmanager/ldapSyncService.go +++ b/internal/taskmanager/ldapSyncService.go @@ -23,7 +23,8 @@ func RegisterLdapSyncService(ds string) { auth := auth.GetAuthInstance() - cclog.Info("Register LDAP sync service") + cclog.Infof("register ldap sync service with %s interval", ds) + s.NewJob(gocron.DurationJob(interval), gocron.NewTask( func() { @@ -32,6 +33,5 @@ func RegisterLdapSyncService(ds string) { if err := auth.LdapAuth.Sync(); err != nil { cclog.Errorf("ldap sync failed: %s", err.Error()) } - cclog.Print("ldap sync done") })) } diff --git a/internal/taskmanager/taskManager.go b/internal/taskmanager/taskManager.go index e1388c86..cbc4120f 100644 --- a/internal/taskmanager/taskManager.go +++ b/internal/taskmanager/taskManager.go @@ -18,7 +18,7 @@ import ( ) const ( - DefaultCompressOlderThen = 7 + DefaultCompressOlderThan = 7 ) // Retention defines the configuration for job retention policies. @@ -92,7 +92,7 @@ func initArchiveServices(config json.RawMessage) { if cfg.Compression > 0 { RegisterCompressionService(cfg.Compression) } else { - RegisterCompressionService(DefaultCompressOlderThen) + RegisterCompressionService(DefaultCompressOlderThan) } } @@ -118,6 +118,9 @@ func Start(cronCfg, archiveConfig json.RawMessage) { if archiveConfig != nil { initArchiveServices(archiveConfig) + } else { + // Always enable compression + RegisterCompressionService(DefaultCompressOlderThan) } lc := auth.Keys.LdapConfig