@Test public void testWrongMemberIsRejected() throws IOException { setupServerAndResolver(member -> ClusterMemberVerifierResult.invalid("wrong member")); await().until(() -> resolver.getRejectedMemberError().equals("wrong member")); }
@VisibleForTesting String getRejectedMemberError() { return rejectedMemberError; }
SingleClusterMemberResolver implements DirectClusterMemberResolver { @VisibleForTesting String getRejectedMemberError() { return rejectedMemberError; } }
SingleClusterMemberResolver implements DirectClusterMemberResolver { @VisibleForTesting String getRejectedMemberError() { return rejectedMemberError; } SingleClusterMemberResolver(ClusterMembershipResolverConfiguration configuration,
                                       Function<ClusterMemberAddress, ManagedChannel> channelProvider,
                                       ClusterMemberAddress address,
                                       ClusterMemberVerifier clusterMemberVerifier,
                                       Scheduler scheduler,
                                       TitusRuntime titusRuntime); }
SingleClusterMemberResolver implements DirectClusterMemberResolver { @VisibleForTesting String getRejectedMemberError() { return rejectedMemberError; } SingleClusterMemberResolver(ClusterMembershipResolverConfiguration configuration,
                                       Function<ClusterMemberAddress, ManagedChannel> channelProvider,
                                       ClusterMemberAddress address,
                                       ClusterMemberVerifier clusterMemberVerifier,
                                       Scheduler scheduler,
                                       TitusRuntime titusRuntime); @Override void shutdown(); @Override ClusterMemberAddress getAddress(); @Override String getPrintableName(); @Override boolean isHealthy(); @Override ClusterMembershipSnapshot getSnapshot(); @Override Flux<ClusterMembershipSnapshot> resolve(); }
SingleClusterMemberResolver implements DirectClusterMemberResolver { @VisibleForTesting String getRejectedMemberError() { return rejectedMemberError; } SingleClusterMemberResolver(ClusterMembershipResolverConfiguration configuration,
                                       Function<ClusterMemberAddress, ManagedChannel> channelProvider,
                                       ClusterMemberAddress address,
                                       ClusterMemberVerifier clusterMemberVerifier,
                                       Scheduler scheduler,
                                       TitusRuntime titusRuntime); @Override void shutdown(); @Override ClusterMemberAddress getAddress(); @Override String getPrintableName(); @Override boolean isHealthy(); @Override ClusterMembershipSnapshot getSnapshot(); @Override Flux<ClusterMembershipSnapshot> resolve();  }