runner

Documentation

Index

• type Job
  • func (j *Job) Stop()
• type Runner
  • func New(updateInterval time.Duration, scriptsManager scriptsManager, ...) *Runner
  • func (rnr *Runner) Stop()
  • func (rnr *Runner) Watch(ctx context.Context, ctxCancel context.CancelFunc, 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(updateInterval time.Duration, 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, ctxCancel context.CancelFunc, wg *sync.WaitGroup, once bool)