ClusterCockpit/cc-backend
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-backend synced 2025-12-16 12:16:16 +01:00
Code Issues Packages Releases Activity

feat: Add omitTagged flag for retention services

Browse Source 
Fixes #344
This commit is contained in:
Jan Eitzinger
2025-12-15 13:44:17 +01:00
parent cfa7461855
commit 72ce3954b4
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
internal/taskManager/retentionService.go
View File

@@ -13,14 +13,14 @@ import (
"github.com/go-co-op/gocron/v2" "github.com/go-co-op/gocron/v2"
) )
func RegisterRetentionDeleteService(age int, includeDB bool) { func RegisterRetentionDeleteService(age int, includeDB bool, omitTagged bool) {
cclog.Info("Register retention delete service") cclog.Info("Register retention delete service")
s.NewJob(gocron.DailyJob(1, gocron.NewAtTimes(gocron.NewAtTime(0o4, 0, 0))), s.NewJob(gocron.DailyJob(1, gocron.NewAtTimes(gocron.NewAtTime(0o4, 0, 0))),
gocron.NewTask( gocron.NewTask(
func() { func() {
startTime := time.Now().Unix() - int64(age*24*3600) startTime := time.Now().Unix() - int64(age*24*3600)
jobs, err := jobRepo.FindJobsBetween(0, startTime, false) jobs, err := jobRepo.FindJobsBetween(0, startTime, omitTagged)
if err != nil { if err != nil {
cclog.Warnf("Error while looking for retention jobs: %s", err.Error()) cclog.Warnf("Error while looking for retention jobs: %s", err.Error())
} }
@@ -40,14 +40,14 @@ func RegisterRetentionDeleteService(age int, includeDB bool) {
})) }))
} }
func RegisterRetentionMoveService(age int, includeDB bool, location string) { func RegisterRetentionMoveService(age int, includeDB bool, location string, omitTagged bool) {
cclog.Info("Register retention move service") cclog.Info("Register retention move service")
s.NewJob(gocron.DailyJob(1, gocron.NewAtTimes(gocron.NewAtTime(0o4, 0, 0))), s.NewJob(gocron.DailyJob(1, gocron.NewAtTimes(gocron.NewAtTime(0o4, 0, 0))),
gocron.NewTask( gocron.NewTask(
func() { func() {
startTime := time.Now().Unix() - int64(age*24*3600) startTime := time.Now().Unix() - int64(age*24*3600)
jobs, err := jobRepo.FindJobsBetween(0, startTime, false) jobs, err := jobRepo.FindJobsBetween(0, startTime, omitTagged)
if err != nil { if err != nil {
cclog.Warnf("Error while looking for retention jobs: %s", err.Error()) cclog.Warnf("Error while looking for retention jobs: %s", err.Error())
} }