goflow
goflow copied to clipboard
s8sg
A Golang based high performance, scalable and distributed workflow framework
After installing goflow as explained in the guide, I have the following problem: ```sh $ go build -o goflow flow.go:6:2: no required module provides package github.com/s8sg/goflow/flow/v1; to add it: go...
If you do not specify to use the master branch, go get will download the v0.1.0 version of goflow by default, which is a version that does not match the...
package main import ( "fmt" "time" goflow "github.com/s8sg/goflow" flow "github.com/s8sg/goflow/flow" ) // Workload function func doSomething1(data []byte, option map[string][]string) ([]byte, error) { time.Sleep(10 * time.Second) fmt.Println(fmt.Sprintf("you said 1 %s", string(data)))...
Currently Flow and Workload are tightly coupled as workload are defined inside of a flow definition This has a few drawbacks 1. You can't scale only a specific workload 2....
Can you please add some examples for using this library? Also how would I return value of final result from dag?
When I try to run the sample program provided, it gives the following errors ./main.go:17:14: cannot use doSomething (type func([]byte, map[string][]string) ([]byte, error)) as type flow.BranchOption in argument to dag.Node...
## Problem The codahale/hdrhistogram repo has been transferred under the github HdrHstogram umbrella with the help from the original author in Sept 2020 (new repo url https://github.com/HdrHistogram/hdrhistogram-go). The main reasons...
**Expect:** `Pause` can pause the specified workflow, and `Resume` can resume it. `Stop` can stop active workflow and set its status to `Finished`. **Actually:** 1. After running `Pasue`, the workflow...
