D-Net

package eu.dnetlib.openaire.exporter.aop;

import io.prometheus.client.Gauge;

import org.aspectj.lang.ProceedingJoinPoint;

import org.aspectj.lang.annotation.Around;

import org.aspectj.lang.annotation.Aspect;

import org.springframework.stereotype.Component;

/**

 * Created by claudio on 25/07/2017.

 */

@Aspect

@Component

public class DatasourceApiProfiler extends AbstractApiProfiler {

	private static final Gauge dsCountries = Gauge.build()

			.name("DSM_listCountries_requests_latency_seconds")

			.help("Request latency in seconds for invocations of the method DatasourcesApiController.listCountries()")

			.register();

	@Around("execution(* eu.dnetlib.openaire.exporter.datasource.DatasourcesApiController.listCountries(..))")

	public Object logTimelistCountries(final ProceedingJoinPoint joinPoint) throws Throwable {

		return _measure(joinPoint, dsCountries.startTimer());

	}

	private static final Gauge dsSearch = Gauge.build()

			.name("DSM_search_requests_latency_seconds")

			.help("Request latency in seconds for invocations of the method DatasourcesApiController.search()")

			.register();

	@Around("execution(* eu.dnetlib.openaire.exporter.datasource.DatasourcesApiController.search(..))")

	public Object logTimeDsSearch(final ProceedingJoinPoint joinPoint) throws Throwable {

		return _measure(joinPoint, dsSearch.startTimer());

	}

	private static final Gauge dsSearchBaseUrls = Gauge.build()

			.name("DSM_searchBaseUrls_requests_latency_seconds")

			.help("Request latency in seconds for invocations of the method DatasourcesApiController.searchBaseUrls()")

			.register();

	@Around("execution(* eu.dnetlib.openaire.exporter.datasource.DatasourcesApiController.searchBaseUrls(..))")

	public Object logTimeDsSearchBaseUrl(final ProceedingJoinPoint joinPoint) throws Throwable {

		return _measure(joinPoint, dsSearchBaseUrls.startTimer());

	}

	private static final Gauge apiGetById = Gauge.build()

			.name("DSM_getApi_requests_latency_seconds")

			.help("Request latency in seconds for invocations of the method DatasourcesApiController.getApis()")

			.register();

	@Around("execution(* eu.dnetlib.openaire.exporter.datasource.DatasourcesApiController.getApi(..))")

	public Object logTimeApiGetById(final ProceedingJoinPoint joinPoint) throws Throwable {

		return _measure(joinPoint, apiGetById.startTimer());

	}

}