workflow

Documentation

Index

• Variables
• func Build(wfConf *conf.WorkflowConfig, id int64) ([]func() (io.ReadWriter, func()), []func() (io.Writer, func()))
• func Run(endpoint string, handle quic.ServerHandler) error
• type Client
• type Stream

Variables

var FlowClients map[string]Client

var SinkClients map[string]Client

Functions

func Build

func Build(wfConf *conf.WorkflowConfig, id int64) ([]func() (io.ReadWriter, func()), []func() (io.Writer, func()))

Build build the workflow by config (.yaml).

func Run

func Run(endpoint string, handle quic.ServerHandler) error

Run runs quic service

Types

type Client

type Client struct {
	App        conf.App
	StreamMap  map[int64]Stream
	QuicClient quic.Client
}

type Stream

type Stream struct {
	St         io.ReadWriter
	CancelFunc context.CancelFunc
}