internal

type Graph[E any] struct {
	Vertices map[string]*GraphVertex[E]
	Edges    map[GraphEdge[E]]bool

	Heads       []*GraphVertex[E]
	VertexSlice []*GraphVertex[E]
	ScheduleNum int

	sync.Mutex
	// contains filtered or unexported fields
}

type GraphEdge[E any] struct {
	From *GraphVertex[E]
	To   *GraphVertex[E]
}

type GraphMarshaler[E any] struct {
	Vertices map[string]E `json:"Vertices,omitempty"`
	Edges    [][2]string  `json:"Edges,omitempty"`

	SubGraphs map[string]*GraphMarshaler[E] `json:"SubGraphs,omitempty"`
}

type GraphVertex[E any] struct {
	Name   string
	Status int
	Wait   int
	Elem   E

	Dependencies []*GraphVertex[E]
	Next         []*GraphVertex[E]
	Group        []*GraphVertex[E]
}

type Mapper[OE any, NE any] func(OE) (NE, error)

type WorkParams struct {
	GorLimit   int
	Tracker    *ogcore.Tracker
	Interrupts iter.Seq[string]
}

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

type WorkerCache struct {
	MaxSize int

	sync.Mutex
	// contains filtered or unexported fields
}

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