()
| 298 | } |
| 299 | |
| 300 | func (m *Manager) Start() { |
| 301 | cloudcfg.SetCloudGlobalConfig(m.cfg.TaskCfg.CloudCfg) |
| 302 | recordercfg.Set(&m.cfg.TaskCfg.RecorderCfg) |
| 303 | |
| 304 | log.Info("manager started") |
| 305 | ctx := context.Context(context.Background()) |
| 306 | go func() { |
| 307 | m.run(ctx) |
| 308 | for range time.Tick(time.Duration(m.cfg.CloudConfigCheckInterval) * time.Second) { |
| 309 | m.run(ctx) |
| 310 | } |
| 311 | }() |
| 312 | } |