loader

package

v0.0.4 Latest Latest Go to latest Published: Jun 23, 2022 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/changsongl/go-wrk-dynamic

Links

Open Source Insights

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 ¶

View Source

const (
	USER_AGENT = "go-wrk"
)

Variables ¶

This section is empty.

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,
	skipVerify bool,
	clientCert string,
	clientKey string,
	caCert string,
	http2 bool,
	dyn dynamic.Dynamic) (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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL