@Test public void canGetLeaderTime() { assertThat(Futures.getUnchecked(resource.leaderTime(AUTH_HEADER, NAMESPACE))).isEqualTo(leaderTime); }
@Override public ListenableFuture<LeaderTime> leaderTime(AuthHeader authHeader, String namespace) { return handleExceptions(() -> forNamespace(namespace).leaderTime()); }
ConjureTimelockResource implements UndertowConjureTimelockService { @Override public ListenableFuture<LeaderTime> leaderTime(AuthHeader authHeader, String namespace) { return handleExceptions(() -> forNamespace(namespace).leaderTime()); } }
ConjureTimelockResource implements UndertowConjureTimelockService { @Override public ListenableFuture<LeaderTime> leaderTime(AuthHeader authHeader, String namespace) { return handleExceptions(() -> forNamespace(namespace).leaderTime()); } @VisibleForTesting  ConjureTimelockResource(
            RedirectRetryTargeter redirectRetryTargeter,
            Function<String, AsyncTimelockService> timelockServices); }
ConjureTimelockResource implements UndertowConjureTimelockService { @Override public ListenableFuture<LeaderTime> leaderTime(AuthHeader authHeader, String namespace) { return handleExceptions(() -> forNamespace(namespace).leaderTime()); } @VisibleForTesting  ConjureTimelockResource(
            RedirectRetryTargeter redirectRetryTargeter,
            Function<String, AsyncTimelockService> timelockServices); static UndertowService undertow(
            RedirectRetryTargeter redirectRetryTargeter,
            Function<String, AsyncTimelockService> timelockServices); static ConjureTimelockService jersey(
            RedirectRetryTargeter redirectRetryTargeter,
            Function<String, AsyncTimelockService> timelockServices); @Override ListenableFuture<ConjureStartTransactionsResponse> startTransactions(
            AuthHeader authHeader, String namespace, ConjureStartTransactionsRequest request); @Override ListenableFuture<ConjureGetFreshTimestampsResponse> getFreshTimestamps(
            AuthHeader authHeader, String namespace, ConjureGetFreshTimestampsRequest request); @Override ListenableFuture<LeaderTime> leaderTime(AuthHeader authHeader, String namespace); @Override ListenableFuture<ConjureLockResponse> lock(
            AuthHeader authHeader, String namespace, ConjureLockRequest request); @Override ListenableFuture<ConjureWaitForLocksResponse> waitForLocks(
            AuthHeader authHeader, String namespace, ConjureLockRequest request); @Override ListenableFuture<ConjureRefreshLocksResponse> refreshLocks(
            AuthHeader authHeader, String namespace, ConjureRefreshLocksRequest request); @Override ListenableFuture<ConjureUnlockResponse> unlock(
            AuthHeader authHeader, String namespace, ConjureUnlockRequest request); @Override ListenableFuture<GetCommitTimestampsResponse> getCommitTimestamps(
            AuthHeader authHeader, String namespace, GetCommitTimestampsRequest request); }
ConjureTimelockResource implements UndertowConjureTimelockService { @Override public ListenableFuture<LeaderTime> leaderTime(AuthHeader authHeader, String namespace) { return handleExceptions(() -> forNamespace(namespace).leaderTime()); } @VisibleForTesting  ConjureTimelockResource(
            RedirectRetryTargeter redirectRetryTargeter,
            Function<String, AsyncTimelockService> timelockServices); static UndertowService undertow(
            RedirectRetryTargeter redirectRetryTargeter,
            Function<String, AsyncTimelockService> timelockServices); static ConjureTimelockService jersey(
            RedirectRetryTargeter redirectRetryTargeter,
            Function<String, AsyncTimelockService> timelockServices); @Override ListenableFuture<ConjureStartTransactionsResponse> startTransactions(
            AuthHeader authHeader, String namespace, ConjureStartTransactionsRequest request); @Override ListenableFuture<ConjureGetFreshTimestampsResponse> getFreshTimestamps(
            AuthHeader authHeader, String namespace, ConjureGetFreshTimestampsRequest request); @Override ListenableFuture<LeaderTime> leaderTime(AuthHeader authHeader, String namespace); @Override ListenableFuture<ConjureLockResponse> lock(
            AuthHeader authHeader, String namespace, ConjureLockRequest request); @Override ListenableFuture<ConjureWaitForLocksResponse> waitForLocks(
            AuthHeader authHeader, String namespace, ConjureLockRequest request); @Override ListenableFuture<ConjureRefreshLocksResponse> refreshLocks(
            AuthHeader authHeader, String namespace, ConjureRefreshLocksRequest request); @Override ListenableFuture<ConjureUnlockResponse> unlock(
            AuthHeader authHeader, String namespace, ConjureUnlockRequest request); @Override ListenableFuture<GetCommitTimestampsResponse> getCommitTimestamps(
            AuthHeader authHeader, String namespace, GetCommitTimestampsRequest request);  }