worker

Documentation

Index

• Constants
• type ResponseCode
• type Stats
• type TotalRequestsComplete
• type Worker
  • func NewWorker(config *http_clients.Config) (Worker, error)
• type WorkerBase
  • func (w *WorkerBase) ReqSize() int64
  • func (w *WorkerBase) RespSize() int64
  • func (w *WorkerBase) Stats() Stats
• type WorkerFixedReqs
  • func (w *WorkerFixedReqs) Run(wg *sync.WaitGroup)
• type WorkerFixedTime
  • func (w *WorkerFixedTime) Run(wg *sync.WaitGroup)
• type WorkerFixedTimeRequests
  • func (w *WorkerFixedTimeRequests) Run(wg *sync.WaitGroup)

Constants

const (
	HttpClientNetHTTP   = "nethttp"
	HttpClientNetHTTP2  = "nethttp2"
	HttpClientNetHTTP3  = "nethttp3"
	HttpClientFastHTTP1 = "fasthttp"
)

Types

type ResponseCode

type ResponseCode int

type Stats

type Stats struct {
	CompletedReqs int64
	FailedReqs    int64
	Responses     *sync.Map
	Errors        *sync.Map
}

type TotalRequestsComplete

type TotalRequestsComplete int64

type Worker

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

func NewWorker

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

type WorkerBase

type WorkerBase struct {
	CompletedReqs atomic.Int64
	FailedReqs    atomic.Int64
	// contains filtered or unexported fields
}

func (*WorkerBase) ReqSize

func (w *WorkerBase) ReqSize() int64

func (*WorkerBase) RespSize

func (w *WorkerBase) RespSize() int64

func (*WorkerBase) Stats

func (w *WorkerBase) Stats() Stats

type WorkerFixedReqs

type WorkerFixedReqs struct {
	*WorkerBase
}

func (*WorkerFixedReqs) Run

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

type WorkerFixedTime

type WorkerFixedTime struct {
	*WorkerBase
}

func (*WorkerFixedTime) Run

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

type WorkerFixedTimeRequests

type WorkerFixedTimeRequests struct {
	*WorkerBase
}

func (*WorkerFixedTimeRequests) Run

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