org.apache.nifi.cluster.coordination.http.endpoints

Class ControllerConfigurationEndpointMerger

java.lang.Object

org.apache.nifi.cluster.coordination.http.endpoints.AbstractSingleEntityEndpoint<ControllerConfigurationEntity>

org.apache.nifi.cluster.coordination.http.endpoints.ControllerConfigurationEndpointMerger

All Implemented Interfaces:

EndpointResponseMerger

public class ControllerConfigurationEndpointMerger
extends AbstractSingleEntityEndpoint<ControllerConfigurationEntity>

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.regex.Pattern	CONTROLLER_CONFIGURATION_URI_PATTERN

Constructor Summary

Constructors

Constructor and Description
ControllerConfigurationEndpointMerger()

Method Summary

Modifier and Type	Method and Description
boolean	canHandle(java.net.URI uri, java.lang.String method) Indicates whether or not this EndpointResponseMapper can handle mapping responses for the given URI and HTTP Method
protected java.lang.Class<ControllerConfigurationEntity>	getEntityClass()
protected void	mergeResponses(ControllerConfigurationEntity clientEntity, java.util.Map<NodeIdentifier,ControllerConfigurationEntity> entityMap, java.util.Set<NodeResponse> successfulResponses, java.util.Set<NodeResponse> problematicResponses) Merges the responses from all nodes in the given map into the single given entity

Methods inherited from class org.apache.nifi.cluster.coordination.http.endpoints.AbstractSingleEntityEndpoint

merge

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CONTROLLER_CONFIGURATION_URI_PATTERN

public static final java.util.regex.Pattern CONTROLLER_CONFIGURATION_URI_PATTERN

Constructor Detail

ControllerConfigurationEndpointMerger

public ControllerConfigurationEndpointMerger()

Method Detail

getEntityClass

protected java.lang.Class<ControllerConfigurationEntity> getEntityClass()

Specified by:

getEntityClass in class AbstractSingleEntityEndpoint<ControllerConfigurationEntity>

Returns:

the class that represents the type of Entity that is expected by this response mapper

mergeResponses

protected void mergeResponses(ControllerConfigurationEntity clientEntity,
                              java.util.Map<NodeIdentifier,ControllerConfigurationEntity> entityMap,
                              java.util.Set<NodeResponse> successfulResponses,
                              java.util.Set<NodeResponse> problematicResponses)

Description copied from class: AbstractSingleEntityEndpoint

Merges the responses from all nodes in the given map into the single given entity

Specified by:

mergeResponses in class AbstractSingleEntityEndpoint<ControllerConfigurationEntity>

Parameters:

clientEntity - the Entity to merge responses into

entityMap - the responses from all nodes

successfulResponses - the responses from nodes that completed the request successfully

problematicResponses - the responses from nodes that did not complete the request successfully

canHandle

public boolean canHandle(java.net.URI uri,
                         java.lang.String method)

Description copied from interface: EndpointResponseMerger

Indicates whether or not this EndpointResponseMapper can handle mapping responses for the given URI and HTTP Method

Parameters:

uri - the URI of the endpoint

method - the HTTP Method used to interact with the endpoint

Returns:

true if the EndpointResponseMapper can handle mapping responses for the endpoint described by the given URI and HTTP Method