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

Class PortStatusEndpointMerger

java.lang.Object

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

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

All Implemented Interfaces:

EndpointResponseMerger, ComponentEntityStatusMerger<PortStatusDTO>

public class PortStatusEndpointMerger
extends AbstractSingleEntityEndpoint<PortStatusEntity>
implements ComponentEntityStatusMerger<PortStatusDTO>

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.regex.Pattern	INPUT_PORT_STATUS_URI_PATTERN
static java.util.regex.Pattern	OUTPUT_PORT_STATUS_URI_PATTERN

Constructor Summary

Constructors

Constructor and Description
PortStatusEndpointMerger()

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<PortStatusEntity>	getEntityClass()
protected void	mergeResponses(PortStatusEntity clientEntity, java.util.Map<NodeIdentifier,PortStatusEntity> 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
void	mergeStatus(PortStatusDTO clientStatus, boolean clientStatusReadablePermission, PortStatusDTO status, boolean statusReadablePermission, NodeIdentifier statusNodeIdentifier) Merges status into clientStatus based on the given permissions.

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

INPUT_PORT_STATUS_URI_PATTERN

public static final java.util.regex.Pattern INPUT_PORT_STATUS_URI_PATTERN

OUTPUT_PORT_STATUS_URI_PATTERN

public static final java.util.regex.Pattern OUTPUT_PORT_STATUS_URI_PATTERN

Constructor Detail

PortStatusEndpointMerger

public PortStatusEndpointMerger()

Method Detail

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

Specified by:

canHandle in interface EndpointResponseMerger

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

getEntityClass

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

Specified by:

getEntityClass in class AbstractSingleEntityEndpoint<PortStatusEntity>

Returns:

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

mergeResponses

protected void mergeResponses(PortStatusEntity clientEntity,
                              java.util.Map<NodeIdentifier,PortStatusEntity> 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<PortStatusEntity>

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

mergeStatus

public void mergeStatus(PortStatusDTO clientStatus,
                        boolean clientStatusReadablePermission,
                        PortStatusDTO status,
                        boolean statusReadablePermission,
                        NodeIdentifier statusNodeIdentifier)

Description copied from interface: ComponentEntityStatusMerger

Merges status into clientStatus based on the given permissions.

Specified by:

mergeStatus in interface ComponentEntityStatusMerger<PortStatusDTO>

Parameters:

clientStatus - The status that will be returned to the client after merging

clientStatusReadablePermission - The read permission of the status that will be returned to the client after merging

status - The status to be merged into the client status

statusReadablePermission - The read permission of the status to be merged into the client status

statusNodeIdentifier - The NodeIdentifier of the node from which status was received