(ctx context.Context, clusterId string, clientDriver gateway.IClientDriver)
| 78 | } |
| 79 | |
| 80 | func (i *imlSubscribeModule) initGateway(ctx context.Context, clusterId string, clientDriver gateway.IClientDriver) error { |
| 81 | |
| 82 | projects, err := i.serviceService.List(ctx) |
| 83 | if err != nil { |
| 84 | return err |
| 85 | } |
| 86 | serviceIds := utils.SliceToSlice(projects, func(p *service.Service) string { |
| 87 | return p.Id |
| 88 | }) |
| 89 | releases, err := i.getSubscribers(ctx, serviceIds) |
| 90 | if err != nil { |
| 91 | return err |
| 92 | } |
| 93 | |
| 94 | return clientDriver.Subscribe().Online(ctx, releases...) |
| 95 | } |
| 96 | |
| 97 | func (i *imlSubscribeModule) SearchSubscriptions(ctx context.Context, appId string, keyword string) ([]*subscribe_dto.SubscriptionItem, error) { |
| 98 | info, err := i.serviceService.Get(ctx, appId) |
nothing calls this directly
no test coverage detected