D-Net

package eu.dnetlib.openaire.exporter.aop;

import io.prometheus.client.Gauge.Timer;

import org.aspectj.lang.ProceedingJoinPoint;

public abstract class AbstractApiProfiler {

	// HELPER

	protected Object _measure(final ProceedingJoinPoint joinPoint, final Timer requestTimer) throws Throwable {

		try {

			return joinPoint.proceed();

		} finally {

			requestTimer.setDuration();

		}

	}

}

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;

@Aspect

@Component

public class CommunityApiProfiler extends AbstractApiProfiler {

	private static final Gauge listCommunities = Gauge.build()

			.name("DSM_listCommunities_requests_latency_seconds")

			.help("Request latency in seconds for invocations of the method CommunityApiController.listCommunities()")

			.register();

	@Around("execution(* eu.dnetlib.openaire.exporter.community.CommunityApiController.listCommunities(..))")

	public Object logTimelistCommunities(final ProceedingJoinPoint joinPoint) throws Throwable {

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

	}

	private static final Gauge getCommunity = Gauge.build()

			.name("DSM_getCommunity_requests_latency_seconds")

			.help("Request latency in seconds for invocations of the method CommunityApiController.getCommunity()")

			.register();

	@Around("execution(* eu.dnetlib.openaire.exporter.community.CommunityApiController.getCommunity(..))")

	public Object logTimeGetCommunity(final ProceedingJoinPoint joinPoint) throws Throwable {

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

	}

	private static final Gauge getCommunityProjects = Gauge.build()

			.name("DSM_getCommunityProjects_requests_latency_seconds")

			.help("Request latency in seconds for invocations of the method CommunityApiController.getCommunityProjects()")

			.register();

	@Around("execution(* eu.dnetlib.openaire.exporter.community.CommunityApiController.getCommunityProjects(..))")

	public Object logTimeGetCommunityProjects(final ProceedingJoinPoint joinPoint) throws Throwable {

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

	}

	private static final Gauge getCommunityContentproviders = Gauge.build()

			.name("DSM_getCommunityContentproviders_requests_latency_seconds")

			.help("Request latency in seconds for invocations of the method CommunityApiController.getCommunityContentproviders()")

			.register();

	@Around("execution(* eu.dnetlib.openaire.exporter.community.CommunityApiController.getCommunityContentproviders(..))")

	public Object logTimeGetCommunityContentproviders(final ProceedingJoinPoint joinPoint) throws Throwable {

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

	}

}

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()")

	@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()")

	@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());

	}

			<version>${javamelody.version}</version>

		<prometheus.version>0.2.0</prometheus.version>

		<javamelody.version>1.71.0</javamelody.version>