runner

Documentation

Index

• type Context
  • func NewContext(root context.Context, params testing.Params) Context
  • func (c Context) Deadline() (time.Time, bool)
  • func (c Context) Done() <-chan struct{}
  • func (c Context) Err() error
  • func (c Context) Params() testing.Params
  • func (c Context) Value(key interface{}) interface{}
• type Options
• type Pool
  • func NewPool(size uint64) *Pool
  • func (pool *Pool) Capacity() uint64
  • func (pool *Pool) Go(f func())
  • func (pool *Pool) Size() uint64
• type Result
• type Runner
  • func New(opts Options) (*Runner, error)
  • func (r *Runner) Run(ctx Context, src sources.Source) Stream
• type Settings
• type Stream
• type Summary
  • func (sum Summary) HasErrors() bool

Types

type Context

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

func NewContext

func NewContext(root context.Context, params testing.Params) Context

func (Context) Deadline

func (c Context) Deadline() (time.Time, bool)

func (Context) Done

func (c Context) Done() <-chan struct{}

func (Context) Err

func (c Context) Err() error

func (Context) Params

func (c Context) Params() testing.Params

func (Context) Value

func (c Context) Value(key interface{}) interface{}

type Options

type Options struct {
	Runtime       runtime.Runtime
	PoolSize      uint64
	TestTimeout   time.Duration
	Attempts      uint64
	Times         uint64
	TimesInterval uint64
}

type Pool

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

func NewPool

func NewPool(size uint64) *Pool

func (*Pool) Capacity

func (pool *Pool) Capacity() uint64

func (*Pool) Go

func (pool *Pool) Go(f func())

func (*Pool) Size

func (pool *Pool) Size() uint64

type Result

type Result struct {
	Times    uint64
	Attempts uint64
	Filename string
	Duration time.Duration
	Error    error
}

type Runner

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

func New

func New(opts Options) (*Runner, error)

func (*Runner) Run

func (r *Runner) Run(ctx Context, src sources.Source) Stream

type Settings

type Settings struct {
	CDPAddress string
	Source     sources.Source
	Params     map[string]interface{}
}

type Stream

type Stream struct {
	Summary  <-chan Summary
	Progress <-chan Result
}

type Summary

type Summary struct {
	Passed   int
	Failed   int
	Duration time.Duration
}

func (Summary) HasErrors

func (sum Summary) HasErrors() bool