@Test public void testElectedLeaderSetInSnapshot() { Iterator<ClusterMembershipSnapshot> eventIt = resolver.resolve().toIterable().iterator(); ClusterMembershipSnapshot leadElectedEvent = eventIt.next(); assertThat(leadElectedEvent.getLeaderRevision()).isNotEmpty(); }
@Override public Flux<ClusterMembershipSnapshot> resolve() { return eventProcessor; }
SingleClusterMemberResolver implements DirectClusterMemberResolver { @Override public Flux<ClusterMembershipSnapshot> resolve() { return eventProcessor; } }
SingleClusterMemberResolver implements DirectClusterMemberResolver { @Override public Flux<ClusterMembershipSnapshot> resolve() { return eventProcessor; } SingleClusterMemberResolver(ClusterMembershipResolverConfiguration configuration,
                                       Function<ClusterMemberAddress, ManagedChannel> channelProvider,
                                       ClusterMemberAddress address,
                                       ClusterMemberVerifier clusterMemberVerifier,
                                       Scheduler scheduler,
                                       TitusRuntime titusRuntime); }
SingleClusterMemberResolver implements DirectClusterMemberResolver { @Override public Flux<ClusterMembershipSnapshot> resolve() { return eventProcessor; } 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 { @Override public Flux<ClusterMembershipSnapshot> resolve() { return eventProcessor; } 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();  }