content

type BlobLister interface {
	Blob(ctx context.Context) iter.Seq[digest.Digest]
}

type BlobStore interface {
	Ingester
	Provider
	Remover
}

type BlobWriter interface {
	io.WriteCloser

	ID() string
	Digest(ctx context.Context) digest.Digest
	Size(ctx context.Context) int64
	Cancel(ctx context.Context) error
	Commit(ctx context.Context, expected manifestv1.Descriptor) (*manifestv1.Descriptor, error)
}

type DigestIterable interface {
	Digests(ctx context.Context) iter.Seq2[digest.Digest, error]
}

type Ingester interface {
	Writer(ctx context.Context) (BlobWriter, error)
	Resume(ctx context.Context, id string) (BlobWriter, error)
}

type LinkedDigest struct {
	Digest  digest.Digest
	ModTime time.Time
}

type LinkedDigestIterable interface {
	LinkedDigests(ctx context.Context) iter.Seq2[LinkedDigest, error]
}

type ManifestService interface {
	Info(ctx context.Context, dgst digest.Digest) (*manifestv1.Descriptor, error)
	Get(ctx context.Context, dgst digest.Digest) (manifestv1.Manifest, error)
	Put(ctx context.Context, manifest manifestv1.Manifest) (digest.Digest, error)
	Delete(ctx context.Context, dgst digest.Digest) error
}

type Namespace interface {
	Repository(ctx context.Context, named reference.Named) (Repository, error)
}

type PersistNamespaceWrapper interface {
	UnwarpPersistNamespace() Namespace
}

type Provider interface {
	Info(ctx context.Context, dgst digest.Digest) (*manifestv1.Descriptor, error)
	Open(ctx context.Context, dgst digest.Digest) (io.ReadCloser, error)
}

type Remover interface {
	Remove(ctx context.Context, dgst digest.Digest) error
}

type Repository interface {
	Named() reference.Named
	Manifests(ctx context.Context) (ManifestService, error)
	Tags(ctx context.Context) (TagService, error)
	Blobs(ctx context.Context) (BlobStore, error)
}

type RepositoryNameIterable interface {
	RepositoryNames(ctx context.Context) iter.Seq2[reference.Named, error]
}

type TagRevisionIterable interface {
	TagRevisions(ctx context.Context, tag string) iter.Seq2[LinkedDigest, error]
}

type TagService interface {
	Get(ctx context.Context, tag string) (*manifestv1.Descriptor, error)
	Tag(ctx context.Context, tag string, desc manifestv1.Descriptor) error
	Untag(ctx context.Context, tag string) error
	All(ctx context.Context) ([]string, error)
}