Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

registryprune

package

Go to main page

Versions in this module

v1

v1.0.40

Aug 24, 2026

v1.0.39

Aug 13, 2026

v1.0.38

Aug 10, 2026

v1.0.37

Aug 8, 2026

v1.0.36

Aug 8, 2026

v1.0.35

Aug 7, 2026

Changes in this version

+ const JobKind

+ const TickInterval

+ var ErrRunInFlight = errors.New("a registry prune run is already queued or running")

+ var ErrUnsafeToPrune = errors.New("unsafe to prune")

+ func Deletable(c Class, p Policy) bool

+ func ValidateRegistryHost(raw string) error

+ type BlobGC struct

+ ConfigPath string

+ HostID string

+ Image string

+ MountPath string

+ PodName string

+ Podman PodRunner

+ RegistryContainer string

+ RegistryPod string

+ SizePath string

+ StoragePath string

+ Timeout time.Duration

+ func (g *BlobGC) Reclaim(ctx context.Context, jc *jobs.JobContext, p Payload) (res Result, err error)

+ type Class string

+ const ClassCalVer

+ const ClassFeatRecent

+ const ClassFeatStale

+ const ClassInUse

+ const ClassProtected

+ const ClassRepoProtected

+ const ClassShaIsLatest

+ const ClassShaOrphan

+ const ClassSharesProtected

+ const ClassUnclassified

+ func Classify(repo string, tg imgregistry.TagGroup, inUse InUseSet, ...) Class

+ type Config struct

+ MaxSnapshotAge time.Duration

+ Now func() time.Time

+ RegistryHosts []string

+ type Handler struct

+ BlobGC *BlobGC

+ Config Config

+ Hosts HostEnumerator

+ Inventory InventorySource

+ Metrics Metrics

+ Registry imgregistry.Client

+ Specs SpecSource

+ func (h *Handler) Run(ctx context.Context, job store.Job, jc *jobs.JobContext) error

+ type HostEnumerator interface

+ Hosts func() []config.Host

+ type InUseSet struct

+ Digests map[string]struct{}

+ ForeignSkipped []string

+ NonDigestObserved []string

+ Valid bool

+ func BuildInUseSet(ctx context.Context, hostSrc HostEnumerator, inv InventorySource, ...) (InUseSet, error)

+ func (s InUseSet) Has(digest string) bool

+ func (s InUseSet) Len() int

+ type InventorySource interface

+ ListAllInstancesWithMeta func(ctx context.Context, host string) ([]instance.Observed, instance.Freshness, error)

+ type ManifestResolver interface

+ Catalog func(ctx context.Context) ([]string, error)

+ Manifest func(ctx context.Context, repo, ref string) (imgregistry.Manifest, error)

+ type Metrics interface

+ BytesReclaimed func(bytes int64)

+ ManifestsDeleted func(repo string, n int)

+ RepoSkipped func(repo string, candidates int)

+ RunDone func(result string)

+ type Payload struct

+ DryRun bool

+ Policy Policy

+ SkipBlobGC bool

+ type PodRunner interface

+ ContainerExec func(ctx context.Context, hostID, container string, cmd []string) (podman.ExecResult, error)

+ PlayKube func(ctx context.Context, hostID, yaml string, replace bool, networks ...string) error

+ PodRemove func(ctx context.Context, hostID, name string, force bool) error

+ PodStart func(ctx context.Context, hostID, name string) error

+ PodStop func(ctx context.Context, hostID, name string) error

+ WaitForPodCompletion func(ctx context.Context, hostID, podName string, timeout time.Duration) (int, error)

+ type Policy struct

+ CalVer *regexp.Regexp

+ DeleteUnrecognised bool

+ ExtraPerRepo map[string]*regexp.Regexp

+ MaxDeletesPerRepo int

+ ProtectedExact []string

+ RetentionDays int

+ func DefaultPolicy() Policy

+ type Result struct

+ After int64

+ Before int64

+ Measured bool

+ Reclaimed int64

+ type Scheduler struct

+ Interval time.Duration

+ Now func() time.Time

+ Payload func() Payload

+ Store store.JobStore

+ func (s *Scheduler) EnqueueNow(ctx context.Context) (store.Job, error)

+ func (s *Scheduler) Start(ctx context.Context)

+ func (s *Scheduler) Wait()

+ type SpecSource interface

+ GetSpec func(ctx context.Context, host, template, slug string) (store.Spec, error)

+ ListSpecKeys func(ctx context.Context, host string) ([]store.SpecKey, error)