fluxcd
/
source-controller
mirror of https://github.com/fluxcd/source-controller.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

reconcilers: include artifact digest in event meta 

Signed-off-by: Hidde Beydals <hello@hidde.co>
This commit is contained in:
Hidde Beydals 2022-11-07 13:48:25 +00:00
parent 1ddc6340c1
commit 51c030e43c
5 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
controllers/bucket_controller.go
View File

@ -386,6 +386,9 @@ func (r *BucketReconciler) notify(ctx context.Context, oldObj, newObj *sourcev1.
sourcev1.GroupVersion.Group + "/revision": newObj.Status.Artifact.Revision, sourcev1.GroupVersion.Group + "/revision": newObj.Status.Artifact.Revision,
sourcev1.GroupVersion.Group + "/checksum": newObj.Status.Artifact.Checksum, sourcev1.GroupVersion.Group + "/checksum": newObj.Status.Artifact.Checksum,
} }
if newObj.Status.Artifact.Digest != "" {
annotations[sourcev1.GroupVersion.Group+"/digest"] = newObj.Status.Artifact.Digest
}
var oldChecksum string var oldChecksum string
if oldObj.GetArtifact() != nil { if oldObj.GetArtifact() != nil {

3
controllers/gitrepository_controller.go
View File

@ -306,6 +306,9 @@ func (r *GitRepositoryReconciler) notify(ctx context.Context, oldObj, newObj *so
sourcev1.GroupVersion.Group + "/revision": newObj.Status.Artifact.Revision, sourcev1.GroupVersion.Group + "/revision": newObj.Status.Artifact.Revision,
sourcev1.GroupVersion.Group + "/checksum": newObj.Status.Artifact.Checksum, sourcev1.GroupVersion.Group + "/checksum": newObj.Status.Artifact.Checksum,
} }
if newObj.Status.Artifact.Digest != "" {
annotations[sourcev1.GroupVersion.Group+"/digest"] = newObj.Status.Artifact.Digest
}
var oldChecksum string var oldChecksum string
if oldObj.GetArtifact() != nil { if oldObj.GetArtifact() != nil {

3
controllers/helmchart_controller.go
View File

@ -311,6 +311,9 @@ func (r *HelmChartReconciler) notify(ctx context.Context, oldObj, newObj *source
sourcev1.GroupVersion.Group + "/revision": newObj.Status.Artifact.Revision, sourcev1.GroupVersion.Group + "/revision": newObj.Status.Artifact.Revision,
sourcev1.GroupVersion.Group + "/checksum": newObj.Status.Artifact.Checksum, sourcev1.GroupVersion.Group + "/checksum": newObj.Status.Artifact.Checksum,
} }
if newObj.Status.Artifact.Digest != "" {
annotations[sourcev1.GroupVersion.Group+"/digest"] = newObj.Status.Artifact.Digest
}
var oldChecksum string var oldChecksum string
if oldObj.GetArtifact() != nil { if oldObj.GetArtifact() != nil {

3
controllers/helmrepository_controller.go
View File

@ -271,6 +271,9 @@ func (r *HelmRepositoryReconciler) notify(ctx context.Context, oldObj, newObj *s
sourcev1.GroupVersion.Group + "/revision": newObj.Status.Artifact.Revision, sourcev1.GroupVersion.Group + "/revision": newObj.Status.Artifact.Revision,
sourcev1.GroupVersion.Group + "/checksum": newObj.Status.Artifact.Checksum, sourcev1.GroupVersion.Group + "/checksum": newObj.Status.Artifact.Checksum,
} }
if newObj.Status.Artifact.Digest != "" {
annotations[sourcev1.GroupVersion.Group+"/digest"] = newObj.Status.Artifact.Digest
}
humanReadableSize := "unknown size" humanReadableSize := "unknown size"
if size := newObj.Status.Artifact.Size; size != nil { if size := newObj.Status.Artifact.Size; size != nil {

3
controllers/ocirepository_controller.go
View File

@ -1101,6 +1101,9 @@ func (r *OCIRepositoryReconciler) notify(ctx context.Context, oldObj, newObj *so
sourcev1.GroupVersion.Group + "/revision": newObj.Status.Artifact.Revision, sourcev1.GroupVersion.Group + "/revision": newObj.Status.Artifact.Revision,
sourcev1.GroupVersion.Group + "/checksum": newObj.Status.Artifact.Checksum, sourcev1.GroupVersion.Group + "/checksum": newObj.Status.Artifact.Checksum,
} }
if newObj.Status.Artifact.Digest != "" {
annotations[sourcev1.GroupVersion.Group+"/digest"] = newObj.Status.Artifact.Digest
}
var oldChecksum string var oldChecksum string
if oldObj.GetArtifact() != nil { if oldObj.GetArtifact() != nil {