com.ebay.lightning.core.services

Class TaskExecutionServiceImpl

java.lang.Object

com.ebay.lightning.core.services.TaskExecutionServiceImpl

All Implemented Interfaces:

TaskExecutionService

@Component
 @Scope(value="singleton")
public class TaskExecutionServiceImpl
extends java.lang.Object
implements TaskExecutionService

The TaskExecutionServiceImpl provides the implementation for TaskExecutionService that defines the operations for processing the request and getting the response. Most of the operation are delegated to TaskExecutionManager.

Author:

shashukla

See Also:

TaskExecutionServiceImpl, TaskExecutionManager

Constructor Summary

Constructors

Constructor and Description
TaskExecutionServiceImpl(TaskExecutionManager taskExecutionManager)

Method Summary

Modifier and Type	Method and Description
java.util.List<LightningRequestReport>	getAuditReports(java.lang.String sessionId) Get the detailed execution reports.
SystemStatus	getLightningStats() Get the system metrics including CPU, physical and JVM memory.
LightningRequestReport	getReport(java.lang.String sessionId) Get the detailed execution report for the request.
SystemConfig	getSystemConfig() Get the system configuration including capacity, retention policy etc
LightningResponse	pollResponse(java.lang.String sessionId, boolean pollDeltaOnly) Poll the current execution state for the request submitted by #TaskExecutionService.submit(LightningRequest) method.
ReservationReceipt	reserve(int load) Check for bandwidth to make reservation for the specified load.
void	submit(LightningRequest request) Submit a request to get executed asynchronously at high speed.
SystemConfig	updateSystemConfig(SystemConfig sysConfig) Update the system configuration including capacity, retention policy etc

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskExecutionServiceImpl

@Autowired
public TaskExecutionServiceImpl(TaskExecutionManager taskExecutionManager)

Method Detail

submit

public void submit(LightningRequest request)

Description copied from interface: TaskExecutionService

Submit a request to get executed asynchronously at high speed. The request should contain the ReservationReceipt returned by the TaskExecutionService.reserve(int) call.

Specified by:

submit in interface TaskExecutionService

Parameters:

request - contains the list of Task and configuration to execute

pollResponse

public LightningResponse pollResponse(java.lang.String sessionId,
                                      boolean pollDeltaOnly)

Description copied from interface: TaskExecutionService

Poll the current execution state for the request submitted by #TaskExecutionService.submit(LightningRequest) method. This method id helpful to check if the request has completed.

Specified by:

pollResponse in interface TaskExecutionService

Parameters:

sessionId - the session id of the LightningRequest

pollDeltaOnly - get full if true and delta response if false

Returns:

LightningResponse that has the current state of task execution

reserve

public ReservationReceipt reserve(int load)

Description copied from interface: TaskExecutionService

Check for bandwidth to make reservation for the specified load.

Specified by:

reserve in interface TaskExecutionService

Parameters:

load - the load to check for reservation

Returns:

the reservation receipt containing either of the state ACCEPTED, DENIED, BUSY

getReport

public LightningRequestReport getReport(java.lang.String sessionId)

Description copied from interface: TaskExecutionService

Get the detailed execution report for the request. This method is usually called after checking if the request is completed by calling TaskExecutionService.pollResponse(String, boolean)

Specified by:

getReport in interface TaskExecutionService

Parameters:

sessionId - the session id of the LightningRequest

Returns:

LightningRequestReport that has the detailed execution report of the request

getLightningStats

public SystemStatus getLightningStats()

Description copied from interface: TaskExecutionService

Get the system metrics including CPU, physical and JVM memory.

Specified by:

getLightningStats in interface TaskExecutionService

Returns:

the current system status

updateSystemConfig

public SystemConfig updateSystemConfig(SystemConfig sysConfig)
                                throws java.lang.Exception

Description copied from interface: TaskExecutionService

Update the system configuration including capacity, retention policy etc

Specified by:

updateSystemConfig in interface TaskExecutionService

Parameters:

sysConfig - the system configuration changes to make

Returns:

the system configuration after update

Throws:

java.lang.Exception - when the update fails

getSystemConfig

public SystemConfig getSystemConfig()

Description copied from interface: TaskExecutionService

Get the system configuration including capacity, retention policy etc

Specified by:

getSystemConfig in interface TaskExecutionService

Returns:

the current system configuration

getAuditReports

public java.util.List<LightningRequestReport> getAuditReports(java.lang.String sessionId)

Description copied from interface: TaskExecutionService

Get the detailed execution reports.

Specified by:

getAuditReports in interface TaskExecutionService

Parameters:

sessionId - the session id of the request

Returns:

the list of LightningRequestReport available in the store