processes

Documentation

Index

• Variables
• func ConstString(element *ProcessElement) (bool, error)
• func Evaluate(element *ProcessElement) (bool, error)
• func File(element *ProcessElement) (bool, error)
• func String(element *ProcessElement) (bool, error)
• type Controller
  • func NewController(logger *zap.Logger, s Service) Controller
• type DefaultController
  • func (d *DefaultController) GetProcess(c *gin.Context)
  • func (d *DefaultController) GetProcesses(c *gin.Context)
  • func (d *DefaultController) ReserveProcess(c *gin.Context)
  • func (d *DefaultController) UpdateProcess(c *gin.Context)
• type InitProcessGroupFn
  • func CreateInitControllersFn(jc Controller) InitProcessGroupFn
• type ProcessElement
• type ProcessManager
  • func GetManager() ProcessManager
  • func NewManager(logger *zap.Logger) ProcessManager
• type Service
  • func NewService(logger *zap.Logger, manager ProcessManager) Service

Variables

var ProviderSet = wire.NewSet(CreateInitControllersFn,
	NewController,
	NewService,
	NewManager,
)

Functions

func ConstString

func ConstString(element *ProcessElement) (bool, error)

func Evaluate

func Evaluate(element *ProcessElement) (bool, error)

func File

func File(element *ProcessElement) (bool, error)

func String

func String(element *ProcessElement) (bool, error)

Types

type Controller

type Controller interface {
	GetProcesses(c *gin.Context)
	GetProcess(c *gin.Context)
	UpdateProcess(c *gin.Context)
	ReserveProcess(c *gin.Context)
}

func NewController

func NewController(logger *zap.Logger, s Service) Controller

type DefaultController

type DefaultController struct {
	// contains filtered or unexported fields
}

func (*DefaultController) GetProcess

func (d *DefaultController) GetProcess(c *gin.Context)

func (*DefaultController) GetProcesses

func (d *DefaultController) GetProcesses(c *gin.Context)

func (*DefaultController) ReserveProcess

func (d *DefaultController) ReserveProcess(c *gin.Context)

func (*DefaultController) UpdateProcess

func (d *DefaultController) UpdateProcess(c *gin.Context)

type InitProcessGroupFn

type InitProcessGroupFn func(r *gin.RouterGroup)

func CreateInitControllersFn

func CreateInitControllersFn(jc Controller) InitProcessGroupFn

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) ProcessManager

type Service

type Service interface {
	GetProcesses(processType string) (process []*models.Process, err error)
	GetProcess(processId string) (process *models.Process, err error)
	UpdateProcess(processId, warning, error string, outputs *models.Slots) (process *models.Process, err error)
	ReserveProcess(processId string) (token string, locked bool, err error)
}

func NewService

func NewService(logger *zap.Logger, manager ProcessManager) Service