co.cask.coopr.scheduler.callback

Class HttpPostClusterCallback

java.lang.Object

co.cask.coopr.scheduler.callback.HttpPostClusterCallback

All Implemented Interfaces:

ClusterCallback

public class HttpPostClusterCallback
extends Object
implements ClusterCallback

Executes before and after hooks by sending an HTTP POST request to some configurable endpoints, with the post body containing the cluster and job objects, assuming there is a valid url assigned to the start, success, and/or failure urls. If no url is specified, no request will be sent. Additionally, trigger actions can be configured so that the HTTP POST request is sent only for specific cluster actions. This is done by specifying a comma separated list of ClusterActions in the configuration for start, success, and/or triggers.

Constructor Summary

Constructors

Constructor and Description
HttpPostClusterCallback()

Method Summary

Methods

Modifier and Type	Method and Description
void	initialize(Configuration conf) Initialize the cluster callback.
void	onFailure(CallbackData data, CallbackContext context) Execute some method after a cluster job fails.
boolean	onStart(CallbackData data, CallbackContext context) Execute some method before a cluster job starts, returning whether or not the job can proceed or whether it should be failed.
void	onSuccess(CallbackData data, CallbackContext context) Execute some method after a cluster completes successfully.

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpPostClusterCallback

public HttpPostClusterCallback()

Method Detail

initialize

public void initialize(Configuration conf)

Description copied from interface: ClusterCallback

Initialize the cluster callback. Guaranteed to be called exactly once before any other methods are called.

Specified by:

initialize in interface ClusterCallback

Parameters:

conf - Server configuration.

onStart

public boolean onStart(CallbackData data,
              CallbackContext context)

Description copied from interface: ClusterCallback

Execute some method before a cluster job starts, returning whether or not the job can proceed or whether it should be failed. Is guaranteed to be called and executed before the cluster operation begins.

Specified by:

onStart in interface ClusterCallback

Parameters:

data - Data available to use while executing callback.

Returns:

True if it is ok to proceed with the operation, false if not.

onSuccess

public void onSuccess(CallbackData data,
             CallbackContext context)

Description copied from interface: ClusterCallback

Execute some method after a cluster completes successfully.

Specified by:

onSuccess in interface ClusterCallback

Parameters:

data - Data available to use while executing callback.

onFailure

public void onFailure(CallbackData data,
             CallbackContext context)

Description copied from interface: ClusterCallback

Execute some method after a cluster job fails.

Specified by:

onFailure in interface ClusterCallback

Parameters:

data - Data available to use while executing callback.