diff --git a/main.go b/main.go index d78a2ac..134a479 100644 --- a/main.go +++ b/main.go @@ -6,9 +6,6 @@ import ( "github.com/docker/docker/client" "github.com/robfig/cron" "golang.org/x/net/context" - "io" - "log" - "os" "strings" "time" ) @@ -40,15 +37,12 @@ func main() { panic(err) } - c := cron.New() - jobs := []ContainerStartJob{} for _, container := range containers { if val, ok := container.Labels["cron.schedule"]; ok { jobName := strings.Join(container.Names, "/") - fmt.Println("Scheduling ", jobName, "(", val, ")") - c.AddJob(val, ContainerStartJob{ + jobs = append(jobs, ContainerStartJob{ Schedule: val, Client: cli, ContainerID: container.ID, @@ -58,6 +52,13 @@ func main() { } } + c := cron.New() + + for _, job := range jobs { + fmt.Println("Scheduling ", job.Name, "(", job.Schedule, ")") + c.AddJob(job.Schedule, job) + } + // Start the cron job threads c.Start()