Skip to content

Commit

Permalink
Document TestDiscoveryRequest and TestDiscoveryRequestBuilder (#234)
Browse files Browse the repository at this point in the history
  • Loading branch information
marcphilipp committed May 26, 2016
1 parent f2cf669 commit b80c19b
Show file tree
Hide file tree
Showing 2 changed files with 61 additions and 6 deletions.
Expand Up @@ -34,26 +34,59 @@
@API(Experimental) @API(Experimental)
public interface TestDiscoveryRequest extends EngineDiscoveryRequest { public interface TestDiscoveryRequest extends EngineDiscoveryRequest {


/**
* Adds the supplied {@code selector} to this request.
*/
void addSelector(DiscoverySelector selector); void addSelector(DiscoverySelector selector);


/**
* Adds all of the supplied {@code selectors} to this request.
*/
void addSelectors(Collection<DiscoverySelector> selectors); void addSelectors(Collection<DiscoverySelector> selectors);


/**
* Adds the supplied {@code engineIdFilter} to this request.
*/
void addEngineIdFilter(EngineIdFilter engineIdFilter); void addEngineIdFilter(EngineIdFilter engineIdFilter);


/**
* Adds all of the supplied {@code engineIdFilters} to this request.
*/
void addEngineIdFilters(Collection<EngineIdFilter> engineIdFilters); void addEngineIdFilters(Collection<EngineIdFilter> engineIdFilters);


/**
* Adds the supplied {@code discoveryFilter} to this request.
*/
void addFilter(DiscoveryFilter<?> discoveryFilter); void addFilter(DiscoveryFilter<?> discoveryFilter);


/**
* Adds all of the supplied {@code discoveryFilters} to this request.
*/
void addFilters(Collection<DiscoveryFilter<?>> discoveryFilters); void addFilters(Collection<DiscoveryFilter<?>> discoveryFilters);


/**
* Adds the supplied {@code postDiscoveryFilter} to this request.
*/
void addPostFilter(PostDiscoveryFilter postDiscoveryFilter); void addPostFilter(PostDiscoveryFilter postDiscoveryFilter);


/**
* Adds all of the supplied {@code postDiscoveryFilters} to this request.
*/
void addPostFilters(Collection<PostDiscoveryFilter> postDiscoveryFilters); void addPostFilters(Collection<PostDiscoveryFilter> postDiscoveryFilters);


/**
* Adds the supplied {@code configurationParameters} to this request.
*/
void addConfigurationParameters(Map<String, String> configurationParameters); void addConfigurationParameters(Map<String, String> configurationParameters);


/**
* Returns the {@code engineIdFilters} that have been added to this request.
*/
List<EngineIdFilter> getEngineIdFilters(); List<EngineIdFilter> getEngineIdFilters();


/**
* Returns the {@code postDiscoveryFilters} that have been added to this request.
*/
List<PostDiscoveryFilter> getPostDiscoveryFilters(); List<PostDiscoveryFilter> getPostDiscoveryFilters();


} }
Expand Up @@ -70,37 +70,55 @@ public final class TestDiscoveryRequestBuilder {
private List<PostDiscoveryFilter> postDiscoveryFilters = new LinkedList<>(); private List<PostDiscoveryFilter> postDiscoveryFilters = new LinkedList<>();
private Map<String, String> configurationParameters = new HashMap<>(); private Map<String, String> configurationParameters = new HashMap<>();


/**
* Returns a new {@link TestDiscoveryRequestBuilder}.
*/
public static TestDiscoveryRequestBuilder request() { public static TestDiscoveryRequestBuilder request() {
return new TestDiscoveryRequestBuilder(); return new TestDiscoveryRequestBuilder();
} }


public TestDiscoveryRequestBuilder select(DiscoverySelector... elements) { /**
if (elements != null) { * Adds all of the supplied {@code selectors} to the request.
select(Arrays.asList(elements)); */
public TestDiscoveryRequestBuilder select(DiscoverySelector... selectors) {
if (selectors != null) {
select(Arrays.asList(selectors));
} }
return this; return this;
} }


public TestDiscoveryRequestBuilder select(List<DiscoverySelector> elements) { /**
if (elements != null) { * Adds all of the supplied {@code selectors} to the request.
this.selectors.addAll(elements); */
public TestDiscoveryRequestBuilder select(List<DiscoverySelector> selectors) {
if (selectors != null) {
this.selectors.addAll(selectors);
} }
return this; return this;
} }


/**
* Adds all of the supplied {@code filters} to the request.
*/
public TestDiscoveryRequestBuilder filter(Filter<?>... filters) { public TestDiscoveryRequestBuilder filter(Filter<?>... filters) {
if (filters != null) { if (filters != null) {
Arrays.stream(filters).forEach(this::storeFilter); Arrays.stream(filters).forEach(this::storeFilter);
} }
return this; return this;
} }


/**
* Adds the supplied <em>configuration parameter</em> to the request.
*/
public TestDiscoveryRequestBuilder configurationParameter(String key, String value) { public TestDiscoveryRequestBuilder configurationParameter(String key, String value) {
Preconditions.notBlank(key, "configuration parameter key must not be null or empty"); Preconditions.notBlank(key, "configuration parameter key must not be null or empty");
this.configurationParameters.put(key, value); this.configurationParameters.put(key, value);
return this; return this;
} }


/**
* Adds all of the supplied {@code configurationParameters} to the request.
*/
public TestDiscoveryRequestBuilder configurationParameters(Map<String, String> configurationParameters) { public TestDiscoveryRequestBuilder configurationParameters(Map<String, String> configurationParameters) {
if (configurationParameters != null) { if (configurationParameters != null) {
configurationParameters.forEach(this::configurationParameter); configurationParameters.forEach(this::configurationParameter);
Expand All @@ -125,6 +143,10 @@ else if (filter instanceof DiscoveryFilter<?>) {
} }
} }


/**
* Builds and returns the {@link TestDiscoveryRequest} that has previously
* been setup by the methods of this builder.
*/
public TestDiscoveryRequest build() { public TestDiscoveryRequest build() {
DiscoveryRequest discoveryRequest = new DiscoveryRequest(); DiscoveryRequest discoveryRequest = new DiscoveryRequest();
discoveryRequest.addSelectors(this.selectors); discoveryRequest.addSelectors(this.selectors);
Expand Down

0 comments on commit b80c19b

Please sign in to comment.