@Test public void testElasticSearchDetector() { Assertions.assertThat(detector.detect()) .contains(Dependency.on(Component.of("mycluster", ComponentType.ELASTIC_SEARCH))); }
@Override public Set<Relationship> detect() { return clients.stream() .map(c -> Dependency.on(Component.of(c.settings().get("cluster.name"), ComponentType.ELASTIC_SEARCH))) .collect(Collectors.toSet()); }
ElasticSearchRelationshipDetector implements RelationshipDetector { @Override public Set<Relationship> detect() { return clients.stream() .map(c -> Dependency.on(Component.of(c.settings().get("cluster.name"), ComponentType.ELASTIC_SEARCH))) .collect(Collectors.toSet()); } }
ElasticSearchRelationshipDetector implements RelationshipDetector { @Override public Set<Relationship> detect() { return clients.stream() .map(c -> Dependency.on(Component.of(c.settings().get("cluster.name"), ComponentType.ELASTIC_SEARCH))) .collect(Collectors.toSet()); } ElasticSearchRelationshipDetector(Collection<Client> esClients); }
ElasticSearchRelationshipDetector implements RelationshipDetector { @Override public Set<Relationship> detect() { return clients.stream() .map(c -> Dependency.on(Component.of(c.settings().get("cluster.name"), ComponentType.ELASTIC_SEARCH))) .collect(Collectors.toSet()); } ElasticSearchRelationshipDetector(Collection<Client> esClients); @Override Set<Relationship> detect(); }
ElasticSearchRelationshipDetector implements RelationshipDetector { @Override public Set<Relationship> detect() { return clients.stream() .map(c -> Dependency.on(Component.of(c.settings().get("cluster.name"), ComponentType.ELASTIC_SEARCH))) .collect(Collectors.toSet()); } ElasticSearchRelationshipDetector(Collection<Client> esClients); @Override Set<Relationship> detect();  }