private String sumSumOverTimeFunc()

in ozhera-monitor/ozhera-monitor-service/src/main/java/org/apache/ozhera/monitor/service/prometheus/PrometheusService.java [484:546]


    private String sumSumOverTimeFunc(String source,String metric,String sumBy) {

        StringBuilder sb = new StringBuilder();
        sb.append("sum(sum_over_time(");
        sb.append(source);
        sb.append(")) ");
        if (StringUtils.isNotBlank(sumBy)) {
            sb.append(" by (").append(sumBy).append( ")");
        }else {
            switch (metric) {
                case "dubboProviderSLAError":
                    sb.append(" by (application,methodName,serviceName,serverEnv,serverZone,clientProjectName,clientEnv) ");
                    break;
                case "dubboConsumerError":
                    sb.append(" by (serverIp,application,methodName,serviceName,serverEnv,serverZone) ");
                    break;
                case "dubboProviderError":
                    sb.append(" by (serverIp,application,methodName,serviceName,serverEnv,serverZone) ");
                    break;
                case "httpError":
                    sb.append(" by (serverIp,application,methodName,serviceName,serverEnv,serverZone,errorCode) ");
                    break;
                case "httpClientError":
                    sb.append(" by (serverIp,application,methodName,serviceName,serverEnv,serverZone,errorCode) ");
                    break;
                case "redisError":
                    sb.append(" by (serverIp,application,method,serverEnv,serverZone) ");
                    break;
                case "dbError":
                    sb.append(" by (serverIp,application,dataSource,sqlMethod,sql,serverEnv,serverZone) ");
                    break;
                case "grpcClientError":
                    sb.append(" by (serverIp,application,methodName,serviceName,serverEnv,serverZone) ");
                    break;
                case "grpcServerError":
                    sb.append(" by (serverIp,application,methodName,serviceName,serverEnv,serverZone) ");
                    break;
                case "thriftServerError":
                    sb.append(" by (serverIp,application,methodName,serviceName,serverEnv,serverZone) ");
                    break;
                case "thriftClientError":
                    sb.append(" by (serverIp,application,methodName,serviceName,serverEnv,serverZone) ");
                    break;
                case "apusServerError":
                    sb.append(" by (serverIp,application,methodName,serviceName,serverEnv,serverZone) ");
                    break;
                case "apusClientError":
                    sb.append(" by (serverIp,application,methodName,serviceName,serverEnv,serverZone) ");
                    break;
                case "oracleError":
                    sb.append(" by (serverIp,application,dataSource,sqlMethod,sql,serverEnv,serverZone) ");
                    break;
                case "elasticsearchClientError":
                    sb.append(" by (serverIp,application,dataSource,sqlMethod,sql,serverEnv,serverZone) ");
                    break;

                default:
                    sb.append(" by (serverIp,application,methodName,serviceName,dataSource,sqlMethod,sql,serverEnv,serverZone,containerName,method,clientProjectId,clientProjectName,clientEnv) ");
            }
        }

        return sb.toString();
    }