handler

Oct 31, 2026

Changes in this version

+ const HostedGenericRepository

+ var ErrHostedChecksumMismatch = errors.New("pushed bytes don't match the expected sha256")

+ var ErrHostedExists = errors.New("this file was already pushed; delete it first to push it again")

+ var ErrHostedFileNotFound = errors.New("no pushed file of this name for this version")

+ var ErrUnsupportedDigest = errors.New("unsupported digest")

+ func ComposerReleaseArchive(version, distURL, distType, shasum string) (filename, declared string, err error)

+ func CondaFilenameIdentity(filename string) (name, version string)

+ func CooldownSupported(ecosystem string) bool

+ func HostedFileInPath(ecosystem string) bool

+ func JuliaPackageDownload(upstreamURL, uuid, treeHash string) (url, filename string, err error)

+ func PyPIFilenameIdentity(filename string) (name, version string)

+ func RoutedFilenamePrefix(routeURL string) string

+ func RoutedPackageURL(routes map[string]string, packageName string) (string, bool)

+ func ServingHead(ctx context.Context) context.Context

+ func StreamCacheMiss(ctx context.Context) context.Context

+ func SwiftIdentityOf(body []byte, sourceURL string) (scope, name string, _ error)

+ func SwiftSourcePURL(p *purl.PURL) string

+ func SwiftSourceURL(name string) string

+ func ValidateHostedPath(ecosystem, name, version, filename string) error

+ func WithUpstreamLastModified(ctx context.Context, fn func(time.Time)) context.Context

+ type ArtifactRoute struct

+ FilenamePrefix string

+ Resolver *fetch.Resolver

+ type FreeBSDHandler struct

+ func NewFreeBSDHandler(proxy *Proxy, proxyURL string, repositories map[string]string) *FreeBSDHandler

+ func (h *FreeBSDHandler) Routes() http.Handler

type GenericHandler

+ func (h *GenericHandler) WithPaths(paths map[string][]string) *GenericHandler

+ type GitHandler struct

+ func NewGitHandler(proxy *Proxy, cache *gitcache.Cache, upstream config.UpstreamConfig) *GitHandler

+ func (h *GitHandler) Routes() http.Handler

+ func (h *GitHandler) WithBaseURL(baseURL string) *GitHandler

type GoHandler

+ func (h *GoHandler) SetVulnDB(vulnDBURL string)

type HelmHandler

+ func (h *HelmHandler) MirrorChart(ctx context.Context, repository, chart, version string) (*CacheResult, error)

type HomebrewHandler

+ func (h *HomebrewHandler) BottleImage(ctx context.Context, formula, version string) (ImageRef, error)

type MavenHandler

+ func (h *MavenHandler) WithRepositories(repositories map[string]string) *MavenHandler

type Proxy

+ RouteFor func(ecosystem, name string) *ArtifactRoute

+ ShortestCooldown time.Duration

+ func (p *Proxy) CheckPush(ecosystem string, target HostedTarget) error

+ func (p *Proxy) DeleteLocalFile(ecosystem, name, version, filename string) error

+ func (p *Proxy) ReadMetadataSized(r io.Reader, size int64) ([]byte, error)

+ func (p *Proxy) RecordComposerPublishTime(packageName, version string, publishedAt time.Time) error

type SwiftHandler

+ func (h *SwiftHandler) MirrorRelease(ctx context.Context, scope, name, version string) (*CacheResult, error)

+ func (h *SwiftHandler) ResolveIdentities(ctx context.Context, sourceURL string) ([]SwiftIdentity, error)

+ func (h *SwiftHandler) ResolveIdentity(ctx context.Context, sourceURL string) (scope, name string, _ error)

+ func (h *SwiftHandler) ResolveSourcePURL(ctx context.Context, p *purl.PURL) ([]*purl.PURL, error)

+ type SwiftIdentity struct

+ Name string

+ Scope string

+ func SwiftIdentitiesOf(body []byte, sourceURL string) ([]SwiftIdentity, error)

+ type UpstreamHolds interface

+ Held func(rawURL string) error

Oct 20, 2026

Changes in this version

+ var ErrHostedArtifactMissing = errors.New("pushed artifact is no longer stored")

+ var ErrHostedArtifactUnavailable = errors.New("pushed artifact is stored but can't be read")

+ var ErrHostedInvalidArchive = errors.New("archive has no readable package manifest")

+ var ErrHostedInvalidName = errors.New("invalid package name or version")

+ var ErrHostedManifestMismatch = errors.New("package manifest does not match the pushed name and version")

+ var ErrHostedUnsupported = errors.New("pushing packages is not supported for this ecosystem")

