com.ebay.lightning.core.controllers

Class LightningController

java.lang.Object

com.ebay.lightning.core.controllers.LightningController

@RestController
 @RequestMapping(value="l")
public class LightningController
extends java.lang.Object

REST based controller for the client to communicate with the seed.

Author:

shashukla

Constructor Summary

Constructors

Constructor and Description
LightningController()

Method Summary

Modifier and Type	Method and Description
byte[]	audit(java.lang.String sessionId) Get the detailed report for the request in compressed format.
LightningRequestReport	auditJson(java.lang.String sessionId) Get the detailed report for the request in JSON format.
byte[]	auditSummary(java.lang.String sessionId) Get the list of detailed reports in store.
byte[]	getLightningStats() Get the system metrics including CPU, physical and JVM memory.
java.lang.String	getSystemConfig() Get the system configuration including capacity, retention policy etc
byte[]	poll(java.lang.String sessionId, boolean pollDeltaOnly) Poll the current status of the request in compressed format.
LightningResponse	pollJson(java.lang.String sessionId, boolean pollDeltaOnly) Poll the current status of the request in JSON format.
java.lang.String	reserve() ECV check URL.
ReservationReceipt	reserve(java.lang.Integer load) Get reservation for the load.
void	setTaskExecutionService(TaskExecutionService taskExecutionService)
java.lang.String	submit(java.lang.String request) Submit a request.
SystemConfig	updateSystemConfig(java.lang.String payload) 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

LightningController

public LightningController()

Method Detail

reserve

@RequestMapping(value="/ecv",
                method={GET,HEAD},
                produces="application/json")
public java.lang.String reserve()

ECV check URL.

Returns:

the ECV response

setTaskExecutionService

public void setTaskExecutionService(TaskExecutionService taskExecutionService)

submit

@RequestMapping(value="/submit",
                method=POST)
public java.lang.String submit(@RequestBody
                                                                                             java.lang.String request)

Submit a request.

Parameters:

request - request to submit

Returns:

the submit response

reserve

@RequestMapping(value="/reserve/{load}",
                method=GET,
                produces="application/json")
public ReservationReceipt reserve(@PathVariable(value="load")
                                                                                                                                                    java.lang.Integer load)

Get reservation for the load.

Parameters:

load - the load

Returns:

the reservation receipt

pollJson

@RequestMapping(value="/poll/json/{sessionId}/{pollDeltaOnly}",
                method=GET,
                produces="application/json")
public LightningResponse pollJson(@PathVariable(value="sessionId")
                                                                                                                                                                           java.lang.String sessionId,
                                                                                                                                                                           @PathVariable(value="pollDeltaOnly")
                                                                                                                                                                           boolean pollDeltaOnly)

Poll the current status of the request in JSON format.

Parameters:

sessionId - the session id for the request

pollDeltaOnly - get full or changes only

Returns:

the status of request.

poll

@RequestMapping(value="/poll/{sessionId}/{pollDeltaOnly}",
                method=GET,
                produces="application/zip")
public byte[] poll(@PathVariable(value="sessionId")
                                                                                                                                                      java.lang.String sessionId,
                                                                                                                                                      @PathVariable(value="pollDeltaOnly")
                                                                                                                                                      boolean pollDeltaOnly)

Poll the current status of the request in compressed format.

Parameters:

sessionId - the session id for the request

pollDeltaOnly - get full or changes only

Returns:

the status of request.

audit

@RequestMapping(value="/audit/{sessionId}",
                method=GET,
                produces="application/zip")
public byte[] audit(@PathVariable(value="sessionId")
                                                                                                                                        java.lang.String sessionId)

Get the detailed report for the request in compressed format.

Parameters:

sessionId - the session id for the request

Returns:

the detailed report for the request

auditJson

@RequestMapping(value="/audit/json/{sessionId}",
                method=GET,
                produces="application/json")
public LightningRequestReport auditJson(@PathVariable(value="sessionId")
                                                                                                                                                                  java.lang.String sessionId)

Get the detailed report for the request in JSON format.

Parameters:

sessionId - the session id for the request

Returns:

the detailed report for the request

auditSummary

@RequestMapping(value="/auditSummary",
                method=GET,
                produces="application/zip")
public byte[] auditSummary(@RequestParam(value="sessionId",required=false,defaultValue="")
                                                                                                                                          java.lang.String sessionId)

Get the list of detailed reports in store.

Parameters:

sessionId - the session id

Returns:

the list of detailed reports

getLightningStats

@RequestMapping(value="/lightningStats",
                method=GET,
                produces="application/zip")
public byte[] getLightningStats()

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

Returns:

the lightning stats

updateSystemConfig

@RequestMapping(value="/updateSystemConfig",
                method=POST,
                produces="application/json")
public SystemConfig updateSystemConfig(@RequestBody
                                                                                                                                                              java.lang.String payload)

Update the system configuration including capacity, retention policy etc

Parameters:

payload - the SystemConfig in JSON format

Returns:

the system configuration after update

getSystemConfig

@RequestMapping(value="/getSystemConfig",
                method=GET,
                produces="application/json")
public java.lang.String getSystemConfig()

Get the system configuration including capacity, retention policy etc

Returns:

the current system configuration