request

Documentation

Index

• func NewClients(kubeCfgPath string, connsNum int, opts ...ClientCfgOpt) ([]rest.Interface, error)
• type ClientCfgOpt
  • func WithClientContentTypeOpt(ct types.ContentType) ClientCfgOpt
  • func WithClientDisableHTTP2Opt(b bool) ClientCfgOpt
  • func WithClientQPSOpt(qps float64) ClientCfgOpt
  • func WithClientUserAgentOpt(ua string) ClientCfgOpt
• type RESTRequestBuilder
• type Result
  • func Schedule(ctx context.Context, spec *types.LoadProfileSpec, restCli []rest.Interface) (*Result, 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 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 RESTRequestBuilder

type RESTRequestBuilder interface {
	Build(cli rest.Interface) (method string, _ *rest.Request)
}

RESTRequestBuilder is used to build rest.Request.

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 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.