manager

type Handler interface {
	IsMatched(tp string) bool
	Work(runtime *ProcessRuntime) error
}

type ProcessManager interface {
	Push(judgement *models.Judgement, block *engine.Block, inputs *models.Slots) <-chan *models.Slots
	Fetch(judgementId, processId, processType string, ignoreLock bool) *ProcessRuntime
	Finish(element *ProcessRuntime, slots *models.Slots) error
	FinishWithError(element *ProcessRuntime, message string) error
	Reserve(element *ProcessRuntime) bool
}

type ProcessRuntime struct {
	Mutex     *sync.Mutex
	Judgement *models.Judgement
	Process   *models.Process
	// contains filtered or unexported fields
}