[小ネタ]Go言語でワークフローを実行できる「goflow」を試してみた

package main

import (
	"errors"
	"log"
	"net/http"

	"github.com/fieldryand/goflow/v2"
	bbolt "github.com/philippgille/gokv/bbolt"
)

type PositiveAddition struct{ a, b int }

func (o PositiveAddition) Run() (interface{}, error) {
	if o.a < 0 || o.b < 0 {
		return 0, errors.New("can't add negative numbers")
	}
	result := o.a + o.b
	return result, nil
}

func myJob() *goflow.Job {
	j := &goflow.Job{Name: "my-job", Schedule: "CRON_TZ=Asia/Tokyo 00 22 16 * * *", Active: true}
	j.Add(&goflow.Task{
		Name:     "1秒Sleep",
		Operator: goflow.Command{Cmd: "sleep", Args: []string{"1"}},
	})
	return j
}
func myJob2() *goflow.Job {
	j := &goflow.Job{Name: "my-job2", Schedule: "CRON_TZ=Asia/Tokyo 00 58 16 * * *", Active: true}
	j.Add(&goflow.Task{
		Name:       "1秒Sleep",
		Operator:   goflow.Command{Cmd: "sleep", Args: []string{"1"}},
		Retries:    5,
		RetryDelay: goflow.ConstantDelay{Period: 1},
	})
	j.Add(&goflow.Task{
		Name:     "get-google",
		Operator: goflow.Get{Client: &http.Client{}, URL: "https://www.google.com"},
	})
	j.Add(&goflow.Task{
		Name:     "add-two-plus-three",
		Operator: PositiveAddition{a: 2, b: 3},
	})
	j.SetDownstream(j.Task("1秒Sleep"), j.Task("get-google"))
	j.SetDownstream(j.Task("get-google"), j.Task("add-two-plus-three"))
	return j
}

func main() {
	store, err := bbolt.NewStore(bbolt.Options{
		BucketName: "boltBucket",
		Path:       "bbolt.db",
	})
	if err != nil {
		log.Fatal(err)
	}
	defer store.Close()

	options := goflow.Options{
		Store:        store,
		UIPath:       "ui/",
		ShowExamples: false, // not show examples
		Streaming:    true,
		WithSeconds:  true,
	}
	gf := goflow.New(options)
	gf.AddJob(myJob)
	gf.AddJob(myJob2)
	gf.Use(goflow.DefaultLogger())

	gf.Run(":8181")
}