http

Documentation

Index

• Variables
• func CreateProxiedDialer(proxyURL string) (fasthttp.DialFunc, error)
• func GetResponseHeaders(resp *http.Response) map[string]string
• func NewThrottledTransport(limitPeriod time.Duration, requestCount int, transportWrap http.RoundTripper) http.RoundTripper
• func SetRequestBody(body interface{}, req *http.Request) error
• type Config
  • func NewConfig(requestsPerSecond *int, skipTlsVerification *bool, proxy *string) *Config
• type CustomClient
  • func NewConfigHttp2(requestsPerSecond *int, skipTlsVerification *bool, proxy *string) *CustomClient
  • func (c *CustomClient) Do(uri string, method string, queryParams any, headers any, reqBody any) (*client.Response, error)
• type Http
  • func NewHttp(config *Config) *Http
• type ThrottledTransport
  • func (c *ThrottledTransport) RoundTrip(r *http.Request) (*http.Response, error)

Variables

var DefaultClient = NewHttp(HttpDefaultConfig) // this won't be proxied

var HttpDefaultConfig = NewConfig(&HttpDefaultRateLimit, &HttpDefaultTlsVerification, &emptyStr)

var HttpDefaultRateLimit = 60

var HttpDefaultTlsVerification = true

Functions

func CreateProxiedDialer

func CreateProxiedDialer(proxyURL string) (fasthttp.DialFunc, error)

CreateDialer returns a dialer function based on the given proxy URL and type. returns non proxied dialer if empty string is passed.

func GetResponseHeaders

func GetResponseHeaders(resp *http.Response) map[string]string

func NewThrottledTransport

func NewThrottledTransport(limitPeriod time.Duration, requestCount int, transportWrap http.RoundTripper) http.RoundTripper

NewThrottledTransport wraps the provided transport with a rate limiter

func SetRequestBody

func SetRequestBody(body interface{}, req *http.Request) error

Types

type Config

type Config struct {
	HttpClient        *fasthttp.Client
	RequestsPerSecond *int
}

func NewConfig

func NewConfig(requestsPerSecond *int, skipTlsVerification *bool, proxy *string) *Config

type CustomClient

type CustomClient struct {
	Requests  []*client.Request
	Responses []*client.ConcurrentResponse
	Client    *http.Client
}

func NewConfigHttp2

func NewConfigHttp2(requestsPerSecond *int, skipTlsVerification *bool, proxy *string) *CustomClient

func (*CustomClient) Do

func (c *CustomClient) Do(uri string, method string, queryParams any, headers any, reqBody any) (*client.Response, error)

type Http

type Http struct {
	Requests  []*client.Request
	Responses []*client.ConcurrentResponse
	Config    *Config
	Client    *client.RateLimitedClient
}

func NewHttp

func NewHttp(config *Config) *Http

type ThrottledTransport

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

func (*ThrottledTransport) RoundTrip

func (c *ThrottledTransport) RoundTrip(r *http.Request) (*http.Response, error)

RoundTrip method implements the rate limiting logic for HTTP requests