middleware

Documentation

Index

• type ContextRoundTripper
  • func (rt *ContextRoundTripper) RoundTrip(r *http.Request) (*http.Response, error)
• type RateLimiters
  • func (limiters *RateLimiters) RoundTripper(rt http.RoundTripper, host string) http.RoundTripper
• type RoundTripRateLimiter
  • func (t *RoundTripRateLimiter) RoundTrip(r *http.Request) (*http.Response, error)

Types

type ContextRoundTripper

type ContextRoundTripper struct {
	Transport http.RoundTripper
	Ctx       context.Context
}

func (*ContextRoundTripper) RoundTrip

func (rt *ContextRoundTripper) RoundTrip(r *http.Request) (*http.Response, error)

type RateLimiters

type RateLimiters struct {
	RPS, Burst int
	// contains filtered or unexported fields
}

func (*RateLimiters) RoundTripper

func (limiters *RateLimiters) RoundTripper(rt http.RoundTripper, host string) http.RoundTripper

Limit returns a RoundTripper for a particular host. We expect to do a number of requests to a particular host at a time.

type RoundTripRateLimiter

type RoundTripRateLimiter struct {
	// contains filtered or unexported fields
}

func (*RoundTripRateLimiter) RoundTrip

func (t *RoundTripRateLimiter) RoundTrip(r *http.Request) (*http.Response, error)