load

README

Load tests

Local run

Start BE API + loadtest migrations data

docker-compose -f be-api-compose-loadtest.yaml build
docker-compose -f be-api-compose-loadtest.yaml up

Run suite

go run load/cmd/load/main.go -gen_config load/gen_cfg/generator_block_explorer.yaml -config load/run_configs/${SUITE_NAME}.yaml

see results.csv/runners.log after test

Down compose to clear data in pg

docker-compose -f be-api-compose-loadtest.yaml down

Documentation

Index

• Constants
• func AttackerFromName(name string) loadgen.Attack
• func CheckFromName(name string) loadgen.RuntimeCheckFunc
• func DefaultLimit(a loadgen.Attack) int32
• func GetJetDropsByID(a *GetJetDropByIDAttack, id string) error
• func GetRecordsByID(a *GetRecordsAttack, id string) error
• func NewCSVWriter(name string) (*csv.Writer, func() error)
• func NewGeneratedBEClient(a loadgen.Attack) *client.APIClient
• type GetJetDropByIDAttack
  • func (a *GetJetDropByIDAttack) Clone(r *loadgen.Runner) loadgen.Attack
  • func (a *GetJetDropByIDAttack) Do(ctx context.Context) loadgen.DoResult
  • func (a *GetJetDropByIDAttack) Setup(hc loadgen.RunnerConfig) error
• type GetJetDropsByJetIDAttack
  • func (a *GetJetDropsByJetIDAttack) Clone(r *loadgen.Runner) loadgen.Attack
  • func (a *GetJetDropsByJetIDAttack) Do(ctx context.Context) loadgen.DoResult
  • func (a *GetJetDropsByJetIDAttack) Setup(hc loadgen.RunnerConfig) error
• type GetJetDropsByPulseNumberAttack
  • func (a *GetJetDropsByPulseNumberAttack) Clone(r *loadgen.Runner) loadgen.Attack
  • func (a *GetJetDropsByPulseNumberAttack) Do(ctx context.Context) loadgen.DoResult
  • func (a *GetJetDropsByPulseNumberAttack) Setup(hc loadgen.RunnerConfig) error
• type GetLifelineAttack
  • func (a *GetLifelineAttack) Clone(r *loadgen.Runner) loadgen.Attack
  • func (a *GetLifelineAttack) Do(ctx context.Context) loadgen.DoResult
  • func (a *GetLifelineAttack) Setup(hc loadgen.RunnerConfig) error
• type GetPulseAttack
  • func (a *GetPulseAttack) Clone(r *loadgen.Runner) loadgen.Attack
  • func (a *GetPulseAttack) Do(ctx context.Context) loadgen.DoResult
  • func (a *GetPulseAttack) Setup(hc loadgen.RunnerConfig) error
• type GetPulsesAttack
  • func (a *GetPulsesAttack) Clone(r *loadgen.Runner) loadgen.Attack
  • func (a *GetPulsesAttack) Do(ctx context.Context) loadgen.DoResult
  • func (a *GetPulsesAttack) Setup(hc loadgen.RunnerConfig) error
• type GetRecordsAttack
  • func (a *GetRecordsAttack) Clone(r *loadgen.Runner) loadgen.Attack
  • func (a *GetRecordsAttack) Do(ctx context.Context) loadgen.DoResult
  • func (a *GetRecordsAttack) Setup(hc loadgen.RunnerConfig) error
• type SearchAttack
  • func (a *SearchAttack) Clone(r *loadgen.Runner) loadgen.Attack
  • func (a *SearchAttack) Do(ctx context.Context) loadgen.DoResult
  • func (a *SearchAttack) Setup(hc loadgen.RunnerConfig) error

Constants

const (
	GetPulseLabel              = "get_pulse"
	GetPulsesLabel             = "get_pulses"
	GetJetDropByIDLabel        = "get_jet_drop_by_id"
	GetJetDropsByJetIDLabel    = "get_jet_drops_by_jet_id"
	GetRecordsLabel            = "get_records"
	GetLifelineLabel           = "get_lifeline"
	SearchLabel                = "search"
	GetJetDropsByPulseNumLabel = "get_jet_drops_by_pulse_number"
)

Functions

func AttackerFromName

func AttackerFromName(name string) loadgen.Attack

func CheckFromName

func CheckFromName(name string) loadgen.RuntimeCheckFunc

func DefaultLimit

func DefaultLimit(a loadgen.Attack) int32

func GetJetDropsByID

func GetJetDropsByID(a *GetJetDropByIDAttack, id string) error

func GetRecordsByID

func GetRecordsByID(a *GetRecordsAttack, id string) error

func NewCSVWriter

