runtime

package

v0.0.1 Latest Latest Go to latest Published: Jul 13, 2023 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func AttachSubFlowsToContext(flowMetas *[]dsl.LogicFlowDefine, ctx context.Context) context.Context

func FirstUpper(s string) string

FirstUpper 字符串首字母大写

func RegisterActivity(name string, activity interface{})

func RegisterActivity[Config any, T Activity[Config]](name string, factory func(meta *dsl.ActivityDefine) *T) {

type ActivityJointers struct {
	// contains filtered or unexported fields
}

func (j *ActivityJointers) GetInput(name string) *Jointer

func (j *ActivityJointers) GetInputById(id string) *Jointer

func (j *ActivityJointers) GetOutput(name string) *Jointer

func (j *ActivityJointers) GetOutputById(id string) *Jointer

type BaseActivity[Config any] struct {
	Id       string
	Jointers *ActivityJointers
	Meta     *dsl.ActivityDefine
	Ctx      context.Context
}

func (b *BaseActivity[Config]) GetConfig() Config

func (b *BaseActivity[T]) Init(meta *dsl.ActivityDefine, ctx context.Context)

func (b *BaseActivity[Config]) Next(inputValue interface{}, outputName string)

type InputHandler = func(inputValue any, ctx context.Context)

type Jointer struct {
	Id   string
	Name string
	// contains filtered or unexported fields
}

func (j *Jointer) Connect(inuptHandler InputHandler)

func (j *Jointer) Push(inputValue any, ctx context.Context)

type LogicFlow struct {
	Id       string
	Jointers *ActivityJointers
	// contains filtered or unexported fields
}

func NewLogicflow(flowMeta dsl.LogicFlowDefine, ctx context.Context) *LogicFlow

ctx用于传递value，minions.CONTEXT_KEY_SUBMETAS 对应*[]dsl.LogicFlowDefine，子编排metas