worker

package

v0.1.0 Latest Latest Go to latest Published: Apr 27, 2023 License: GPL-3.0 Imports: 9 Imported by: 0

Details

View Source

const (
	HttpClientNetHTTP   = "nethttp"
	HttpClientNetHTTP3  = "nethttp-3"
	HttpClientFastHTTP1 = "fasthttp-1"
	HttpClientFastHTTP2 = "fasthttp-2"
)

This section is empty.

This section is empty.

type ResponseCode int

type Stats struct {
	CompletedReqs int64
	FailedReqs    int64
	Responses     map[ResponseCode]int64
	Errors        map[string]uint
}

type TotalRequestsComplete int64

type Worker interface {
	Run(wg *sync.WaitGroup)
	Stats() Stats
	ReqSize() int64
	RespSize() int64
}

func NewWorker(config *http_clients.Config) (Worker, error)

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

func (w *WorkerBase) ReqSize() int64

func (w *WorkerBase) RespSize() int64

func (w *WorkerBase) Stats() Stats

type WorkerFixedReqs struct {
	*WorkerBase
}

func (w *WorkerFixedReqs) Run(wg *sync.WaitGroup)

type WorkerFixedTime struct {
	*WorkerBase
}

func (w *WorkerFixedTime) Run(wg *sync.WaitGroup)

type WorkerFixedTimeRequests struct {
	*WorkerBase
}

func (w *WorkerFixedTimeRequests) Run(wg *sync.WaitGroup)