internal

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

	Heads        []*GraphVertex[E]
	SerialGroups map[string][]*GraphVertex[E]
	DoingMap     map[string]struct{}
	ScheduleNum  int

	sync.Mutex
}

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

type GraphMarshaler[E any] struct {
	Vertices map[string]E
	Edges    [][2]string
}

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

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

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

type WorkParams struct {
	GorLimit         int
	ActionsBeforeRun map[string]ogcore.Action
	ActionsAfterRun  map[string]ogcore.Action
}

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
}