(ctx context.Context, clusterId string)
| 160 | } |
| 161 | |
| 162 | func (m *imlPluginClusterModule) initCluster(ctx context.Context, clusterId string) error { |
| 163 | client, err := m.clusterService.GatewayClient(ctx, clusterId) |
| 164 | if err != nil { |
| 165 | return err |
| 166 | } |
| 167 | defer func() { |
| 168 | err := client.Close(ctx) |
| 169 | if err != nil { |
| 170 | log.Warn("close apinto client:", err) |
| 171 | } |
| 172 | }() |
| 173 | return m.initGateway(ctx, clusterId, client) |
| 174 | } |
no test coverage detected