Method ProviderStatistics

module/catalogue/iml.go:186–223

(ctx context.Context, start, end time.Time, serviceIds ...string)

}

func (i *imlCatalogueModule) ProviderStatistics(ctx context.Context, start, end time.Time, serviceIds ...string) (map[string]int64, error) {
	// 判断是否配置influxdb
	clusterId := cluster.DefaultClusterID
	_, err := i.monitorService.Get(ctx, clusterId)
	if err != nil {
		if errors.Is(err, gorm.ErrRecordNotFound) {
			return make(map[string]int64), nil
		}
		return nil, err
	}
	_, err = i.clusterService.Get(ctx, clusterId)
	if err != nil {
		return nil, err
	}

	wheres, err := i.genCommonWheres(ctx, clusterId)
	if err != nil {
		return nil, err
	}

	if len(serviceIds) > 0 {
		wheres = append(wheres, monitor.MonWhereItem{
			Key:       "provider",
			Operation: "in",
			Values:    serviceIds,
		})
	}
	statisticMap, err := i.statistics(ctx, clusterId, "provider", start, end, wheres, 0)
	if err != nil {
		return nil, err
	}
	resultMap := make(map[string]int64)
	for key, item := range statisticMap {
		resultMap[key] = item.RequestTotal
	}

	return resultMap, nil
}

func (i *imlCatalogueModule) Subscribe(ctx context.Context, subscribeInfo *catalogue_dto.SubscribeService) error {
	if len(subscribeInfo.Applications) == 0 {