goflow

goflow copied to clipboard

Redis might become a single point of failure even if redis-sentinel/cluster is used. Replacement of redis with https://github.com/hashicorp/raft will remove that single point of failure and enable packaging of goflow...

alphadose

There is no option to pass the redis client into goflow struct

1

When initializing GoFlow with all the necessary configurations, I encountered an issue with passing the Redis client. In the GoFlow struct, there's only an option to provide the RedisClient: fs...

AswathyAshokan

Why do we choose []byte as the type of workload func's param/output, not interface{}

2

IIUC, the workload function is like: ``` func doSomething(data []byte, option map[string][]string) ([]byte, error) ``` Why do we choose []byte as the type of its param/output, not interface{} or Golang...

jasonliu119

Broken dependency tree when trying to use goflow for the first time

1

Hey All, The imported the two dependencies for golang as follows - ``` import ( "fmt" goflow "github.com/s8sg/goflow/v1" flow "github.com/s8sg/goflow/flow/v1" ) ``` and then `go mod tidy`, but I get...

manitgupta

Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.9.0 to 0.17.0. Commits 9d2ee97 ssh: implement strict KEX protocol changes 4e5a261 ssh: close net.Conn on all NewServerConn errors 152cdb1 x509roots/fallback: update bundle fdfe1f8 ssh: defer channel...

dependabot[bot]

Bumps [golang.org/x/net](https://github.com/golang/net) from 0.10.0 to 0.17.0. Commits b225e7c http2: limit maximum handler goroutines to MaxConcurrentStreams 88194ad go.mod: update golang.org/x dependencies 2b60a61 quic: fix several bugs in flow control accounting 73d82ef...

dependabot[bot]

Allow to connect to a specifically redis db by adding a field RedisDB to FlowService struct

caubechankiu

Get response from latest edge/node

2

How to get response from latest executed node and send back to the client?

suryakoinworks

I have a flow with multiple nodes: 1 -> 2 -> 3 -> 4. When this flow is executed, Node 1 done, Node 2 done, Node 3 runs for a...

caubechankiu

[enhancement]: flow metrics / prometheus integration

1

It would be awesome to have default metrics like: flow started, elapsed times, flow counts, etc. Also those can be exported to prometheus by default. We would like to contribute...

mstrYoda