runner

Documentation

Index

• type Job
  • func (j *Job) EntryID() cron.EntryID
  • func (j *Job) GetCronLocation() *time.Location
  • func (j *Job) GetPriorExecutionTime() time.Duration
  • func (j *Job) Name() string
  • func (j *Job) Run()
  • func (j *Job) Script() *script.Script
  • func (j *Job) SetEntryID(id cron.EntryID)
  • func (j *Job) SetLuaState(ls *lua.LState)
  • func (j *Job) Stop()
• type Runner
  • func New(updateInterval time.Duration, scriptsManager scriptsManager, ...) (*Runner, error)
  • 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
}

Job represents script Job

func (*Job) EntryID

func (j *Job) EntryID() cron.EntryID

func (*Job) GetCronLocation

func (j *Job) GetCronLocation() *time.Location

func (*Job) GetPriorExecutionTime

func (j *Job) GetPriorExecutionTime() time.Duration

func (*Job) Name

func (j *Job) Name() string

func (*Job) Run

func (j *Job) Run()

Run the job

func (*Job) Script

func (j *Job) Script() *script.Script

func (*Job) SetEntryID

func (j *Job) SetEntryID(id cron.EntryID)

func (*Job) SetLuaState

func (j *Job) SetLuaState(ls *lua.LState)

func (*Job) Stop

func (j *Job) Stop()

Stop the job

type Runner

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

Runner represents the script runner

func New

func New(
	updateInterval time.Duration,
	scriptsManager scriptsManager,
	dsManager dsManager,
	storagesManager storagesManager,
	coreModules []modules.Module,
	cliScript string,
	systemCfg *system.System,
	logger *zap.Logger,
) (*Runner, error)

New creates new script runner

func (*Runner) RunScript

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

RunScript runs the scripts by name

func (*Runner) Stop

func (rnr *Runner) Stop()

Stop the module

func (*Runner) Watch

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

Watch runs scripts watcher