Versions in this module Expand all Collapse all v1 v1.0.1 Oct 4, 2023 Changes in this version type Properties + EnabledDebugMode bool v1.0.0 Oct 4, 2023 Changes in this version + const ContextLogJobMeta + const ContextValueJobName + const ContextValueJobRunId + func ContextExtractor(ctx context.Context) []field.Field + func GetJobName(job Job) string + func OnStopHook(in OnStopCronIn) + func OnStopHookOpt() fx.Option + func Opt() fx.Option + func ProvideJob(jobConstructor interface{}) fx.Option + func RegisterJob(in RegisterJobIn) error + func StartCron(c Engine) + type Engine interface + AddJob func(spec string, cmd Job) error + StartAsync func() + StartSync func() + Stop func() + func NewDefaultRobfigCron(logger log.Logger) Engine + func NewRobfigCron(c *cron.Cron) Engine + type Job interface + Run func(ctx context.Context) + type JobAttributes struct + Name string + RunId string + func (c JobAttributes) MarshalLogObject(encoder field.ObjectEncoder) error + type JobConfig struct + Disabled bool + Name string + Spec string + type NamedJob interface + Name func() string + type OnStopCronIn struct + Cron Engine + Lc fx.Lifecycle + type Properties struct + Jobs []JobConfig + func NewProperties(loader config.Loader) (*Properties, error) + func (o *Properties) GetJob(jobName string) (job JobConfig, found bool) + func (o *Properties) PostBinding() error + func (o *Properties) Prefix() string + type RegisterJobIn struct + Engine Engine + Jobs []Job + Props *Properties + type RobfigCron struct + func (r RobfigCron) AddJob(spec string, cmd Job) error + func (r RobfigCron) StartAsync() + func (r RobfigCron) StartSync() + func (r RobfigCron) Stop() + type RobfigJob struct + func NewRobfigJob(job Job) *RobfigJob + func (r RobfigJob) Run() + type RobfigLogger struct + func NewRobfigLogger(logger log.Logger) *RobfigLogger + func (r RobfigLogger) Error(err error, msg string, keysAndValues ...interface{}) + func (r RobfigLogger) Info(msg string, keysAndValues ...interface{})