control

Oct 24, 2023

Changes in this version

+ var ErrNoFactory = errors.New("factory is not set")

+ var ErrNoSuch = errors.New("no such")

+ type Controller struct

+ func New(opts ...Option) (*Controller, error)

+ func (c *Controller) Run(ctx context.Context) <-chan Event

+ type ErrorEvent struct

+ Err error

+ func NewErrorEvent(err error) ErrorEvent

+ func (e ErrorEvent) Error() string

+ func (e ErrorEvent) Time() time.Time

+ func (e ErrorEvent) Unwrap() error

+ type Event interface

+ Time func() time.Time

+ type Job struct

+ Args []string

+ Dir string

+ Env []string

+ ID string

+ ModulePars map[string]string

+ Name string

+ Timeout time.Duration

+ func NewJob(name string, conf *project.Config) *Job

+ func UnwrapJob(e Event) *Job

+ type JobError struct

+ Err error

+ func (e *JobError) Error() string

+ func (e *JobError) Unwrap() error

+ type LogEvent struct

+ Text string

+ func NewLogEvent(job *Job, text string) LogEvent

+ func (e LogEvent) Time() time.Time

+ type Option func(*Controller) error

+ func MaxWorkers(n int) Option

+ func WithFactory(f RunnerFactory) Option

+ type Runner interface

+ Run func(context.Context) <-chan Event

+ type RunnerFactory func() (Runner, error)

+ type StartEvent struct

+ Name string

+ func NewStartEvent(job *Job, name string) StartEvent

+ func (e StartEvent) Time() time.Time

+ type StopEvent struct

+ Begin time.Time

+ Name string

+ Verdict string

+ func NewStopEvent(job *Job, name string, verdict string) StopEvent

+ func (e StopEvent) Time() time.Time

+ type TestPlan struct

+ Controls []string

+ Tests []string

+ func NewTestPlan(conf *project.Config) (*TestPlan, error)

+ func (tp *TestPlan) Add(name string) error

+ func (tp *TestPlan) Next() *Job

+ type TickerEvent struct

+ func NewTickerEvent(job *Job) TickerEvent

+ func (e TickerEvent) Time() time.Time