feat: slowIo support

Author: Angular2Guy

backend/src/main/java/ch/xxx/trader/usecase/services/CoinbaseService.java

@@ -86,6 +86,8 @@ private record GetSetMethodFunctions(Function<QuoteCb, BigDecimal> getter, BiCon
 	private final Scheduler mongoScheduler = Schedulers.newBoundedElastic(6, 10, "mongoImport", 10);
 	@Value("${single.instance.deployment:false}")
 	private boolean singleInstanceDeployment;
+	@Value("${single.instance.slow-io:false}")
+	private boolean slowIo;
 
 	public CoinbaseService(MyMongoRepository myMongoRepository, ServiceUtils serviceUtils) {
 		this.myMongoRepository = myMongoRepository;
@@ -204,13 +206,13 @@ private void processTimeFrame(MyTimeFrame timeFrame1, boolean isDay) {
 		// Coinbase
 		final var logFailed = String.format("Coinbase prepare %s data failed", isDay ? "day" : "hour");
 		Mono<Collection<QuoteCb>> collectCb = this.myMongoRepository.find(query, QuoteCb.class)
-				.timeout(Duration.ofSeconds(30L)).doOnError(ex -> LOG.warn(logFailed, ex))
+				.timeout(this.slowIo ? Duration.ofSeconds(30L) : Duration.ofSeconds(10L)).doOnError(ex -> LOG.warn(logFailed, ex))
 				.onErrorResume(ex -> Mono.empty()).subscribeOn(this.mongoScheduler).collectList()
 				.map(quotes -> this.createCbQuoteTimeFrame(timeFrame1, isDay, quotes));
 		collectCb.filter(Predicate.not(Collection::isEmpty))
 				.map(myColl -> this.countRelevantProperties(nonZeroProperties, myColl))
 				.flatMap(myColl -> this.myMongoRepository.insertAll(Mono.just(myColl), isDay ? CB_DAY_COL : CB_HOUR_COL)
-						.timeout(Duration.ofSeconds(30L)).doOnError(ex -> LOG.warn(logFailed, ex))
+						.timeout(this.slowIo ? Duration.ofSeconds(30L) : Duration.ofSeconds(10L)).doOnError(ex -> LOG.warn(logFailed, ex))
 						.onErrorResume(ex -> Mono.empty()).subscribeOn(this.mongoScheduler).collectList())
 				.subscribeOn(this.mongoScheduler).block();
 		LOG.info(String.format("Prepared Coinbase %s Data for: ", isDay ? "Day" : "Hour")

backend/src/main/resources/application.properties

@@ -16,6 +16,7 @@ server.compression.min-response-size=2KB
 spring.codec.max-in-memory-size=2MB
 server.servlet.session.timeout=10s
 kubernetes.pod.cpu.constraint=${CPU_CONSTRAINT:false}
+single.instance.slow-io=false
 single.instance.deployment=false
 management.health.livenessstate.enabled=true
 management.health.readinessstate.enabled=true