+ var ErrHostedVersionNotFound = errors.New("no pushed artifacts for this version")

+ var ErrPackageNotFound = errors.New("package not found")

+ var ErrVersionNotFound = errors.New("version not found")

+ func DetachUpstreamFetch(ctx context.Context) context.Context

+ func HostedSupported(ecosystem string) bool

+ type ArchHandler struct

+ func NewArchHandler(proxy *Proxy, proxyURL string, repositories map[string]string) *ArchHandler

+ func (h *ArchHandler) Routes() http.Handler

+ type ChefHandler struct

+ func NewChefHandler(proxy *Proxy, proxyURL, upstreamURL string) *ChefHandler

+ func (h *ChefHandler) Routes() http.Handler

type ComposerHandler

+ func (h *ComposerHandler) WithPackageRoutes(routes map[string]string) *ComposerHandler

type ContainerHandler

+ func (h *ContainerHandler) MirrorImage(ctx context.Context, ref ImageRef, platforms []Platform) (ImageResult, error)

+ func (h *ContainerHandler) SetMirroredRegistries(mirrors map[string][]string)

type GoHandler

+ func (h *GoHandler) SetSumDBs(sumDBs map[string]string, offline bool)

+ type HostedArtifact struct

+ Filename string

+ PushedAt time.Time

+ SHA256 string

+ Size int64

+ Version string

+ type HostedTarget struct

+ Filename string

+ Name string

+ Version string

+ func HostedTargetFor(ecosystem, name, version string) (HostedTarget, error)

+ type ImageRef struct

+ Name string

+ References []string

+ Registry string

+ type ImageResult struct

+ Bytes int64

+ Fetched int

+ Warnings []string

type NPMHandler

+ func (h *NPMHandler) WithPackageRoutes(routes map[string]string) *NPMHandler

+ type Platform struct

+ Architecture string

+ OS string

+ Variant string

+ func ParsePlatform(value string) (Platform, error)

type Proxy

+ HostedComposerVendors []string

+ HostedEnabled bool

+ HostedNPMScopes []string

+ RateLimits *registryclient.RateLimitGate

+ func (p *Proxy) DeleteLocalVersion(ecosystem, name, version string) error

+ func (p *Proxy) GetLocalArtifact(ctx context.Context, ecosystem, name, version, filename string) (*CacheResult, error)

+ func (p *Proxy) GetOrFetchArtifactFromURLWithIntegrity(ctx context.Context, ...) (*CacheResult, error)

+ func (p *Proxy) HasCachedArtifact(ctx context.Context, ecosystem, name, version, filename string) (bool, error)

+ func (p *Proxy) LocalArtifacts(ecosystem, name string) ([]HostedArtifact, error)

+ func (p *Proxy) PushLocalArtifact(ctx context.Context, ecosystem string, target HostedTarget, body io.Reader, ...) (HostedArtifact, error)

Oct 5, 2026

Changes in this version

+ func ServeArtifactRequest(w http.ResponseWriter, r *http.Request, result *CacheResult)

+ type CooldownPolicy interface

+ Enabled func() bool

+ Evaluate func(ecosystem, packagePURL string, publishedAt, evaluatedAt time.Time) cooldown.Decision

+ For func(ecosystem, packagePURL string) time.Duration

+ IsAllowed func(ecosystem, packagePURL string, publishedAt time.Time) bool

type Proxy

+ StreamArtifacts bool

+ func (p *Proxy) SetMetadataRewriteCacheSize(maxBytes int64)

Oct 1, 2026

Changes in this version

+ var ErrVersionDenied = errors.New("package version blocked by denylist")

type HelmHandler

+ func NewHelmHandlerWithOCIRegistries(proxy *Proxy, proxyURL string, repositories map[string]string, ...) *HelmHandler

type Proxy

+ Denylist *denylist.Policy

Sep 4, 2026

Changes in this version

+ var ErrArtifactBlocked = errors.New("artifact blocked by security scan")

+ var ErrArtifactDigestMismatch = errors.New("artifact digest mismatch")

+ func RegisterHomebrewArtifacts(container *ContainerHandler, artifactUpstream string)

+ type APKHandler struct

+ func NewAPKHandler(proxy *Proxy, proxyURL string, repositories map[string]string) *APKHandler

+ func (h *APKHandler) Routes() http.Handler

type CRANHandler

+ func NewCRANHandlerWithUpstream(proxy *Proxy, proxyURL, upstreamURL string) *CRANHandler

type CacheResult

+ Artifact artifacts.Artifact

type ComposerHandler

+ func NewComposerHandlerWithUpstreams(proxy *Proxy, proxyURL, upstreamURL, repoURL string) *ComposerHandler

