loader

Documentation

Index

• Constants
• func DoRequest(httpClient *http.Client, header map[string]string, ...) (respSize int, duration time.Duration)
• type LoadCfg
  • func NewLoadCfg(duration int, goroutines int, testUrl string, reqBody string, method string, ...) (rt *LoadCfg)
  • func (cfg *LoadCfg) RunSingleLoadSession()
  • func (cfg *LoadCfg) Stop()
• type RequesterStats

Constants

const (
	USER_AGENT = "go-wrk"
)

Functions

func DoRequest

func DoRequest(httpClient *http.Client, header map[string]string, method, host, loadUrl, reqBody string) (respSize int, duration time.Duration)

DoRequest single request implementation. Returns the size of the response and its duration On error - returns -1 on both

Types

type LoadCfg

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

func NewLoadCfg

func NewLoadCfg(duration int,
	goroutines int,
	testUrl string,
	reqBody string,
	method string,
	host string,
	header map[string]string,
	statsAggregator chan *RequesterStats,
	timeoutms int,
	allowRedirects bool,
	disableCompression bool,
	disableKeepAlive bool,
	clientCert string,
	clientKey string,
	caCert string,
	http2 bool) (rt *LoadCfg)

func (*LoadCfg) RunSingleLoadSession

func (cfg *LoadCfg) RunSingleLoadSession()

Requester a go function for repeatedly making requests and aggregating statistics as long as required When it is done, it sends the results using the statsAggregator channel

func (*LoadCfg) Stop

func (cfg *LoadCfg) Stop()

type RequesterStats

type RequesterStats struct {
	TotRespSize    int64
	TotDuration    time.Duration
	MinRequestTime time.Duration
	MaxRequestTime time.Duration
	NumRequests    int
	NumErrs        int
}

RequesterStats used for colelcting aggregate statistics