client

Oct 24, 2026

Changes in this version

+ var ErrResponseTooLarge = errors.New("response body too large")

type Client

+ MaxResponseSize int64

+ MaxStreamSize int64

+ func (c *Client) GetJSONWithHeaders(ctx context.Context, url string, headers http.Header, v any) (http.Header, error)

+ func (c *Client) StreamJSON(ctx context.Context, url string, fn func(*json.Decoder) error) error

type Option

+ func WithMaxResponseSize(n int64) Option

+ func WithMaxStreamSize(n int64) Option

Oct 18, 2026

Changes in this version

+ var ErrUpstreamHeld = errors.New("upstream requests are held by rate limiting")

+ type HeldError struct

+ Host string

+ RetryAfter time.Duration

+ Until time.Time

+ func (e *HeldError) Error() string

+ func (e *HeldError) Is(target error) bool

+ type HoldEvent struct

+ FromHeader bool

+ Host string

+ RetryAfter time.Duration

+ Until time.Time

+ type RateLimitGate struct

+ OnHold func(HoldEvent)

+ OnRelease func(host string)

+ func NewRateLimitGate(base http.RoundTripper) *RateLimitGate

+ func (g *RateLimitGate) Held(rawURL string) error

+ func (g *RateLimitGate) Holds() map[string]time.Time

+ func (g *RateLimitGate) RoundTrip(req *http.Request) (*http.Response, error)

Sep 26, 2026

Changes in this version

+ var ErrNotFound = errors.New("not found")

+ func BuildURLs(urls URLBuilder, name, version string) map[string]string

+ type BaseURLs struct

+ DocumentationFn func(name, version string) string

+ DownloadFn func(name, version string) string

+ PURLFn func(name, version string) string

+ RegistryFn func(name, version string) string

+ func (b *BaseURLs) Documentation(name, version string) string

+ func (b *BaseURLs) Download(name, version string) string

+ func (b *BaseURLs) PURL(name, version string) string

+ func (b *BaseURLs) Registry(name, version string) string

+ type Client struct

+ BaseDelay time.Duration

+ HTTPClient *http.Client

+ MaxRetries int

+ RateLimiter RateLimiter

+ UserAgent string

+ func DefaultClient() *Client

+ func NewClient(opts ...Option) *Client

+ func (c *Client) GetBody(ctx context.Context, url string) ([]byte, error)

+ func (c *Client) GetJSON(ctx context.Context, url string, v any) error

+ func (c *Client) GetText(ctx context.Context, url string) (string, error)

+ func (c *Client) Head(ctx context.Context, url string) (int, error)

+ func (c *Client) WithRateLimiter(rl RateLimiter) *Client

+ func (c *Client) WithUserAgent(ua string) *Client

+ type HTTPError struct

+ Body string

+ StatusCode int

+ URL string

+ func (e *HTTPError) Error() string

+ func (e *HTTPError) IsNotFound() bool

+ type NotFoundError struct

+ Ecosystem string

+ Name string

+ Version string

+ func (e *NotFoundError) Error() string

+ func (e *NotFoundError) Unwrap() error

+ type Option func(*Client)

+ func WithHTTPClient(h *http.Client) Option

+ func WithMaxRetries(n int) Option

+ func WithSafeHTTP() Option

+ func WithTimeout(d time.Duration) Option

+ func WithTransport(rt http.RoundTripper) Option

+ type RateLimitError struct

+ RetryAfter int

+ func (e *RateLimitError) Error() string

+ type RateLimiter interface

+ Wait func(ctx context.Context) error

+ type URLBuilder interface

+ Documentation func(name, version string) string

+ Download func(name, version string) string

+ PURL func(name, version string) string

+ Registry func(name, version string) string