runner

Documentation

Index

• type Job
  • func (j *Job) Stop()
• type Runner
  • func New(scriptsManager scriptsManager, dsManager dsManager, ...) *Runner
  • func (rnr *Runner) Stop()
  • func (rnr *Runner) Watch(ctx context.Context, wg *sync.WaitGroup)

Types

type Job

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

func (*Job) Stop

func (j *Job) Stop()

type Runner

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

func New

func New(scriptsManager scriptsManager, dsManager dsManager, storagesManager storagesManager, coreModules []modules.Module, logger *zap.Logger) *Runner

func (*Runner) Stop

func (rnr *Runner) Stop()

func (*Runner) Watch

func (rnr *Runner) Watch(ctx context.Context, wg *sync.WaitGroup)