spec

Documentation

Index

• type SpecRunner
  • func NewRunner(req *SpecRunnerReq) (*SpecRunner, error)
  • func (s *SpecRunner) Cancel() error
  • func (s *SpecRunner) Start() error
• type SpecRunnerReq

Types

type SpecRunner

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

func NewRunner

func NewRunner(req *SpecRunnerReq) (*SpecRunner, error)

func (*SpecRunner) Cancel

func (s *SpecRunner) Cancel() error

func (*SpecRunner) Start

func (s *SpecRunner) Start() error

type SpecRunnerReq

type SpecRunnerReq struct {
	Client *api.Client
	Logger *zap.Logger

	RunID    ulid.ULID
	Flow     *state.Flow
	Trigger  string
	UpdateCh chan *state.Run
	Vars     map[string]any
}