nachogarrone

@Component
public class MyForkJoinPool {
    private static final Logger LOGGER = LoggerFactory.getLogger(MyForkJoinPool.class);

    private ForkJoinPool forkJoinPool;
    private ForkJoinPool hardForkJoinPool;

    @PostConstruct
    public void init() {
        this.forkJoinPool = new ForkJoinPool(2);

nachogarrone

public class ClustersHelper {

    private ObjectMapper mapper = new ObjectMapper();
    private List<String> neighbours;

    public List<String> getNeighbours() {
        if (CollectionUtils.isNotEmpty(this.neighbours)) {
            return this.neighbours;
        } else {
            this.neighbours = new ArrayList<>();

nachogarrone

#!/bin/bash

declare -a arr=("clt-guard-00" "clt-guard-01" "clt-guard-02" "clt-guard-08" "clt-guard-09" "clt-guard-10" "clt-guard-11" "clt-guard-12" "clt-guard-13")

for cluster in "${arr[@]}"
do
    echo "PUT http://${cluster}:9290/collect/payment-methods/cache/overlapped/reload"
    curl -X PUT \
      http://${cluster}:9290/collect/payment-methods/cache/overlapped/reload \
      -H 'Cache-Control: no-cache' \

nachogarrone

import base64
import json
import random
from datetime import date, timedelta

import requests
from locust import HttpLocust, TaskSet, task

events = []