| 309 | } |
| 310 | |
| 311 | func getGenesisKubernetesData(g *genesis.Genesis) gin.HandlerFunc { |
| 312 | return gin.HandlerFunc(func(c *gin.Context) { |
| 313 | orgID, err := routercommon.GetContextOrgID(c) |
| 314 | if err != nil { |
| 315 | response.JSON(c, response.SetOptStatus(httpcommon.ORG_ID_INVALID), response.SetError(err)) |
| 316 | return |
| 317 | } |
| 318 | k8sEntries, err := service.GetGenesisKubernetesData(g, orgID, c.Param("clusterID")) |
| 319 | if err != nil { |
| 320 | response.JSON(c, response.SetOptStatus(httpcommon.RESOURCE_NOT_FOUND), response.SetError(err)) |
| 321 | return |
| 322 | } |
| 323 | data := map[string][]string{} |
| 324 | for key, entries := range k8sEntries { |
| 325 | for _, entry := range entries { |
| 326 | data[key] = append(data[key], string(entry)) |
| 327 | } |
| 328 | } |
| 329 | response.JSON(c, response.SetData(data), response.SetError(err)) |
| 330 | }) |
| 331 | } |
| 332 | |
| 333 | func triggerKubernetesRefresh(m *manager.Manager) gin.HandlerFunc { |
| 334 | return gin.HandlerFunc(func(c *gin.Context) { |