Method Delete

core/metadata/content.go:204–243

(ctx context.Context, dgst digest.Digest)

}

func (cs *contentStore) Delete(ctx context.Context, dgst digest.Digest) error {
	ns, err := namespaces.NamespaceRequired(ctx)
	if err != nil {
		return err
	}

	cs.l.RLock()
	defer cs.l.RUnlock()

	if err := update(ctx, cs.db, func(tx *bolt.Tx) error {
		bkt := getBlobBucket(tx, ns, dgst)
		if bkt == nil {
			return fmt.Errorf("content digest %v: %w", dgst, errdefs.ErrNotFound)
		}

		if err := getBlobsBucket(tx, ns).DeleteBucket([]byte(dgst.String())); err != nil {
			return err
		}
		if err := removeContentLease(ctx, tx, dgst); err != nil {
			return err
		}

		// Mark content store as dirty for triggering garbage collection
		cs.db.dirty.Add(1)
		cs.db.dirtyCS = true

		return nil
	}); err != nil {
		return err
	}

	if publisher := cs.db.Publisher(ctx); publisher != nil {
		if err := publisher.Publish(ctx, "/content/delete", &eventstypes.ContentDelete{
			Digest: dgst.String(),
		}); err != nil {
			return err
		}
	}
	return nil
}

func (cs *contentStore) ListStatuses(ctx context.Context, fs ...string) ([]content.Status, error) {
	ns, err := namespaces.NamespaceRequired(ctx)