httpclient

Jul 27, 2023

Changes in this version

type Option

+ func WithCustomMetrics(o RequestMeasurer) Option

+ type RequestMeasurer interface

+ MeasureRequest func(*http.Request, *http.Response, error, time.Duration)

Jul 4, 2023

Changes in this version

+ type Option func(current http.RoundTripper) http.RoundTripper

+ func WithInstrumentedCache(table CacheTable, defaultExpiry, cleanupInterval time.Duration, ...) Option

+ func WithInstrumentedLimiter(maxParallel int64, namespace, subsystem, application string) Option

+ func WithLimiter(maxParallel int64) Option

+ type RoundTripperFunc func(*http.Request) (*http.Response, error)

+ func (f RoundTripperFunc) RoundTrip(req *http.Request) (*http.Response, error)

Apr 21, 2023

Changes in this version

+ var DefaultCacheTable []*CacheTableEntry

Apr 20, 2023

Changes in this version

+ func WithMetrics(namespace, subsystem, application string) func(*RoundTripper)

Dec 10, 2022

Changes in this version

+ type Cache struct

+ Table CacheTable

+ func NewCache(table CacheTable, defaultExpiry, cleanupInterval time.Duration) *Cache

+ func (c *Cache) Get(req *http.Request) (string, *http.Response, bool, error)

+ func (c *Cache) Put(key string, req *http.Request, resp *http.Response) error

type CacheTableEntry

+ Path string

+ type RoundTripper struct

+ func NewRoundTripper(options ...RoundTripperOption) *RoundTripper

+ func (r *RoundTripper) Collect(metrics chan<- prometheus.Metric)

+ func (r *RoundTripper) Describe(descs chan<- *prometheus.Desc)

+ func (r *RoundTripper) RoundTrip(request *http.Request) (response *http.Response, err error)

+ type RoundTripperMetrics struct

+ func (pm *RoundTripperMetrics) Collect(ch chan<- prometheus.Metric)

+ func (pm *RoundTripperMetrics) Describe(ch chan<- *prometheus.Desc)

+ type RoundTripperOption interface

+ type WithCache struct

+ CleanupInterval time.Duration

+ DefaultExpiry time.Duration

+ Table CacheTable

+ type WithRoundTripper struct

+ RoundTripper http.RoundTripper

+ type WithRoundTripperMetrics struct

+ Application string

+ Namespace string

+ Subsystem string

Dec 6, 2022

Changes in this version

+ type BaseClient struct

+ HTTPClient *http.Client

+ func (b *BaseClient) Do(req *http.Request) (resp *http.Response, err error)

+ type CacheTable struct

+ Table []CacheTableEntry

+ type CacheTableEntry struct

+ Endpoint string

+ Expiry time.Duration

+ IsRegExp bool

+ Methods []string

+ type Cacher struct

+ Cache cache.Cacher[string, []byte]

+ Table CacheTable

+ func NewCacher(httpClient *http.Client, application string, options Options, ...) *Cacher

+ func (c *Cacher) Do(req *http.Request) (resp *http.Response, err error)

+ type Caller interface

+ Do func(req *http.Request) (resp *http.Response, err error)

+ type InstrumentedClient struct

+ Application string

+ Options Options

+ func (c *InstrumentedClient) Do(req *http.Request) (resp *http.Response, err error)

+ type Metrics struct

+ func NewMetrics(namespace, subsystem string) *Metrics

+ func (pm *Metrics) Collect(ch chan<- prometheus.Metric)

+ func (pm *Metrics) Describe(ch chan<- *prometheus.Desc)

+ type Options struct

+ PrometheusMetrics *Metrics