🤬
Revision indexing in progress... (symbol navigation in revisions will be accurate after indexed)
  • ■ ■ ■ ■ ■
    pkg/cron/job/cluster_event.go
    skipped 27 lines
    28 28  }
    29 29   
    30 30  func (c *ClusterEvent) Run() {
    31  - logger.Log.Infof("start health check")
    32 31   var wg sync.WaitGroup
    33 32   sem := make(chan struct{}, 5) // 信号量
    34 33   clusters, _ := c.clusterService.List()
    skipped 71 lines
Please wait...
Page is in error, reload to recover