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]

	Priority int
}

type HasPriority interface {
	GetPriority() int
}

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

type Transaction struct {
	Manager *TransactionManager

	Node ogcore.Transactional
}

type TransactionManager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

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

	Pause        bool
	ContinueCond *sync.Cond
}

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
}