Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // Module provides the timeout scanner and cron job registration. Module = fx.Module( "vef:approval:timeout", fx.Provide(NewScanner), fx.Invoke(registerTimeoutJobs), ) )
Functions ¶
This section is empty.
Types ¶
type Scanner ¶
type Scanner struct {
// contains filtered or unexported fields
}
Scanner scans for timed-out tasks and processes them.
func NewScanner ¶
func NewScanner( db orm.DB, publisher *dispatcher.EventPublisher, taskSvc *service.TaskService, nodeSvc *service.NodeService, userResolver approval.UserInfoResolver, ) *Scanner
NewScanner creates a new timeout scanner.
func (*Scanner) ScanPreWarnings ¶
ScanPreWarnings finds tasks approaching their deadline and sends warning notifications.
func (*Scanner) ScanTimeouts ¶
ScanTimeouts finds tasks that have passed their deadline and processes them.
Source Files
Click to show internal directories.
Click to hide internal directories.