(ctx context.Context, clusterId string)
| 76 | return nodesOut, nil |
| 77 | } |
| 78 | func (m *imlClusterModule) initGateway(ctx context.Context, clusterId string) error { |
| 79 | client, err := m.clusterService.GatewayClient(ctx, clusterId) |
| 80 | if err != nil { |
| 81 | return err |
| 82 | } |
| 83 | defer func() { |
| 84 | err := client.Close(ctx) |
| 85 | if err != nil { |
| 86 | log.Warn("close apinto client:", err) |
| 87 | } |
| 88 | }() |
| 89 | return gateway.InitGateway(ctx, clusterId, client) |
| 90 | } |
| 91 | func (m *imlClusterModule) ClusterNodes(ctx context.Context, clusterId string) ([]*cluster_dto.Node, error) { |
| 92 | |
| 93 | nodes, err := m.clusterService.Nodes(ctx) |
no test coverage detected