request

Documentation

Index

• func NewClients(kubeCfgPath string, connsNum int, opts ...ClientCfgOpt) ([]rest.Interface, error)
• type BaseRequester
  • func (reqr *BaseRequester) Method() string
  • func (reqr *BaseRequester) Timeout(timeout time.Duration)
  • func (reqr *BaseRequester) URL() *url.URL
• type ClientCfgOpt
  • func WithClientContentTypeOpt(ct types.ContentType) ClientCfgOpt
  • func WithClientDisableHTTP2Opt(b bool) ClientCfgOpt
  • func WithClientQPSOpt(qps float64) ClientCfgOpt
  • func WithClientUserAgentOpt(ua string) ClientCfgOpt
• type DiscardRequester
  • func (reqr *DiscardRequester) Do(ctx context.Context) (bytes int64, err error)
• type RESTRequestBuilder
• type Requester
• type Result
  • func Schedule(ctx context.Context, spec *types.LoadProfileSpec, restCli []rest.Interface) (*Result, error)
• type WatchListRequester
  • func (reqr *WatchListRequester) Do(ctx context.Context) (zero int64, _ error)
• type WeightedRandomRequests
  • func NewWeightedRandomRequests(spec *types.LoadProfileSpec) (*WeightedRandomRequests, error)
  • func (r *WeightedRandomRequests) Chan() chan RESTRequestBuilder
  • func (r *WeightedRandomRequests) Run(ctx context.Context, total int)
  • func (r *WeightedRandomRequests) Stop()

Functions

func NewClients

func NewClients(kubeCfgPath string, connsNum int, opts ...ClientCfgOpt) ([]rest.Interface, error)

NewClients creates N rest.Interface.

FIXME(weifu):

1. Is it possible to build one http2 client with multiple connections? 2. How to monitor HTTP2 GOAWAY frame?

Types

type BaseRequester

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

func (*BaseRequester) Method

func (reqr *BaseRequester) Method() string

func (*BaseRequester) Timeout

func (reqr *BaseRequester) Timeout(timeout time.Duration)

func (*BaseRequester) URL

func (reqr *BaseRequester) URL() *url.URL

type ClientCfgOpt

type ClientCfgOpt func(*clientCfg)

ClientCfgOpt is used to update default client setting.

func WithClientContentTypeOpt

func WithClientContentTypeOpt(ct types.ContentType) ClientCfgOpt

WithClientContentTypeOpt updates content type of response.

func WithClientDisableHTTP2Opt

func WithClientDisableHTTP2Opt(b bool) ClientCfgOpt

WithClientDisableHTTP2Opt disables HTTP2 protocol.

func WithClientQPSOpt

func WithClientQPSOpt(qps float64) ClientCfgOpt

WithClientQPSOpt updates QPS value.

func WithClientUserAgentOpt

func WithClientUserAgentOpt(ua string) ClientCfgOpt

WithClientUserAgentOpt updates user agent.

type DiscardRequester

type DiscardRequester struct {
	BaseRequester
}

func (*DiscardRequester) Do

func (reqr *DiscardRequester) Do(ctx context.Context) (bytes int64, err error)

type RESTRequestBuilder

type RESTRequestBuilder interface {
	Build(cli rest.Interface) Requester
}

RESTRequestBuilder is used to build rest.Request.

type Requester

type Requester interface {
	Method() string
	URL() *url.URL
	Timeout(time.Duration)
	Do(context.Context) (bytes int64, err error)
}

type Result

type Result struct {
	types.ResponseStats
	// Duration means the time of benchmark.
	Duration time.Duration
	// Total means the total number of requests.
	Total int
}

Result contains responseStats vlaues from Gather() and adds Duration and Total values separately

func Schedule

func Schedule(ctx context.Context, spec *types.LoadProfileSpec, restCli []rest.Interface) (*Result, error)

Schedule files requests to apiserver based on LoadProfileSpec.

type WatchListRequester

type WatchListRequester struct {
	BaseRequester
}

func (*WatchListRequester) Do

func (reqr *WatchListRequester) Do(ctx context.Context) (zero int64, _ error)

type WeightedRandomRequests

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

WeightedRandomRequests is used to generate requests based on LoadProfileSpec.

func NewWeightedRandomRequests

func NewWeightedRandomRequests(spec *types.LoadProfileSpec) (*WeightedRandomRequests, error)

NewWeightedRandomRequests creates new instance of WeightedRandomRequests.

func (*WeightedRandomRequests) Chan

func (r *WeightedRandomRequests) Chan() chan RESTRequestBuilder

Chan returns channel to get random request.

func (*WeightedRandomRequests) Run

func (r *WeightedRandomRequests) Run(ctx context.Context, total int)

Run starts to random pick request.

func (*WeightedRandomRequests) Stop

func (r *WeightedRandomRequests) Stop()

Stop stops request generator.