type ConanHandler

+ func NewConanHandlerWithUpstream(proxy *Proxy, proxyURL, upstreamURL string) *ConanHandler

type CondaHandler

+ func NewCondaHandlerWithUpstream(proxy *Proxy, proxyURL, upstreamURL string) *CondaHandler

type ContainerHandler

+ func NewContainerHandlerWithRegistry(proxy *Proxy, proxyURL, registryURL string, ...) *ContainerHandler

+ func (h *ContainerHandler) BlockRegistry(repositoryPrefix string)

+ func (h *ContainerHandler) RegisterRegistry(repositoryPrefix, registryURL string)

type GemHandler

+ func NewGemHandlerWithUpstream(proxy *Proxy, proxyURL, upstreamURL string) *GemHandler

+ type GenericHandler struct

+ func NewGenericHandler(proxy *Proxy, repositories map[string]string) *GenericHandler

+ func (h *GenericHandler) Routes() http.Handler

type GoHandler

+ func NewGoHandlerWithUpstream(proxy *Proxy, proxyURL, upstreamURL string) *GoHandler

+ type HelmHandler struct

+ func NewHelmHandler(proxy *Proxy, proxyURL string, repositories map[string]string) *HelmHandler

+ func (h *HelmHandler) Routes() http.Handler

type HexHandler

+ func NewHexHandlerWithUpstreams(proxy *Proxy, proxyURL, upstreamURL, apiURL string) *HexHandler

+ type HomebrewHandler struct

+ func NewHomebrewHandler(proxy *Proxy, apiUpstream string) *HomebrewHandler

+ func (h *HomebrewHandler) Routes() http.Handler

type JuliaHandler

+ func NewJuliaHandlerWithUpstream(proxy *Proxy, upstreamURL string) *JuliaHandler

type NuGetHandler

+ func NewNuGetHandlerWithUpstreams(proxy *Proxy, proxyURL, upstreamURL, searchURL string) *NuGetHandler

type Proxy

+ NPMFullMetadata bool

+ ScanFetchBaseURL string

+ ScanSigningKey []byte

+ Scanners *scanner.Group

+ func (p *Proxy) ClearCachedArtifact(ctx context.Context, ecosystem, name, version, filename string) error

+ func (p *Proxy) GetOrFetchArtifactFromURLWithDigest(ctx context.Context, ...) (*CacheResult, error)

+ func (p *Proxy) ServeScanFetch(w http.ResponseWriter, r *http.Request)

type PubHandler

+ func NewPubHandlerWithUpstream(proxy *Proxy, proxyURL, upstreamURL string) *PubHandler

type PyPIHandler

+ func NewPyPIHandlerWithUpstreams(proxy *Proxy, proxyURL, upstreamURL, downloadURL string) *PyPIHandler

type RPMHandler

+ func NewRPMHandlerWithUpstream(proxy *Proxy, proxyURL, upstreamURL string) *RPMHandler

+ type SwiftHandler struct

+ func NewSwiftHandler(proxy *Proxy, proxyURL, upstreamURL string) *SwiftHandler

+ func (h *SwiftHandler) Routes() http.Handler

Aug 14, 2026

Changes in this version

type Proxy

+ func (p *Proxy) GetCachedArtifact(ctx context.Context, ecosystem, name, version, filename string) (*CacheResult, error)

Aug 6, 2026

Changes in this version

+ const PyPIMetadataSuffix

Jul 27, 2026

Changes in this version

type Proxy

+ AuthForURL func(string) (headerName, headerValue string)

Jun 7, 2026

Changes in this version

type Proxy

+ MetadataMaxSize int64

+ func (p *Proxy) ReadMetadata(r io.Reader) ([]byte, error)

May 22, 2026

Changes in this version

+ type GradleBuildCacheHandler struct

+ func NewGradleBuildCacheHandler(proxy *Proxy) *GradleBuildCacheHandler

+ func (h *GradleBuildCacheHandler) Routes() http.Handler

+ type JuliaHandler struct

+ func NewJuliaHandler(proxy *Proxy, _ string) *JuliaHandler

+ func (h *JuliaHandler) Routes() http.Handler

type Proxy

+ GradleMaxUploadSize int64

+ GradleReadOnly bool

May 2, 2026

Changes in this version

+ var ErrMetadataTooLarge = errors.New("metadata response exceeds size limit")

+ var ErrUpstreamNotFound = fmt.Errorf("upstream: not found")

+ func JSONError(w http.ResponseWriter, status int, message string)

+ func ReadMetadata(r io.Reader) ([]byte, error)

+ func ServeArtifact(w http.ResponseWriter, result *CacheResult)

