manager

Documentation

Index

• Variables
• func Push(judgement *models.Judgement, block *engine.Block, inputs *models.Slots) <-chan *models.Slots
• type Handler
• type ProcessManager
  • func NewManager(logger *zap.Logger, ins []Handler) ProcessManager
• type ProcessRuntime

Variables

var ProviderSet = wire.NewSet(NewManager)

Functions

func Push

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

Types

type Handler

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

type ProcessManager

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
}

func NewManager

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

type ProcessRuntime

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