(m *manager.Manager)
| 331 | } |
| 332 | |
| 333 | func triggerKubernetesRefresh(m *manager.Manager) gin.HandlerFunc { |
| 334 | return gin.HandlerFunc(func(c *gin.Context) { |
| 335 | domainLcuuid := c.Query("domain_lcuuid") |
| 336 | subDomainLcuuid := c.Query("sub_domain_lcuuid") |
| 337 | versionString := c.Query("version") |
| 338 | if domainLcuuid == "" || subDomainLcuuid == "" || versionString == "" { |
| 339 | response.JSON(c, response.SetOptStatus(httpcommon.INVALID_PARAMETERS), response.SetError(fmt.Errorf("required parameter missing"))) |
| 340 | return |
| 341 | } |
| 342 | version, err := strconv.Atoi(versionString) |
| 343 | if err != nil { |
| 344 | response.JSON(c, response.SetOptStatus(httpcommon.INVALID_PARAMETERS), response.SetError(err)) |
| 345 | return |
| 346 | } |
| 347 | err = service.TriggerKubernetesRefresh(domainLcuuid, subDomainLcuuid, version, m) |
| 348 | response.JSON(c, response.SetError(err)) |
| 349 | }) |
| 350 | } |
no test coverage detected