Versions in this module Expand all Collapse all v0 v0.4.0 Jul 14, 2018 v0.3.0 Jul 14, 2018 Changes in this version + func NewCron(cfg []byte, options *config.Options) (*cron.Cron, error) + type CronEntry struct + Command []string + Cron string + Name string + Options map[string]interface{} + type Runner struct + Cmd []string + FireAndForget bool + LogBuffer RunnerPipe + MutexName string + MutexPrefix string + MutexTTL time.Duration + RandomWait int + RedisPool *redis.Pool + Stderr RunnerPipe + Stdout RunnerPipe + TaskTTL time.Duration + func NewRunner(cmd []string) *Runner + func (r *Runner) Run() (int, error) + type RunnerPipe struct + Reader *io.PipeReader + Writer *io.PipeWriter
Go to main page