libdag

type CONTROL_CODE int

type ConfigManager interface {
	GetConfig(configKey string) (*DagConfig, error)
}

type DagConfig struct {
	Name   string                 `yaml:"name"`
	Input  []string               `yaml:"input"`
	Output []string               `yaml:"output"`
	Nodes  map[string]*NodeConfig `yaml:"nodes"`
}

type DagGraph struct {
	Nodes map[string]*DagGraphNode
}

type DagGraphNode struct {
	Name     string
	Indegree int        //入度
	Outputs  *list.List //输出节点
}

type DagNodeHandler interface {
	Init(parentCtx context.Context, params map[string]interface{}) error //初始化方法
	Process(parentCtx context.Context, input map[string]interface{}) (map[string]interface{}, error)
}

type HandlerManager interface {
	CreateHandler(handlerName string) (DagNodeHandler, error)
}

type Job struct {
	Key  string
	Name string
	// contains filtered or unexported fields
}

type JobContext struct {
	sync.RWMutex
	Config          *DagConfig
	GlobalVals      *sync.Map
	HandlerRegistry HandlerManager
}

type NodeConfig struct {
	Name      string                 `yaml:"name"`
	Labels    []string               `yaml:"labels"`
	Critical  bool                   `yaml:"critical"`
	Processor string                 `yaml:"processor"`
	Params    map[string]interface{} `yaml:"params"`
	Input     map[string]string      `yaml:"input"`
	Output    map[string]string      `yaml:"output"`
}

type Task struct {
	Key  string
	Name string
	// contains filtered or unexported fields
}

type YamlConfig struct {
	DagConfig *DagConfig `yaml:"dag_config"`
}