+ type CRANHandler struct

+ func NewCRANHandler(proxy *Proxy, proxyURL string) *CRANHandler

+ func (h *CRANHandler) Routes() http.Handler

+ type CacheResult struct

+ Cached bool

+ ContentType string

+ Hash string

+ Reader io.ReadCloser

+ RedirectURL string

+ Size int64

+ type CargoConfig struct

+ API string

+ DL string

+ type CargoHandler struct

+ func NewCargoHandler(proxy *Proxy, proxyURL string) *CargoHandler

+ func (h *CargoHandler) Routes() http.Handler

+ type ComposerHandler struct

+ func NewComposerHandler(proxy *Proxy, proxyURL string) *ComposerHandler

+ func (h *ComposerHandler) Routes() http.Handler

+ type ConanHandler struct

+ func NewConanHandler(proxy *Proxy, proxyURL string) *ConanHandler

+ func (h *ConanHandler) Routes() http.Handler

+ type CondaHandler struct

+ func NewCondaHandler(proxy *Proxy, proxyURL string) *CondaHandler

+ func (h *CondaHandler) Routes() http.Handler

+ type ContainerHandler struct

+ func NewContainerHandler(proxy *Proxy, proxyURL string) *ContainerHandler

+ func (h *ContainerHandler) Routes() http.Handler

+ type DebianHandler struct

+ func NewDebianHandler(proxy *Proxy, proxyURL string) *DebianHandler

+ func (h *DebianHandler) Routes() http.Handler

+ type GemHandler struct

+ func NewGemHandler(proxy *Proxy, proxyURL string) *GemHandler

+ func (h *GemHandler) Routes() http.Handler

+ type GoHandler struct

+ func NewGoHandler(proxy *Proxy, proxyURL string) *GoHandler

+ func (h *GoHandler) Routes() http.Handler

+ type HexHandler struct

+ func NewHexHandler(proxy *Proxy, proxyURL string) *HexHandler

+ func (h *HexHandler) Routes() http.Handler

+ type MavenHandler struct

+ func NewMavenHandler(proxy *Proxy, proxyURL string) *MavenHandler

+ func (h *MavenHandler) Routes() http.Handler

+ type NPMHandler struct

+ func NewNPMHandler(proxy *Proxy, proxyURL string) *NPMHandler

+ func (h *NPMHandler) Routes() http.Handler

+ type NuGetHandler struct

+ func NewNuGetHandler(proxy *Proxy, proxyURL string) *NuGetHandler

+ func (h *NuGetHandler) Routes() http.Handler

+ type Proxy struct

+ CacheMetadata bool

+ Cooldown *cooldown.Config

+ DB *database.DB

+ DirectServe bool

+ DirectServeBaseURL string

+ DirectServeTTL time.Duration

+ Fetcher fetch.FetcherInterface

+ HTTPClient *http.Client

+ Logger *slog.Logger

+ MetadataTTL time.Duration

+ Resolver *fetch.Resolver

+ Storage storage.Storage

+ func NewProxy(db *database.DB, store storage.Storage, fetcher fetch.FetcherInterface, ...) *Proxy

+ func (p *Proxy) FetchOrCacheMetadata(ctx context.Context, ecosystem, cacheKey, upstreamURL string, ...) ([]byte, string, error)

+ func (p *Proxy) GetOrFetchArtifact(ctx context.Context, ecosystem, name, version, filename string) (*CacheResult, error)

+ func (p *Proxy) GetOrFetchArtifactFromURL(ctx context.Context, ecosystem, name, version, filename, downloadURL string) (*CacheResult, error)

+ func (p *Proxy) GetOrFetchArtifactFromURLWithHeaders(ctx context.Context, ecosystem, name, version, filename, downloadURL string, ...) (*CacheResult, error)

+ func (p *Proxy) ProxyCached(w http.ResponseWriter, r *http.Request, ...)

+ func (p *Proxy) ProxyFile(w http.ResponseWriter, r *http.Request, upstreamURL string)

+ func (p *Proxy) ProxyUpstream(w http.ResponseWriter, r *http.Request, upstreamURL string, ...)

+ type PubHandler struct

+ func NewPubHandler(proxy *Proxy, proxyURL string) *PubHandler

+ func (h *PubHandler) Routes() http.Handler

+ type PyPIHandler struct

+ func NewPyPIHandler(proxy *Proxy, proxyURL string) *PyPIHandler

+ func (h *PyPIHandler) Routes() http.Handler

+ type RPMHandler struct

+ func NewRPMHandler(proxy *Proxy, proxyURL string) *RPMHandler

+ func (h *RPMHandler) Routes() http.Handler