func NewCSVWriter(name string) (*csv.Writer, func() error)

func NewGeneratedBEClient

func NewGeneratedBEClient(a loadgen.Attack) *client.APIClient

Types

type GetJetDropByIDAttack

type GetJetDropByIDAttack struct {
	loadgen.WithRunner
	// contains filtered or unexported fields
}

func (*GetJetDropByIDAttack) Clone

func (a *GetJetDropByIDAttack) Clone(r *loadgen.Runner) loadgen.Attack

func (*GetJetDropByIDAttack) Do

func (a *GetJetDropByIDAttack) Do(ctx context.Context) loadgen.DoResult

func (*GetJetDropByIDAttack) Setup

func (a *GetJetDropByIDAttack) Setup(hc loadgen.RunnerConfig) error

type GetJetDropsByJetIDAttack

type GetJetDropsByJetIDAttack struct {
	loadgen.WithRunner
	// contains filtered or unexported fields
}

func (*GetJetDropsByJetIDAttack) Clone

func (a *GetJetDropsByJetIDAttack) Clone(r *loadgen.Runner) loadgen.Attack

func (*GetJetDropsByJetIDAttack) Do

func (a *GetJetDropsByJetIDAttack) Do(ctx context.Context) loadgen.DoResult

func (*GetJetDropsByJetIDAttack) Setup

func (a *GetJetDropsByJetIDAttack) Setup(hc loadgen.RunnerConfig) error

type GetJetDropsByPulseNumberAttack

type GetJetDropsByPulseNumberAttack struct {
	loadgen.WithRunner
	// contains filtered or unexported fields
}

func (*GetJetDropsByPulseNumberAttack) Clone

func (a *GetJetDropsByPulseNumberAttack) Clone(r *loadgen.Runner) loadgen.Attack

func (*GetJetDropsByPulseNumberAttack) Do

func (a *GetJetDropsByPulseNumberAttack) Do(ctx context.Context) loadgen.DoResult

func (*GetJetDropsByPulseNumberAttack) Setup

func (a *GetJetDropsByPulseNumberAttack) Setup(hc loadgen.RunnerConfig) error

type GetLifelineAttack

type GetLifelineAttack struct {
	loadgen.WithRunner
	// contains filtered or unexported fields
}

func (*GetLifelineAttack) Clone

func (a *GetLifelineAttack) Clone(r *loadgen.Runner) loadgen.Attack

func (*GetLifelineAttack) Do

func (a *GetLifelineAttack) Do(ctx context.Context) loadgen.DoResult

func (*GetLifelineAttack) Setup

func (a *GetLifelineAttack) Setup(hc loadgen.RunnerConfig) error

type GetPulseAttack

type GetPulseAttack struct {
	loadgen.WithRunner
	// contains filtered or unexported fields
}

func (*GetPulseAttack) Clone

func (a *GetPulseAttack) Clone(r *loadgen.Runner) loadgen.Attack

func (*GetPulseAttack) Do

func (a *GetPulseAttack) Do(ctx context.Context) loadgen.DoResult

func (*GetPulseAttack) Setup

func (a *GetPulseAttack) Setup(hc loadgen.RunnerConfig) error

type GetPulsesAttack

type GetPulsesAttack struct {
	loadgen.WithRunner
	// contains filtered or unexported fields
}

func (*GetPulsesAttack) Clone

func (a *GetPulsesAttack) Clone(r *loadgen.Runner) loadgen.Attack

func (*GetPulsesAttack) Do

func (a *GetPulsesAttack) Do(ctx context.Context) loadgen.DoResult

func (*GetPulsesAttack) Setup

func (a *GetPulsesAttack) Setup(hc loadgen.RunnerConfig) error

type GetRecordsAttack

type GetRecordsAttack struct {
	loadgen.WithRunner
	// contains filtered or unexported fields
}

func (*GetRecordsAttack) Clone

func (a *GetRecordsAttack) Clone(r *loadgen.Runner) loadgen.Attack

func (*GetRecordsAttack) Do

func (a *GetRecordsAttack) Do(ctx context.Context) loadgen.DoResult

func (*GetRecordsAttack) Setup

func (a *GetRecordsAttack) Setup(hc loadgen.RunnerConfig) error

type SearchAttack

type SearchAttack struct {
	loadgen.WithRunner
	// contains filtered or unexported fields
}

func (*SearchAttack) Clone

func (a *SearchAttack) Clone(r *loadgen.Runner) loadgen.Attack

func (*SearchAttack) Do

func (a *SearchAttack) Do(ctx context.Context) loadgen.DoResult

func (*SearchAttack) Setup

func (a *SearchAttack) Setup(hc loadgen.RunnerConfig) error