Merge pull request #46 from zengzhengrong/fix45

Fix45

.gitignore

@@ -15,3 +15,4 @@ goflow.db
 
 # The test database
 test.db
+.vscode

example.go

@@ -8,7 +8,8 @@ import (
 func complexAnalyticsJob() *Job {
 	j := &Job{
 		Name:     "exampleComplexAnalytics",
-		Schedule: "* * * * *",
+		Schedule: "* * * * * *",
+		Active:   false,
 	}
 
 	j.Add(&Task{
@@ -82,7 +83,7 @@ func (o PositiveAddition) Run() (interface{}, error) {
 
 // Use our custom operation in a job.
 func customOperatorJob() *Job {
-	j := &Job{Name: "exampleCustomOperator", Schedule: "* * * * *", Active: true}
+	j := &Job{Name: "exampleCustomOperator", Schedule: "* * * * * *", Active: true}
 	j.Add(&Task{Name: "posAdd", Operator: PositiveAddition{5, 6}})
 	return j
 }

example/goflow-example.go

@@ -1,12 +1,15 @@
 package main
 
-import "github.com/fieldryand/goflow/v2"
+import (
+	"github.com/fieldryand/goflow/v2"
+)
 
 func main() {
 	options := goflow.Options{
 		UIPath:       "ui/",
 		Streaming:    true,
 		ShowExamples: true,
+		WithSeconds:  true,
 	}
 	gf := goflow.New(options)
 	gf.Use(goflow.DefaultLogger())

goflow.go

@@ -26,21 +26,28 @@ type Options struct {
 	UIPath       string
 	Streaming    bool
 	ShowExamples bool
+	WithSeconds  bool
 }
 
 // New returns a Goflow engine.
 func New(opts Options) *Goflow {
+	var c *cron.Cron
 	if opts.Store == nil {
 		opts.Store = gomap.NewStore(gomap.DefaultOptions)
 	}
 	defer opts.Store.Close()
+	if opts.WithSeconds {
+		c = cron.New(cron.WithSeconds())
+	} else {
+		c = cron.New()
+	}
 
 	g := &Goflow{
 		Store:            opts.Store,
 		Options:          opts,
 		Jobs:             make(map[string](func() *Job)),
 		router:           gin.New(),
-		cron:             cron.New(),
+		cron:             c,
 		activeJobCronIDs: make(map[string]cron.EntryID),
 	}