dags

Documentation

Index

• type ChannelDag
  • func (dag *ChannelDag) Push(taskName string, data interface{}, resultChan chan map[string]interface{}) chan map[string]interface{}
  • func (dag *ChannelDag) Run() *sync.WaitGroup
  • func (dag *ChannelDag) Stop()
• type DAG
  • func InitChannelDag(dagGrpah [][]string, assetsMap map[string]processing.Asset, ...) DAG
• type DagRoutine
• type TransitionTask

Types

type ChannelDag

type ChannelDag struct {
	DagInstanceName string
	// contains filtered or unexported fields
}

func (*ChannelDag) Push

func (dag *ChannelDag) Push(taskName string, data interface{}, resultChan chan map[string]interface{}) chan map[string]interface{}

func (*ChannelDag) Run

func (dag *ChannelDag) Run() *sync.WaitGroup

Run implements DAG.

func (*ChannelDag) Stop

func (dag *ChannelDag) Stop()

type DAG

type DAG interface {
	Run() *sync.WaitGroup
	Push(workflowInstanceName string, data interface{}, resultChan chan map[string]interface{}) chan map[string]interface{}
	Stop()
}

func InitChannelDag

func InitChannelDag(dagGrpah [][]string, assetsMap map[string]processing.Asset, config *configs.Config, name string) DAG

type DagRoutine

type DagRoutine struct {
	Name string

	Asset          processing.Asset
	InputChannels  map[string]chan *TransitionTask
	OutPutChannels map[string]chan *TransitionTask
	// contains filtered or unexported fields
}

type TransitionTask

type TransitionTask struct {
	TaskName     string
	Data         interface{}
	StopSignal   bool
	IngoreSignal bool
}