slapperx

Documentation

Index

• Constants
• func Main()
• type Config
  • func ParseFlags() *Config
• type LogFile
  • func NewLogFile(logFile string) *LogFile
  • func (f *LogFile) Close()
  • func (f *LogFile) WriteLoop()
  • func (f *LogFile) WriteString(s string)
• type MovingWindow
  • func (mw *MovingWindow) Reset()
  • func (mw *MovingWindow) ResetSlot(slot int)
• type OkBadCounter
• type RampUpController
  • func NewRamUpController(rampUpTime time.Duration, maxRate float64) *RampUpController
  • func (r *RampUpController) GetRateChanger() chan float64
• type Stats
• type StatsResponse
• type Targeter
  • func NewTargeter(requests *[]http.Request, timeout time.Duration, logFile *LogFile, ...) *Targeter
  • func (trgt *Targeter) Close()
  • func (trgt *Targeter) Start(workers uint, ticker <-chan time.Time)
• type Ticker
  • func NewTicker(rate float64) *Ticker
  • func (t *Ticker) GetRateChanger() chan float64
  • func (t *Ticker) Start() <-chan time.Time
  • func (t *Ticker) Stop()
• type UI
  • func InitTerminal(minY time.Duration, maxY time.Duration) *UI
  • func (ui *UI) Close()
  • func (ui *UI) Show()

Constants

const (
	Ready  windowState = 0
	Filled windowState = 1
)

Functions

func Main

func Main()

Types

type Config

type Config struct {
	Workers   uint
	Timeout   time.Duration
	Targets   string
	Overrides string
	Rate      float64
	MinY      time.Duration
	MaxY      time.Duration
	RampUp    time.Duration
	LogFile   string
	Verbose   bool
}

func ParseFlags

func ParseFlags() *Config

type LogFile

type LogFile struct {
	sync.WaitGroup
	// contains filtered or unexported fields
}

func NewLogFile

func NewLogFile(logFile string) *LogFile

func (*LogFile) Close

func (f *LogFile) Close()

func (*LogFile) WriteLoop

func (f *LogFile) WriteLoop()

func (*LogFile) WriteString

func (f *LogFile) WriteString(s string)

type MovingWindow

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

ring moving window buffer

func (*MovingWindow) Reset

func (mw *MovingWindow) Reset()

func (*MovingWindow) ResetSlot

func (mw *MovingWindow) ResetSlot(slot int)

type OkBadCounter

type OkBadCounter struct {
	Ok  counter
	Bad counter
}

type RampUpController

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

func NewRamUpController

func NewRamUpController(rampUpTime time.Duration, maxRate float64) *RampUpController

func (*RampUpController) GetRateChanger

func (r *RampUpController) GetRateChanger() chan float64

GetRateChanger returns a channel for changing the ticker's rate during operation.

type Stats

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

type StatsResponse

type StatsResponse struct {
	ErrorEof         counter
	ErrorTimeout     counter
	ErrorConnRefused counter
	ErrorNoSuchHost  counter
	// contains filtered or unexported fields
}

type Targeter

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

func NewTargeter

func NewTargeter(requests *[]http.Request, timeout time.Duration, logFile *LogFile, verbose bool) *Targeter

func (*Targeter) Close

func (trgt *Targeter) Close()

func (*Targeter) Start

func (trgt *Targeter) Start(workers uint, ticker <-chan time.Time)

type Ticker

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

func NewTicker

func NewTicker(rate float64) *Ticker

NewTicker creates a new ticker instance with a given rate and ramp-up time.

func (*Ticker) GetRateChanger

func (t *Ticker) GetRateChanger() chan float64

GetRateChanger returns a channel for changing the ticker's rate during operation.

func (*Ticker) Start

func (t *Ticker) Start() <-chan time.Time

Start initializes the tick process and returns a channel to receive tick events.

func (*Ticker) Stop

func (t *Ticker) Stop()

type UI

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

func InitTerminal

func InitTerminal(minY time.Duration, maxY time.Duration) *UI

InitTerminal initializes the terminal and sets the UI dimensions

func (*UI) Close

func (ui *UI) Close()

func (*UI) Show

func (ui *UI) Show()

show periodically updates and redraws the histogram