pipelinex

type Adapter interface {
	// Config 适配器配置
	Config(config map[string]interface{}) Adapter
	// Conn 连接到环境中
	Conn(ctx context.Context) interface{}
}

type Bridge interface {
	// Transfer 传输需要执行的数据，并且反回执行的结果
	Transfer(ctx context.Context, in chan<- interface{}, out <-chan interface{})
}

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

type Event string

type Executor interface {
	// Prepare 准备环境
	Prepare(ctx context.Context) error
	// Destruction 销毁环境
	Destruction(ctx context.Context) error
}

type Graph interface {
	//Nodes
	Nodes() map[string]Node
	//AddVertex 添加顶点
	AddVertex(node Node)
	//AddEdge 添加边
	AddEdge(src, dest string)
	//CycelCheck
	CycelCheck() bool
	//BFS 广度有限搜索
	BFS() []string
}

type Listener interface {
	// 处理对应的事件将事件发生的对应的流水线和对应的事件作为参数传入
	Handle(p Pipeline, event Event)
	// 获取当前注册的Event
	Events() []Event
}

type ListeningFn func(p Pipeline)

type Metadata map[string]interface{}

type Node interface {
	//ID 获取节点唯一id
	ID() string
	//节点组id
	GroupID() string
	//Status 获取节点状态
	Status() string
	//Get 获取节点属性数据
	Get(key string) string
}

type Pipeline interface {
	//ID 流水线的id
	ID() string
	//GetGraph 返回图结构
	GetGraph() Graph
	//SetGraph 设置图结构
	SetGraph(graph Graph)
	//Status 返回流水线的整体状态
	Status() string
	//Metadata 返回流水线执行的源数据
	Metadata() Metadata
	//Listening 流水线执行事件监听设置
	Listening(listener Listener)
	//Done流水线是否执行完成
	Done() <-chan struct{}
	//Run执行流水线
	Run(ctx context.Context) error
	//Notify 执行的步骤通知流水线
	Notify()
	//Cancel 取消流水线
	Cancel()
}

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

type Runtime interface {
	//获取流水线状态
	Get(id string) (Pipeline, error)
	//取消运行中的流水线
	Cancel(ctx context.Context, id string) error
	//执行异步流水线
	RunAsync(ctx context.Context, id string, config string, listener Listener) (Pipeline, error)
	//执行同步流水线
	RunSync(ctx context.Context, id string, config string, listener Listener) (Pipeline, error)
	//移除流水线记录
	Rm(id string)
	//runtime已经执行完成
	Done() chan struct{}
	//通知runtime
	Notify(data interface{}) error
	//反回runtime公共
	Ctx() context.Context
	//停止后台处理
	StopBackground()
}