com.lucidworks.apollo.pipeline.query

Class QueryRequestAndResponse

java.lang.Object

com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse

All Implemented Interfaces:

Aggregatable, Copyable<QueryRequestAndResponse>

public class QueryRequestAndResponse
extends Object
implements Aggregatable, Copyable<QueryRequestAndResponse>

Field Summary

Fields

Modifier and Type	Field and Description
Request	request
static String	REQUEST_HEADERS
static String	REQUEST_HTTP_METHOD
static String	REQUEST_PARAMS
static String	REQUEST_PREFIX
Optional<Response>	response
static String	RESPONSE_ENTITY
static String	RESPONSE_HEADERS
static String	RESPONSE_PREFIX
static String	TOTAL_TIME

Method Summary

Modifier and Type	Method and Description
Aggregatable	addField(String field, Object value)
Aggregatable	addFields(String field, Collection<?> values)
Aggregatable	clear()
QueryRequestAndResponse	copyOf()
static QueryRequestAndResponse	create(Request req, Response resp, long totalTime)
DslRequest	getDslRequest()
DslResponseWrapper	getDslResponse()
Set<String>	getFieldNames()
List<Object>	getFieldValues(String field)
Object	getFirstFieldValue(String field)
long	getStartTime()
long	getTotalTime()
static QueryRequestAndResponse	newRequest(DslRequest dslRequest)
static QueryRequestAndResponse	newRequest(DslRequest dslRequest, MultivaluedMap<String,String> headers) Create from a DslRequest and the set of provided headers Currently headers are accessible from Response.getHeaders() only, regardless of the type of request provided to the pipeline.
static QueryRequestAndResponse	newRequest(MultivaluedMap<String,String> queryParams, MultivaluedMap<String,String> headers, String httpMethod)
static QueryRequestAndResponse	newRequest(MultivaluedMap<String,String> queryParams, MultivaluedMap<String,String> headers, String httpMethod, byte[] entityBytes, MediaType entityMediaType)
Aggregatable	removeFields(String field)
void	setDslRequest(DslRequest dslRequest)
void	setDslResponse(DslResponseWrapper dslResponse)
Aggregatable	setField(String field, Object value)
Aggregatable	setFields(String field, Collection<?> values)
void	setStartTime(long startTime)
void	setTotalTime(long totalTime)
QueryRequestAndResponse	withResponse(MultivaluedMap<String,String> headers, AbstractResponse response, long totalTime)

Methods inherited from class java.lang.Object

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

Field Detail

request

public final Request request

response

public final Optional<Response> response

REQUEST_PREFIX

public static final String REQUEST_PREFIX

See Also:

Constant Field Values

REQUEST_PARAMS

public static final String REQUEST_PARAMS

See Also:

Constant Field Values

REQUEST_HEADERS

public static final String REQUEST_HEADERS

See Also:

Constant Field Values

REQUEST_HTTP_METHOD

public static final String REQUEST_HTTP_METHOD

See Also:

Constant Field Values

RESPONSE_PREFIX

public static final String RESPONSE_PREFIX

See Also:

Constant Field Values

RESPONSE_HEADERS

public static final String RESPONSE_HEADERS

See Also:

Constant Field Values

RESPONSE_ENTITY

public static final String RESPONSE_ENTITY

See Also:

Constant Field Values

TOTAL_TIME

public static final String TOTAL_TIME

See Also:

Constant Field Values

Method Detail

withResponse

public QueryRequestAndResponse withResponse(MultivaluedMap<String,String> headers,
                                            AbstractResponse response,
                                            long totalTime)

newRequest

public static QueryRequestAndResponse newRequest(MultivaluedMap<String,String> queryParams,
                                                 MultivaluedMap<String,String> headers,
                                                 String httpMethod)

newRequest

public static QueryRequestAndResponse newRequest(MultivaluedMap<String,String> queryParams,
                                                 MultivaluedMap<String,String> headers,
                                                 String httpMethod,
                                                 byte[] entityBytes,
                                                 MediaType entityMediaType)

newRequest

public static QueryRequestAndResponse newRequest(DslRequest dslRequest)

newRequest

public static QueryRequestAndResponse newRequest(DslRequest dslRequest,
                                                 MultivaluedMap<String,String> headers)

Create from a DslRequest and the set of provided headers Currently headers are accessible from Response.getHeaders() only, regardless of the type of request provided to the pipeline. See APOLLO-27272

create

public static QueryRequestAndResponse create(Request req,
                                             Response resp,
                                             long totalTime)

copyOf

public QueryRequestAndResponse copyOf()

Specified by:

copyOf in interface Copyable<QueryRequestAndResponse>

getFieldValues

public List<Object> getFieldValues(String field)

Specified by:

getFieldValues in interface Aggregatable

getFirstFieldValue

public Object getFirstFieldValue(String field)

Specified by:

getFirstFieldValue in interface Aggregatable

removeFields

public Aggregatable removeFields(String field)

Specified by:

removeFields in interface Aggregatable

setField

public Aggregatable setField(String field,
                             Object value)

Specified by:

setField in interface Aggregatable

setFields

public Aggregatable setFields(String field,
                              Collection<?> values)

Specified by:

setFields in interface Aggregatable

addField

public Aggregatable addField(String field,
                             Object value)

Specified by:

addField in interface Aggregatable

addFields

public Aggregatable addFields(String field,
                              Collection<?> values)

Specified by:

addFields in interface Aggregatable

clear

public Aggregatable clear()

Specified by:

clear in interface Aggregatable

getFieldNames

public Set<String> getFieldNames()

Specified by:

getFieldNames in interface Aggregatable

getTotalTime

public long getTotalTime()

setTotalTime

public void setTotalTime(long totalTime)

getStartTime

public long getStartTime()

setStartTime

public void setStartTime(long startTime)

getDslRequest

public DslRequest getDslRequest()

setDslRequest

public void setDslRequest(DslRequest dslRequest)

getDslResponse

public DslResponseWrapper getDslResponse()

setDslResponse

public void setDslResponse(DslResponseWrapper dslResponse)