io.parallec.core.actor.poll

Class HttpPollerProcessor

java.lang.Object

io.parallec.core.actor.poll.HttpPollerProcessor

public class HttpPollerProcessor
extends java.lang.Object

Define how to poll progress 1. how to get the job id from the 1st response. 2. what is the URL template to poll progress (assuming it is a HTTP GET) 3. the regex to get the progress num. Note that this progress regex is not used to check if the job is completed. just for record. 4. Poll API: assume the HTTP Method for poll: is GET / no body/ and with the same header as the 1st reqwuest

Author:

Yuanteng (Jeff) Pei

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.String	failureRegex The failure regex.
private java.lang.String	jobIdPlaceHolder The job id place holder.
private java.lang.String	jobIdRegex The job id regex.
private static org.slf4j.Logger	logger The logger.
private int	maxPollError The max poll error.
private java.lang.String	pollerRequestTemplate The poller request template.
private java.lang.String	pollerType The poller type.
private long	pollIntervalMillis The poll interval millis.
private java.lang.String	progressRegex The progress regex.
private int	progressStuckTimeoutSeconds The progress stuck timeout seconds.
private java.lang.String	successRegex The success regex.

Constructor Summary

Constructors

Constructor and Description
HttpPollerProcessor() default as the cronus agent poller Assuming the polling API is By HTTP GET; without any postbody (for GET, no post body for sure)
HttpPollerProcessor(java.lang.String pollerType, java.lang.String successRegex, java.lang.String failureRegex, java.lang.String uuidRegex, java.lang.String progressRegex, int progressStuckTimeoutSeconds, long pollIntervalMillis, java.lang.String pollerRequestTemplate, java.lang.String jobIdPlaceHolder, int maxPollError) Instantiates a new http poller processor.

Method Summary

Modifier and Type	Method and Description
java.lang.String	getFailureRegex() Gets the failure regex.
java.lang.String	getJobIdPlaceHolder() Gets the job id place holder.
java.lang.String	getJobIdRegex() Gets the job id regex.
int	getMaxPollError() Gets the max poll error.
java.lang.String	getPollerRequestTemplate() Gets the poller request template.
java.lang.String	getPollerRequestUrl(java.lang.String uuid) Important.
java.lang.String	getPollerType() Gets the poller type.
long	getPollIntervalMillis() Gets the poll interval millis.
double	getProgressFromResponse(ResponseOnSingeRequest myResponse) Gets the progress from response.
java.lang.String	getProgressRegex() Gets the progress regex.
int	getProgressStuckTimeoutSeconds() Gets the progress stuck timeout seconds.
java.lang.String	getUuidFromResponse(ResponseOnSingeRequest myResponse) Gets the uuid from response.
boolean	ifTaskCompletedSuccessOrFailureFromResponse(ResponseOnSingeRequest myResponse) If task completed success or failure from response.
boolean	ifThereIsErrorInResponse(ResponseOnSingeRequest myResponse) If there is error in response.
void	setFailureRegex(java.lang.String failureRegex) Sets the failure regex.
void	setJobIdPlaceHolder(java.lang.String jobIdPlaceHolder) Sets the job id place holder.
void	setJobIdRegex(java.lang.String jobIdRegex) Sets the job id regex.
void	setMaxPollError(int maxPollError) Sets the max poll error.
void	setPollerRequestTemplate(java.lang.String pollerRequestTemplate) Sets the poller request template.
void	setPollerType(java.lang.String pollerType) Sets the poller type.
void	setPollIntervalMillis(long pollIntervalMillis) Sets the poll interval millis.
void	setProgressRegex(java.lang.String progressRegex) Sets the progress regex.
void	setProgressStuckTimeoutSeconds(int progressStuckTimeoutSeconds) Sets the progress stuck timeout seconds.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static org.slf4j.Logger logger

The logger.

pollerType

private java.lang.String pollerType

The poller type.

successRegex

private java.lang.String successRegex

The success regex.

failureRegex

private java.lang.String failureRegex

The failure regex.

jobIdRegex

private java.lang.String jobIdRegex

The job id regex.

progressRegex

private java.lang.String progressRegex

The progress regex.

progressStuckTimeoutSeconds

private int progressStuckTimeoutSeconds

The progress stuck timeout seconds.

maxPollError

private int maxPollError

The max poll error.

pollIntervalMillis

private long pollIntervalMillis

The poll interval millis.

pollerRequestTemplate

private java.lang.String pollerRequestTemplate

The poller request template.

jobIdPlaceHolder

private java.lang.String jobIdPlaceHolder

The job id place holder.

Constructor Detail

HttpPollerProcessor

public HttpPollerProcessor()

default as the cronus agent poller Assuming the polling API is By HTTP GET; without any postbody (for GET, no post body for sure)

