httpscenario

Documentation

Index

• Constants
• func Import(fs afero.Fs)
• func WrapGun(g Gun) core.Gun
• type Gun
• type Postprocessor
• type Preprocessor
• type Request
  • func (r *Request) GetBody() []byte
  • func (r *Request) GetHeaders() map[string]string
• type RequestParts
• type Scenario
  • func (a *Scenario) Clone() scenario.ProvAmmo
  • func (a *Scenario) SetID(id uint64)
• type ScenarioGun
  • func NewHTTP2Gun(conf phttp.GunConfig, answLog *zap.Logger) (*ScenarioGun, error)
  • func NewHTTPGun(conf phttp.GunConfig, answLog *zap.Logger) *ScenarioGun
  • func (g *ScenarioGun) Bind(aggregator netsample.Aggregator, deps core.GunDeps) error
  • func (g *ScenarioGun) Close() error
  • func (g *ScenarioGun) Do(req *http.Request) (*http.Response, error)
  • func (g *ScenarioGun) Shoot(ammo *Scenario)
  • func (g *ScenarioGun) WarmUp(opts *warmup.Options) (any, error)
• type SourceStorage
• type Templater

Constants

const (
	EmptyTag = "__EMPTY__"
)

Functions

func Import

func Import(fs afero.Fs)

func WrapGun

func WrapGun(g Gun) core.Gun

Types

type Gun

type Gun interface {
	Shoot(ammo *Scenario)
	Bind(sample netsample.Aggregator, deps core.GunDeps) error
	WarmUp(opts *warmup.Options) (any, error)
}

type Postprocessor

type Postprocessor interface {
	Process(resp *http.Response, body io.Reader) (map[string]any, error)
}

type Preprocessor

type Preprocessor interface {
	// Process is called before request is sent
	// templateVars - variables from template. Can be modified
	// sourceVars - variables from sources. Must NOT be modified
	Process(templateVars map[string]any) (map[string]any, error)
}

type Request

type Request struct {
	Method         string
	Headers        map[string]string
	Tag            string
	Body           *string
	Name           string
	URI            string
	Preprocessor   Preprocessor
	Postprocessors []Postprocessor
	Templater      Templater
	Sleep          time.Duration
}

func (*Request) GetBody

func (r *Request) GetBody() []byte

func (*Request) GetHeaders

func (r *Request) GetHeaders() map[string]string

type RequestParts

type RequestParts struct {
	URL     string
	Method  string
	Body    []byte
	Headers map[string]string
}

type Scenario

type Scenario struct {
	Requests        []Request
	ID              uint64
	Name            string
	MinWaitingTime  time.Duration
	VariableStorage SourceStorage
}

func (*Scenario) Clone

func (a *Scenario) Clone() scenario.ProvAmmo

func (*Scenario) SetID

func (a *Scenario) SetID(id uint64)

type ScenarioGun

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

func NewHTTP2Gun

func NewHTTP2Gun(conf phttp.GunConfig, answLog *zap.Logger) (*ScenarioGun, error)

NewHTTP2Gun return simple HTTP/2 gun that can shoot sequentially through one connection.

func NewHTTPGun

func NewHTTPGun(conf phttp.GunConfig, answLog *zap.Logger) *ScenarioGun

func (*ScenarioGun) Bind

func (g *ScenarioGun) Bind(aggregator netsample.Aggregator, deps core.GunDeps) error

func (*ScenarioGun) Close

func (g *ScenarioGun) Close() error

func (*ScenarioGun) Do

func (g *ScenarioGun) Do(req *http.Request) (*http.Response, error)

func (*ScenarioGun) Shoot

func (g *ScenarioGun) Shoot(ammo *Scenario)

Shoot is thread safe if Do and Connect hooks are thread safe.

func (*ScenarioGun) WarmUp

func (g *ScenarioGun) WarmUp(opts *warmup.Options) (any, error)

type SourceStorage

type SourceStorage interface {
	Variables() map[string]any
}

type Templater

type Templater interface {
	Apply(request *RequestParts, variables map[string]any, scenarioName, stepName string) error
}