(ctx context.Context, clusterId string, clientDriver gateway.IClientDriver)
| 742 | } |
| 743 | |
| 744 | func (i *imlProviderModule) initGateway(ctx context.Context, clusterId string, clientDriver gateway.IClientDriver) error { |
| 745 | providers, err := i.getAiProviders(ctx) |
| 746 | if err != nil { |
| 747 | return err |
| 748 | } |
| 749 | |
| 750 | for _, p := range providers { |
| 751 | client, err := clientDriver.Dynamic(p.Resource) |
| 752 | if err != nil { |
| 753 | return err |
| 754 | } |
| 755 | err = client.Online(ctx, p) |
| 756 | if err != nil { |
| 757 | return err |
| 758 | } |
| 759 | } |
| 760 | |
| 761 | return nil |
| 762 | } |
| 763 | |
| 764 | func (i *imlProviderModule) syncGateway(ctx context.Context, clusterId string, releases []*gateway.DynamicRelease, online bool) error { |
| 765 | client, err := i.clusterService.GatewayClient(ctx, clusterId) |
nothing calls this directly
no test coverage detected