goflow
goflow copied to clipboard
s8sg
A Golang based high performance, scalable and distributed workflow framework
We would like to add custom middleware to the internal http server. Also if we can pass query parameters to the endpoints, we can create more generalized flows. Goflow library...
It would be awesome to expose flow events via registering event hooks to flow library. We would like to know when our flow state change: started, completed, failed, etc. We...
It's good for triggering workflow by api. But sometimes i wanna run my workflow in command mode. I wanna keep my workflow definition. ``` package amin import ( "fmt" flow...
[Feature] Support dynamically appending flows after the flow service started. Currently, it is only possible to register a workflow before starting the flow service. If you need to register a...
Here is FlowService struct ``` golang type FlowService struct { Port int RedisURL string RedisPassword string RequestAuthSharedSecret string RequestAuthEnabled bool WorkerConcurrency int RetryCount int Flows map[string]runtime.FlowDefinitionHandler RequestReadTimeout time.Duration RequestWriteTimeout time.Duration...
Hi @s8sg , We are using goflow to build an online system. The main use case is to orchestrate different tasks together like workflows. For example, initially user has a...
Queue Worker is mainly used to handle async operations. Queue working internally uses RMQ - which internally uses Redis The goal is to abstract the queue-worker in a way so...
Currently we are using redis to register * Flows * Worker * Workload (In Progress) Code is currently scattered across runtime like [this](https://github.com/s8sg/goflow/blob/4665151427fe3a21c30659122dd4f82e6c0d22a2/runtime/flow_runtime.go#L531) The goal is to obstruct the RDB...
GoFlow DSL would allow user to define a workflow as a DSL. DSL can be a simple yaml file The expectation is: 1. Aligned to go flow domain 2. Provide...