runner

package

v0.2.7 Latest Latest Go to latest Published: Aug 8, 2025 License: MIT Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/aigic8/corn

Links

Open Source Insights

Documentation ¶

Index ¶

func CompileNotifServices(services map[string]config.NotifyService, disabled bool) (map[string][]notify.Notifier, error)
type FailureNotifier
type Runner
- func NewRunner(c *config.Config, l *logs.Logger, db *db.Db) (*Runner, error)
type StringWriter

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CompileNotifServices ¶

func CompileNotifServices(services map[string]config.NotifyService, disabled bool) (map[string][]notify.Notifier, error)

helper function to convert config notification services into application notifiers

Types ¶

type FailureNotifier ¶

type FailureNotifier = func(err error, logMsg string, stdout string, stderr string)

type Runner ¶

type Runner struct {
	L         *logs.Logger
	Config    *config.Config
	Scheduler gocron.Scheduler
	Notif     *notif.Notif
	// contains filtered or unexported fields
}

func NewRunner ¶

func NewRunner(c *config.Config, l *logs.Logger, db *db.Db) (*Runner, error)

func (*Runner) JobFunc ¶

func (r *Runner) JobFunc(jobName string, test bool) func()

func (*Runner) RunJobs ¶

func (r *Runner) RunJobs() error

start the scheduled jobs. Should be called after `ScheduleJobs` is non-blocking

func (*Runner) ScheduleJobs ¶

func (r *Runner) ScheduleJobs() error

func (*Runner) Shutdown ¶

func (r *Runner) Shutdown() error

type StringWriter ¶

type StringWriter interface {
	Write(p []byte) (int, error)
	String() string
}

Source Files ¶

View all Source files

runner.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL