Function initTaskManager

cmd/cql-proxy/init.go:114–130

(e *gin.Engine, cfg *config.Config, db *gorp.DbMap)

}

func initTaskManager(e *gin.Engine, cfg *config.Config, db *gorp.DbMap) (tm *task.Manager) {
	tm = task.NewManager(cfg, db)

	tm.Register(model.TaskCreateDB, api.CreateDatabaseTask)
	tm.Register(model.TaskApplyToken, api.ApplyTokenTask)
	tm.Register(model.TaskTopUp, api.TopUpTask)
	tm.Register(model.TaskCreateProject, api.CreateProjectTask)

	tm.Start()

	e.Use(func(c *gin.Context) {
		c.Set("task", tm)
		c.Next()
	})

	return
}

func initRulesManager(e *gin.Engine) (rm *resolver.RulesManager) {
	rm = &resolver.RulesManager{}