engine

Documentation

Index

• func GetAmmoProvider(c *config.AmmoProvider) (ammo.Provider, error)
• func GetGun(c *config.Gun) (gun.Gun, error)
• func GetLimiter(c *config.Limiter) (limiter.Limiter, error)
• func GetResultListener(c *config.ResultListener) (aggregate.ResultListener, error)
• type Counter
  • func NewCounter(name string) *Counter
  • func (c *Counter) Add(delta int64)
  • func (c *Counter) Get() int64
  • func (c *Counter) Set(value int64)
  • func (c *Counter) String() string
• type Engine
  • func New(cfg config.Global) *Engine
  • func (e *Engine) Serve(ctx context.Context) error
• type User
  • func (u *User) Run(ctx context.Context) error
• type UserPool
  • func NewUserPoolFromConfig(cfg *config.UserPool) (up *UserPool, err error)
  • func (up *UserPool) Start(ctx context.Context) error

Functions

func GetAmmoProvider

func GetAmmoProvider(c *config.AmmoProvider) (ammo.Provider, error)

func GetGun

func GetGun(c *config.Gun) (gun.Gun, error)

func GetLimiter

func GetLimiter(c *config.Limiter) (limiter.Limiter, error)

func GetResultListener

func GetResultListener(c *config.ResultListener) (aggregate.ResultListener, error)

Types

type Counter

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

func NewCounter

func NewCounter(name string) *Counter

func (*Counter) Add

func (c *Counter) Add(delta int64)

func (*Counter) Get

func (c *Counter) Get() int64

func (*Counter) Set

func (c *Counter) Set(value int64)

func (*Counter) String

func (c *Counter) String() string

type Engine

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

func New

func New(cfg config.Global) *Engine

func (*Engine) Serve

func (e *Engine) Serve(ctx context.Context) error

type User

type User struct {
	Name       string
	Ammunition ammo.Provider
	Results    aggregate.ResultListener
	Limiter    limiter.Limiter
	Gun        gun.Gun
}

func (*User) Run

func (u *User) Run(ctx context.Context) error

type UserPool

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

func NewUserPoolFromConfig

func NewUserPoolFromConfig(cfg *config.UserPool) (up *UserPool, err error)

func (*UserPool) Start

func (up *UserPool) Start(ctx context.Context) error