(ctx context.Context, clusterId string)
| 137 | } |
| 138 | |
| 139 | func (i *imlCatalogueModule) getExecutor(ctx context.Context, clusterId string) (driver.IExecutor, error) { |
| 140 | info, err := i.monitorService.GetByCluster(ctx, clusterId) |
| 141 | if err != nil { |
| 142 | return nil, err |
| 143 | } |
| 144 | return driver.CreateExecutor(info.Driver, info.Config) |
| 145 | } |
| 146 | |
| 147 | func (i *imlCatalogueModule) statistics(ctx context.Context, clusterId string, groupBy string, start, end time.Time, wheres []monitor.MonWhereItem, limit int) (map[string]monitor.MonCommonData, error) { |
| 148 | executor, err := i.getExecutor(ctx, clusterId) |
no test coverage detected