(ctx context.Context, s *service.Service)
| 270 | } |
| 271 | |
| 272 | func (i *imlAuthorizationModule) online(ctx context.Context, s *service.Service) error { |
| 273 | clusters, err := i.clusterService.List(ctx) |
| 274 | if err != nil { |
| 275 | return err |
| 276 | } |
| 277 | if len(clusters) < 1 { |
| 278 | return nil |
| 279 | } |
| 280 | release, err := i.getApplicationRelease(ctx, s) |
| 281 | if err != nil { |
| 282 | return err |
| 283 | } |
| 284 | for _, c := range clusters { |
| 285 | if len(release.Authorizations) < 1 { |
| 286 | err = i.doOffline(ctx, c.Uuid, release) |
| 287 | if err != nil { |
| 288 | log.Warnf("service authorization offline for cluster[%s] %v", c.Name, err) |
| 289 | } |
| 290 | continue |
| 291 | } |
| 292 | err = i.doOnline(ctx, c.Uuid, release) |
| 293 | if err != nil { |
| 294 | log.Warnf("service authorization online for cluster[%s] %v", c.Name, err) |
| 295 | } |
| 296 | } |
| 297 | return nil |
| 298 | } |
| 299 | func (i *imlAuthorizationModule) doOnline(ctx context.Context, clusterId string, app *gateway.ApplicationRelease) error { |
| 300 | client, err := i.clusterService.GatewayClient(ctx, clusterId) |
| 301 | if err != nil { |
no test coverage detected