HttpPollerProcessor

public HttpPollerProcessor(java.lang.String pollerType,
                           java.lang.String successRegex,
                           java.lang.String failureRegex,
                           java.lang.String uuidRegex,
                           java.lang.String progressRegex,
                           int progressStuckTimeoutSeconds,
                           long pollIntervalMillis,
                           java.lang.String pollerRequestTemplate,
                           java.lang.String jobIdPlaceHolder,
                           int maxPollError)

Instantiates a new http poller processor.

Parameters:

pollerType - the poller type

successRegex - the success regex

failureRegex - the failure regex

uuidRegex - the uuid regex

progressRegex - the progress regex

progressStuckTimeoutSeconds - the progress stuck timeout seconds

pollIntervalMillis - the poll interval millis

pollerRequestTemplate - the poller request template

jobIdPlaceHolder - the job id place holder

maxPollError - the max poll error

Method Detail

getPollerRequestUrl

public java.lang.String getPollerRequestUrl(java.lang.String uuid)

Important. get the poller URL

Parameters:

uuid - the uuid

Returns:

the poller request url

getPollIntervalMillis

public long getPollIntervalMillis()

Gets the poll interval millis.

Returns:

the poll interval millis

setPollIntervalMillis

public void setPollIntervalMillis(long pollIntervalMillis)

Sets the poll interval millis.

Parameters:

pollIntervalMillis - the new poll interval millis

getPollerRequestTemplate

public java.lang.String getPollerRequestTemplate()

Gets the poller request template.

Returns:

the poller request template

setPollerRequestTemplate

public void setPollerRequestTemplate(java.lang.String pollerRequestTemplate)

Sets the poller request template.

Parameters:

pollerRequestTemplate - the new poller request template

getUuidFromResponse

public java.lang.String getUuidFromResponse(ResponseOnSingeRequest myResponse)

Gets the uuid from response.

Parameters:

myResponse - the my response

Returns:

the uuid from response

getProgressFromResponse

public double getProgressFromResponse(ResponseOnSingeRequest myResponse)

Gets the progress from response.

Parameters:

myResponse - the my response

Returns:

the progress from response

ifThereIsErrorInResponse

public boolean ifThereIsErrorInResponse(ResponseOnSingeRequest myResponse)

If there is error in response.

Parameters:

myResponse - the my response

Returns:

true, if successful

ifTaskCompletedSuccessOrFailureFromResponse

public boolean ifTaskCompletedSuccessOrFailureFromResponse(ResponseOnSingeRequest myResponse)

If task completed success or failure from response.

Parameters:

myResponse - the my response

Returns:

true, if successful

getPollerType

public java.lang.String getPollerType()

Gets the poller type.

Returns:

the poller type

setPollerType

public void setPollerType(java.lang.String pollerType)

Sets the poller type.

Parameters:

pollerType - the new poller type

getFailureRegex

public java.lang.String getFailureRegex()

Gets the failure regex.

Returns:

the failure regex

setFailureRegex

public void setFailureRegex(java.lang.String failureRegex)

Sets the failure regex.

Parameters:

failureRegex - the new failure regex

getProgressRegex

public java.lang.String getProgressRegex()

Gets the progress regex.

Returns:

the progress regex

setProgressRegex

public void setProgressRegex(java.lang.String progressRegex)

Sets the progress regex.

Parameters:

progressRegex - the new progress regex

getProgressStuckTimeoutSeconds

public int getProgressStuckTimeoutSeconds()

Gets the progress stuck timeout seconds.

Returns:

the progress stuck timeout seconds

setProgressStuckTimeoutSeconds

public void setProgressStuckTimeoutSeconds(int progressStuckTimeoutSeconds)

Sets the progress stuck timeout seconds.

Parameters:

progressStuckTimeoutSeconds - the new progress stuck timeout seconds

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getJobIdPlaceHolder

public java.lang.String getJobIdPlaceHolder()

Gets the job id place holder.

Returns:

the job id place holder

setJobIdPlaceHolder

public void setJobIdPlaceHolder(java.lang.String jobIdPlaceHolder)

Sets the job id place holder.

Parameters:

jobIdPlaceHolder - the new job id place holder

getJobIdRegex

public java.lang.String getJobIdRegex()

Gets the job id regex.

Returns:

the job id regex

setJobIdRegex

public void setJobIdRegex(java.lang.String jobIdRegex)

Sets the job id regex.

Parameters:

jobIdRegex - the new job id regex

getMaxPollError

public int getMaxPollError()

Gets the max poll error.

Returns:

the max poll error

setMaxPollError

public void setMaxPollError(int maxPollError)

Sets the max poll error.

Parameters:

maxPollError - the new max poll error