Cleanup print statements. Always enable Compression

This commit is contained in:
2026-01-15 13:39:22 +01:00
parent 155e05495e
commit 72248defbf
3 changed files with 7 additions and 5 deletions

View File

@@ -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
}

View File

@@ -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")
}))
}

View File

@@ -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