Allow redis to be configured with password

[pdxrlj]

package main

import (
	"fmt"

	flow "github.com/s8sg/goflow/flow/v1"
	goflow "github.com/s8sg/goflow/v1"
)

// Workload function
func doSomething(data []byte, option map[string][]string) ([]byte, error) {
	fmt.Printf("hello world\n")
	return []byte(fmt.Sprintf("you said \"%s\"", string(data))), nil
}

// Define provide definition of the workflow
func DefineWorkflow(workflow *flow.Workflow, context *flow.Context) error {
	dag := workflow.Dag()
	dag.Node("test", doSomething)
	return nil
}

func main() {
	fs := &goflow.FlowService{
		Port:              8080,
		RedisURL:          "192.168.1.65:16379", // need redis password 123
		OpenTraceUrl:      "192.168.1.65:5775",
		WorkerConcurrency: 5,
		EnableMonitoring:  true,
	}

	fs.Register("myflow", DefineWorkflow)
	fs.Start()
}

[s8sg]

I think we should have a way to define the redistribution configuration.
For now you can follow the go flow getting started instructions

Let me change the issue as an enhancement to support redis user/password

[s8sg]

#59 Needs to be tested

[s8sg]

Completed