runtime

package

v0.1.1 Latest Latest Go to latest Published: Jul 20, 2023 License: MIT Imports: 5 Imported by: 0

Details

View Source

const CONTEXT_KEY_SUBMETAS = "submetas"

This section is empty.

func AttachSubFlowsToContext(flowMetas *[]dsl.SubLogicFlowMeta, 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.NodeDefine) *T) {

type Activity[Config any] struct {
	BaseActivity BaseActivity
}

为了处理Config添加的一层，这个在反射时不能被显式类型转换

func (a *Activity[Config]) GetConfig() Config

func (a *Activity[Config]) Next(inputValue any, outputName string, ctx context.Context)

func (a *Activity[Config]) Output(inputValue any, ctx context.Context)

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

func (j *ActivityJointers) GetSingleInput() *Jointer

func (j *ActivityJointers) GetSingleOutput() *Jointer

type BaseActivity struct {
	Id       string
	Jointers *ActivityJointers
	Meta     *dsl.NodeDefine
	Ctx      context.Context
}

func (b *BaseActivity) Init(meta *dsl.NodeDefine, ctx context.Context)

func (b *BaseActivity) 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.LogicFlowMeta, ctx context.Context) *LogicFlow

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