diff --git a/daemon/containerd/image_exporter.go b/daemon/containerd/image_exporter.go index 2c6e671a0b..62482d0135 100644 --- a/daemon/containerd/image_exporter.go +++ b/daemon/containerd/image_exporter.go @@ -113,6 +113,8 @@ func (i *ImageService) ExportImage(ctx context.Context, names []string, outStrea "target": target, }).Debug("export image without name") } + + i.LogImageEvent(target.Digest.String(), target.Digest.String(), events.ActionSave) } return i.client.Export(ctx, outStream, opts...) diff --git a/daemon/containerd/image_pull.go b/daemon/containerd/image_pull.go index ab53bd135b..95c5bd2015 100644 --- a/daemon/containerd/image_pull.go +++ b/daemon/containerd/image_pull.go @@ -11,6 +11,7 @@ import ( "github.com/containerd/containerd/pkg/snapshotters" "github.com/containerd/containerd/platforms" "github.com/distribution/reference" + "github.com/docker/docker/api/types/events" "github.com/docker/docker/api/types/registry" "github.com/docker/docker/errdefs" "github.com/docker/docker/pkg/streamformatter" @@ -88,5 +89,8 @@ func (i *ImageService) PullImage(ctx context.Context, image, tagOrDigest string, // error to not mark the pull as failed. logger.WithError(err).Warn("unexpected error while removing outdated dangling image reference") } + + i.LogImageEvent(reference.FamiliarString(ref), reference.FamiliarName(ref), events.ActionPull) + return nil } diff --git a/daemon/containerd/image_push.go b/daemon/containerd/image_push.go index 78c196c442..36d83c2839 100644 --- a/daemon/containerd/image_push.go +++ b/daemon/containerd/image_push.go @@ -16,6 +16,7 @@ import ( "github.com/containerd/containerd/remotes" "github.com/containerd/containerd/remotes/docker" "github.com/distribution/reference" + "github.com/docker/docker/api/types/events" "github.com/docker/docker/api/types/registry" "github.com/docker/docker/errdefs" "github.com/docker/docker/pkg/progress" @@ -147,6 +148,9 @@ func (i *ImageService) PushImage(ctx context.Context, targetRef reference.Named, } } + if err == nil { + i.LogImageEvent(reference.FamiliarString(targetRef), reference.FamiliarName(targetRef), events.ActionPush) + } return err }