com.ebay.lightning.core.manager

Class TaskExecutionManager

java.lang.Object

com.ebay.lightning.core.manager.TaskExecutionManager

@Component
public class TaskExecutionManager
extends java.lang.Object

The TaskExecutionManager provides the actual implementation of request processing, reporting and storage. The requests are queued up and gets processed in FIFO order. THe class delegates report storage to ExecutionDataStore

Author:

shashukla

Constructor Summary

Constructors

Constructor and Description
TaskExecutionManager(SystemConfig systemConfig, ExecutionDataStore dataStore, InetSocketAddressCache inetCache)

Method Summary

Modifier and Type	Method and Description
java.util.List<LightningRequestReport>	getAuditReports(java.lang.String sessionId)
SystemStatus	getLightningStats()
LightningRequestReport	getReport(java.lang.String sessionId)
java.util.Map<ReservationReceipt,java.lang.Long>	getReservationResponseLog() Get the current reservation list.
SystemConfig	getSystemConfig()
java.util.concurrent.BlockingQueue<LightningRequest>	getWorkQueue() Get the request to be processed queue.
LightningResponse	pollResults(java.lang.String sessionId, boolean pollDeltaOnly)
ReservationReceipt	reserve(int load)
void	setWorkQueue(java.util.concurrent.BlockingQueue<LightningRequest> workQueue) Set the request to be processed queue.
void	start() Initialized the TaskExecutionManager with reservation cleanup Reminder and request processing thread.
void	submit(LightningRequest request)
SystemConfig	updateSystemConfig(SystemConfig sysConfig)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskExecutionManager

@Autowired
public TaskExecutionManager(SystemConfig systemConfig,
                                       ExecutionDataStore dataStore,
                                       InetSocketAddressCache inetCache)

Method Detail

start

@PostConstruct
public void start()

Initialized the TaskExecutionManager with reservation cleanup Reminder and request processing thread.

reserve

public ReservationReceipt reserve(int load)

submit

public void submit(LightningRequest request)

pollResults

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

getReport

public LightningRequestReport getReport(java.lang.String sessionId)

getAuditReports

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

getLightningStats

public SystemStatus getLightningStats()

updateSystemConfig

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

Throws:

java.lang.Exception

getWorkQueue

public java.util.concurrent.BlockingQueue<LightningRequest> getWorkQueue()

Get the request to be processed queue.

Returns:

to process queue

setWorkQueue

public void setWorkQueue(java.util.concurrent.BlockingQueue<LightningRequest> workQueue)

Set the request to be processed queue.

Parameters:

workQueue - to process queue

getSystemConfig

public SystemConfig getSystemConfig()

getReservationResponseLog

public java.util.Map<ReservationReceipt,java.lang.Long> getReservationResponseLog()

Get the current reservation list.

Returns:

the current reservation list