// helper
  private static void doParallelCacheOp(int count, IntConsumer consumer) {
    IntStream.range(0, count).parallel().forEach(consumer);
  }

  @Override
  public void setUp() throws Exception {
    super.setUp();
    this.cache =
        CacheBuilder.newBuilder()
            .expireAfterAccess(500000, MILLISECONDS)
            .maximumSize(count)
            .build();
  }

import org.codelibs.fess.unit.UnitFessTestCase;

public class AbstractConfigHelperTest extends UnitFessTestCase {

    private TestConfigHelper configHelper;

    @Override
    public void setUp() throws Exception {
        super.setUp();
        configHelper = new TestConfigHelper();
    }

    public void test_setReloadInterval() {
        assertEquals(1000L, configHelper.reloadInterval);

  --initial-cluster s1=http://0.0.0.0:2380 \
  --initial-cluster-token tkn \
  --initial-cluster-state new
```

You may also setup etcd with TLS following this documentation [here](https://coreos.com/etcd/docs/latest/op-guide/security.html)

### 3. Setup MinIO with etcd

MinIO server expects environment variable for etcd as `MINIO_ETCD_ENDPOINTS`, this environment variable takes many comma separated entries.

```

    private static final Logger logger = LogManager.getLogger(HtmlXpathExtractorTest.class);

    public HtmlXpathExtractor htmlXpathExtractor;

    @Override
    protected void setUp() throws Exception {
        super.setUp();
        StandardCrawlerContainer container = new StandardCrawlerContainer().singleton("htmlXpathExtractor", HtmlXpathExtractor.class);
        htmlXpathExtractor = container.getComponent("htmlXpathExtractor");

  pull_request:
    branches:
    - master
    - "*.x"

jobs:
  build:

    runs-on: ubuntu-latest

    steps:
    - uses: actions/checkout@v2
    - name: Set up JDK 21
      uses: actions/setup-java@v2
      with:
        java-version: '21'
        distribution: 'temurin'
    - name: Build with Maven

/**
 * Test class for Config utility functionality
 */
@DisplayName("Config Utility Tests")
class ConfigTest extends BaseTest {

    private Properties testProperties;

    @BeforeEach
    void setUp() {
        testProperties = new Properties();
        testProperties.setProperty("test.int", "123");
        testProperties.setProperty("test.long", "1234567890123");
        testProperties.setProperty("test.bool.true", "true");

		mkdir -p ${WORK_DIR}/mnt/disk${i}/
		sudo mount ${device} ${WORK_DIR}/mnt/disk${i}/
		sudo chown "$(id -u):$(id -g)" ${device} ${WORK_DIR}/mnt/disk${i}/
	done
	set +e
}

# Start a distributed MinIO setup, unmount one disk and check if it is formatted
function main() {
	start_port=$(shuf -i 10000-65000 -n 1)
	start_minio ${start_port}

	# Unmount the disk, after the unmount the device id

# See the License for the specific language governing permissions and
# limitations under the License.
# ==============================================================================
source "${BASH_SOURCE%/*}/utilities/setup.sh"

    runs-on: ${{ matrix.os }}
    strategy:
      matrix:
        go-version: [1.24.x]
        os: [ubuntu-latest]

    steps:
      - uses: actions/checkout@v4
      - uses: actions/setup-go@v5
        with:
          go-version: ${{ matrix.go-version }}
          check-latest: true
      - name: Start upgrade tests
        run: |

    private FessCookieResourceProvider cookieResourceProvider;
    private FessConfig originalFessConfig;

    @Override
    public void setUp() throws Exception {
        super.setUp();

        originalFessConfig = ComponentUtil.getFessConfig();

        // Set up test FessConfig
        ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() {