runner

Documentation

Index

• type Job
  • func (j *Job) Run()
  • func (j *Job) Stop()
• type Runner
  • func New(updateInterval time.Duration, scriptsManager scriptsManager, ...) *Runner
  • func (rnr *Runner) RunScript(name string, req *http.Request) error
  • func (rnr *Runner) Stop()
  • func (rnr *Runner) Watch(ctx context.Context, ctxCancel context.CancelFunc, once bool)

Types

type Job

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

func (*Job) Run

func (j *Job) Run()

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,
	cliScript string,
	logger *zap.Logger,
) *Runner

func (*Runner) RunScript

func (rnr *Runner) RunScript(name string, req *http.Request) error

func (*Runner) Stop

func (rnr *Runner) Stop()

func (*Runner) Watch

func (rnr *Runner) Watch(ctx context.Context, ctxCancel context.CancelFunc, once bool)