@@ -29,6 +29,7 @@ import (
29
29
"github.com/goharbor/harbor/src/lib/retry"
30
30
"github.com/goharbor/harbor/src/pkg"
31
31
"github.com/goharbor/harbor/src/pkg/project"
32
+ "github.com/goharbor/harbor/src/pkg/project/metadata"
32
33
"github.com/goharbor/harbor/src/pkg/repository"
33
34
"github.com/goharbor/harbor/src/pkg/retention"
34
35
"github.com/goharbor/harbor/src/pkg/retention/policy"
@@ -80,14 +81,16 @@ type defaultController struct {
80
81
launcher retention.Launcher
81
82
projectManager project.Manager
82
83
repositoryMgr repository.Manager
84
+ projectMetaMgr metadata.Manager
83
85
scheduler scheduler.Scheduler
84
86
wp * lib.WorkerPool
85
87
}
86
88
87
89
const (
88
90
// SchedulerCallback ...
89
- SchedulerCallback = "RETENTION"
90
- schedulerVendorType = job .RetentionVendorType
91
+ SchedulerCallback = "RETENTION"
92
+ schedulerVendorType = job .RetentionVendorType
93
+ retentionPolicyMetaKey = "retention_id"
91
94
)
92
95
93
96
// TriggerParam ...
@@ -214,6 +217,7 @@ func (r *defaultController) DeleteRetention(ctx context.Context, id int64) error
214
217
if err != nil {
215
218
return err
216
219
}
220
+
217
221
return r .manager .DeletePolicy (ctx , id )
218
222
}
219
223
@@ -459,6 +463,7 @@ func NewController() Controller {
459
463
launcher : retentionLauncher ,
460
464
projectManager : pkg .ProjectMgr ,
461
465
repositoryMgr : pkg .RepositoryMgr ,
466
+ projectMetaMgr : pkg .ProjectMetaMgr ,
462
467
scheduler : scheduler .Sched ,
463
468
wp : lib .NewWorkerPool (10 ),
464
469
}
0 commit comments