manager

Documentation

Index

• Variables
• type Handler
• type ProcessElement
• type ProcessManager
  • func GetManager() ProcessManager
  • func NewManager(logger *zap.Logger, ins []Handler) ProcessManager

Variables

var ProviderSet = wire.NewSet(NewManager)

Types

type Handler

type Handler interface {
	IsMatched(tp string) bool
	Work(process *models.Process) error
}

type ProcessElement

type ProcessElement struct {
	IsLocked bool
	LockedAt time.Time

	BlockId int
	Process *models.Process
	C       chan *models.Slots
}

type ProcessManager

type ProcessManager interface {
	List()
	Push(blockId int, process *models.Process) <-chan *models.Slots
	Fetch(judgementId, processId, processType string, ignoreLock bool) *ProcessElement
	Finish(element *ProcessElement, slots *models.Slots) error
	FinishWithError(element *ProcessElement, message string) error
	Reserve(element *ProcessElement) bool
}

func GetManager

func GetManager() ProcessManager

func NewManager

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