transport

Documentation

Index

• type CachingTransport
  • func NewCachingTransport(esiTransport *ESITransport, redisClient *redis.Client) *CachingTransport
  • func (transport *CachingTransport) RoundTrip(request *http.Request) (*http.Response, error)
• type ESITransport
  • func NewESITransport(userAgent string, timeout time.Duration, concurrencyLimit int64) *ESITransport
  • func (transport *ESITransport) RoundTrip(request *http.Request) (*http.Response, error)
• type Transport
  • func NewTransport(userAgent string) *Transport
  • func (transport *Transport) RoundTrip(request *http.Request) (*http.Response, error)

Types

type CachingTransport

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

CachingTransport is a redis-based caching wrapper around the custom rate-limited ESITransport

func NewCachingTransport

func NewCachingTransport(esiTransport *ESITransport, redisClient *redis.Client) *CachingTransport

NewCachingTransport generates a new custom transport

func (*CachingTransport) RoundTrip

func (transport *CachingTransport) RoundTrip(request *http.Request) (*http.Response, error)

RoundTrip tries to fetch the request from cache, otherwise it is fetched via ESITransport

type ESITransport

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

ESITransport is a custom transport for rate-limiting requests to ESI

func NewESITransport

func NewESITransport(userAgent string, timeout time.Duration, concurrencyLimit int64) *ESITransport

NewESITransport generates a new custom transport

func (*ESITransport) RoundTrip

func (transport *ESITransport) RoundTrip(request *http.Request) (*http.Response, error)

RoundTrip uses a default transport which blocks when the client is being blocked by ESI or we're close to the limit. Waiting requests will pile-up! Having backpressure in place should be considered.

type Transport

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

Transport is a custom transport for Element43 which simply sets the user agent

func NewTransport

func NewTransport(userAgent string) *Transport

NewTransport generates a new custom transport

func (*Transport) RoundTrip

func (transport *Transport) RoundTrip(request *http.Request) (*http.Response, error)

RoundTrip automatically sets the user agent