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

Class ControllerServiceReferenceEndpointMerger

java.lang.Object

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

All Implemented Interfaces:

EndpointResponseMerger

public class ControllerServiceReferenceEndpointMerger
extends java.lang.Object
implements EndpointResponseMerger

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
ControllerServiceReferenceEndpointMerger()

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
NodeResponse	merge(java.net.URI uri, java.lang.String method, java.util.Set<NodeResponse> successfulResponses, java.util.Set<NodeResponse> problematicResponses, NodeResponse clientResponse) Maps the given Node Responses to a single NodeResponse that is appropriate to return to the client/user

Methods inherited from class java.lang.Object

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

Field Detail

CONTROLLER_SERVICE_REFERENCES_URI_PATTERN

public static final java.util.regex.Pattern CONTROLLER_SERVICE_REFERENCES_URI_PATTERN

Constructor Detail

ControllerServiceReferenceEndpointMerger

public ControllerServiceReferenceEndpointMerger()

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

merge

public NodeResponse merge(java.net.URI uri,
                          java.lang.String method,
                          java.util.Set<NodeResponse> successfulResponses,
                          java.util.Set<NodeResponse> problematicResponses,
                          NodeResponse clientResponse)

Description copied from interface: EndpointResponseMerger

Maps the given Node Responses to a single NodeResponse that is appropriate to return to the client/user

Specified by:

merge in interface EndpointResponseMerger

Parameters:

uri - the URI of the REST Endpoint

method - the HTTP Method used to interact with the REST Endpoint

successfulResponses - the responses from nodes that were successful in handling the request

problematicResponses - the responses from nodes that were not successful in handling the request

clientResponse - the response that was chosen to be returned to the client

Returns:

a NodeResponse that is appropriate to return to the client/user