dag

Documentation

Index

• type DAG
  • func NewDAG(nodes []NamedNode, ops ...OperationFunc) (*DAG, error)
  • func (dag *DAG) GetSchedulableNodeNames(finishes ...string) ([]string, error)
  • func (dag *DAG) GetSchedulableNodes(finishes ...string) (map[string]Node, error)
• type NamedNode
• type Node
• type OperationFunc
  • func WithAllowMarkArbitraryNodeAsDone(allow bool) OperationFunc
  • func WithAllowNotCheckCycle(allow bool) OperationFunc

Types

type DAG

type DAG struct {
	Nodes map[string]*internalNode
	// contains filtered or unexported fields
}

func NewDAG

func NewDAG(nodes []NamedNode, ops ...OperationFunc) (*DAG, error)

func (*DAG) GetSchedulableNodeNames

func (dag *DAG) GetSchedulableNodeNames(finishes ...string) ([]string, error)

func (*DAG) GetSchedulableNodes

func (dag *DAG) GetSchedulableNodes(finishes ...string) (map[string]Node, error)

type NamedNode

type NamedNode interface {
	NodeName() string
	PrevNodeNames() []string
}

type Node

type Node interface {
	NamedNode
	PrevNodes() []Node
	NextNodes() []Node
	NextNodeNames() []string
}

type OperationFunc

type OperationFunc func(dag *DAG)

func WithAllowMarkArbitraryNodeAsDone

func WithAllowMarkArbitraryNodeAsDone(allow bool) OperationFunc

func WithAllowNotCheckCycle

func WithAllowNotCheckCycle(allow bool) OperationFunc