runner

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 17, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Context

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

func NewContext

func NewContext(root context.Context, params 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() Params

func (Context) Value

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

type Params

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

func NewParams

func NewParams() Params

func (*Params) SetSystemValue

func (p *Params) SetSystemValue(name string, value interface{})

func (*Params) SetUserValue

func (p *Params) SetUserValue(name string, value interface{})

func (*Params) SetUserValues

func (p *Params) SetUserValues(values map[string]interface{})

func (Params) ToMap

func (p Params) ToMap() map[string]interface{}

type Pool

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

func NewPool

func NewPool(size int) *Pool

func (*Pool) Capacity

func (pool *Pool) Capacity() int

func (*Pool) Go

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

func (*Pool) Size

func (pool *Pool) Size() int

type Result

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

type Runner

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

func New

func New(rt runtime.Runtime, poolSize int) (*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
	Errors   []error
}

func (Summary) HasErrors

func (sum Summary) HasErrors() bool

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL