manager

Nov 17, 2021

Changes in this version

+ func Push(judgement *models.Judgement, block *engine.Block, inputs *models.Slots) <-chan *models.Slots

Oct 31, 2021

Changes in this version

+ type ProcessRuntime struct

+ Judgement *models.Judgement

+ Mutex *sync.Mutex

+ Process *models.Process

Oct 23, 2021

Changes in this version

+ var ProviderSet = wire.NewSet(NewManager)

+ type Handler interface

+ IsMatched func(tp string) bool

+ Work func(process *models.Process) error

+ type ProcessElement struct

+ BlockId int

+ C chan *models.Slots

+ IsLocked bool

+ LockedAt time.Time

+ Process *models.Process

+ type ProcessManager interface

+ Fetch func(judgementId, processId, processType string, ignoreLock bool) *ProcessElement

+ Finish func(element *ProcessElement, slots *models.Slots) error

+ FinishWithError func(element *ProcessElement, message string) error

+ List func()

+ Push func(blockId int, process *models.Process) <-chan *models.Slots

+ Reserve func(element *ProcessElement) bool

+ func GetManager() ProcessManager

+ func NewManager(logger *zap.Logger, ins []Handler) ProcessManager