assertThat(stats.loadSuccessCount()).isEqualTo(2);
    assertThat(stats.loadExceptionCount()).isEqualTo(0);
    assertThat(stats.hitCount()).isEqualTo(0);

    key = new Object();
    cache.refresh(key);
    checkNothingLogged();
    stats = cache.stats();
    assertThat(stats.missCount()).isEqualTo(2);
    assertThat(stats.loadSuccessCount()).isEqualTo(3);
    assertThat(stats.loadExceptionCount()).isEqualTo(0);

    assertThat(stats.loadSuccessCount()).isEqualTo(2);
    assertThat(stats.loadExceptionCount()).isEqualTo(0);
    assertThat(stats.hitCount()).isEqualTo(0);

    key = new Object();
    cache.refresh(key);
    checkNothingLogged();
    stats = cache.stats();
    assertThat(stats.missCount()).isEqualTo(2);
    assertThat(stats.loadSuccessCount()).isEqualTo(3);
    assertThat(stats.loadExceptionCount()).isEqualTo(0);

     */
    public void setCacheScope(DirectoryCacheScope cacheScope) {
        this.cacheScope = cacheScope;
    }

    /**
     * Gets the maximum age for cached directory data before requiring refresh
     * @return the maximum cache age in milliseconds
     */
    public long getMaxCacheAge() {
        return maxCacheAge;
    }

    /**
     * Sets the maximum age for cached directory data

                or in a cookie).
                """
            ),
        ] = True,
        refreshUrl: Annotated[
            str | None,
            Doc(
                """
                The URL to refresh the token and obtain a new one.
                """
            ),
        ] = None,
    ):
        if not scopes:
            scopes = {}
        flows = OAuthFlowsModel(
            password=cast(

)

type arnTarget struct {
	Client      *TargetClient
	lastRefresh time.Time
}

// arnErrs represents number of errors seen for a ARN and if update is in progress
// to refresh remote targets from bucket metadata.
type arnErrs struct {
	count            int64
	updateInProgress bool
	bucket           string
}

// BucketTargetSys represents bucket targets subsystem

            assertTrue(true);
        } catch (Exception e) {
            assertTrue(true);
        }
    }

    @Test
    public void test_refresh() {
        try {
            suggestHelper.refresh();
            assertTrue(true);
        } catch (Exception e) {
            assertTrue(true);
        }
    }

    // Mock classes
    private static class MockFessConfig extends FessConfig.SimpleImpl {

          "legendFormat": "{{endpoint}}",
          "refId": "A"
        }
      ],
      "title": "Replication Link Offline Duration (sec)",
      "type": "timeseries"
    }
  ],
  "refresh": "",
  "schemaVersion": 39,
  "tags": [
    "minio"
  ],
  "templating": {
    "list": [
      {
        "current": {
          "selected": false,
          "text": "All",

  /**
   * Computes or retrieves a replacement value corresponding to an already-cached {@code key}. This
   * method is called when an existing cache entry is refreshed by {@link
   * CacheBuilder#refreshAfterWrite}, or through a call to {@link LoadingCache#refresh}.
   *
   * <p>This implementation synchronously delegates to {@link #load}. It is recommended that it be
   * overridden with an asynchronous implementation when using {@link

            }
            final String refresh = StringUtil.isNotBlank(fessConfig.getIndexReindexRefresh()) ? fessConfig.getIndexReindexRefresh() : null;
            try (CurlResponse response = ComponentUtil.getCurlHelper()
                    .post("/" + index + "/_update_by_query")
                    .param("refresh", refresh)
                    .param("max_docs", "1")
                    .body(source)

   *
   * <ul>
   *   <li>consolidation of the loader logic to {@linkplain CacheBuilder#build(CacheLoader) a single
   *       authoritative location}
   *   <li>{@linkplain LoadingCache#refresh refreshing of entries}, including {@linkplain
   *       CacheBuilder#refreshAfterWrite automated refreshing}
   *   <li>{@linkplain LoadingCache#getAll bulk loading requests}, including {@linkplain