io.druid.indexing.overlord.http

Class OverlordResource

java.lang.Object

io.druid.indexing.overlord.http.OverlordResource

public class OverlordResource
extends Object

Constructor Summary

Constructors

Constructor and Description
OverlordResource(TaskMaster taskMaster, TaskStorageQueryAdapter taskStorageQueryAdapter, TaskLogStreamer taskLogStreamer, JacksonConfigManager configManager, AuditManager auditManager, AuthConfig authConfig)

Method Summary

Modifier and Type	Method and Description
javax.ws.rs.core.Response	doAction(TaskActionHolder holder)
javax.ws.rs.core.Response	doGetLog(String taskid, long offset)
javax.ws.rs.core.Response	doShutdown(String taskid)
javax.ws.rs.core.Response	getCompleteTasks(javax.servlet.http.HttpServletRequest req)
javax.ws.rs.core.Response	getLeader()
javax.ws.rs.core.Response	getPendingTasks(javax.servlet.http.HttpServletRequest req)
javax.ws.rs.core.Response	getRunningTasks(javax.servlet.http.HttpServletRequest req)
javax.ws.rs.core.Response	getScalingState()
javax.ws.rs.core.Response	getTaskPayload(String taskid)
javax.ws.rs.core.Response	getTaskSegments(String taskid)
javax.ws.rs.core.Response	getTaskStatus(String taskid)
javax.ws.rs.core.Response	getWaitingTasks(javax.servlet.http.HttpServletRequest req)
javax.ws.rs.core.Response	getWorkerConfig()
javax.ws.rs.core.Response	getWorkerConfigHistory(String interval, Integer count)
javax.ws.rs.core.Response	getWorkers()
javax.ws.rs.core.Response	isLeader()
javax.ws.rs.core.Response	setWorkerConfig(WorkerBehaviorConfig workerBehaviorConfig, String author, String comment, javax.servlet.http.HttpServletRequest req)
javax.ws.rs.core.Response	taskPost(Task task, javax.servlet.http.HttpServletRequest req)

Methods inherited from class java.lang.Object

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

Constructor Detail

OverlordResource

@Inject
public OverlordResource(TaskMaster taskMaster,
                                TaskStorageQueryAdapter taskStorageQueryAdapter,
                                TaskLogStreamer taskLogStreamer,
                                JacksonConfigManager configManager,
                                AuditManager auditManager,
                                AuthConfig authConfig)
                         throws Exception

Throws:

Exception

Method Detail

taskPost

public javax.ws.rs.core.Response taskPost(Task task,
                                          @Context
                                          javax.servlet.http.HttpServletRequest req)

getLeader

public javax.ws.rs.core.Response getLeader()

isLeader

public javax.ws.rs.core.Response isLeader()

getTaskPayload

public javax.ws.rs.core.Response getTaskPayload(String taskid)

getTaskStatus

public javax.ws.rs.core.Response getTaskStatus(String taskid)

getTaskSegments

public javax.ws.rs.core.Response getTaskSegments(String taskid)

doShutdown

public javax.ws.rs.core.Response doShutdown(String taskid)

getWorkerConfig

public javax.ws.rs.core.Response getWorkerConfig()

setWorkerConfig

public javax.ws.rs.core.Response setWorkerConfig(WorkerBehaviorConfig workerBehaviorConfig,
                                                 @HeaderParam(value="X-Druid-Author")
                                                 String author,
                                                 @HeaderParam(value="X-Druid-Comment")
                                                 String comment,
                                                 @Context
                                                 javax.servlet.http.HttpServletRequest req)

getWorkerConfigHistory

public javax.ws.rs.core.Response getWorkerConfigHistory(String interval,
                                                        Integer count)

doAction

public javax.ws.rs.core.Response doAction(TaskActionHolder holder)

getWaitingTasks

public javax.ws.rs.core.Response getWaitingTasks(@Context
                                                 javax.servlet.http.HttpServletRequest req)

getPendingTasks

public javax.ws.rs.core.Response getPendingTasks(@Context
                                                 javax.servlet.http.HttpServletRequest req)

getRunningTasks

public javax.ws.rs.core.Response getRunningTasks(@Context
                                                 javax.servlet.http.HttpServletRequest req)

getCompleteTasks

public javax.ws.rs.core.Response getCompleteTasks(@Context
                                                  javax.servlet.http.HttpServletRequest req)

getWorkers

public javax.ws.rs.core.Response getWorkers()

getScalingState

public javax.ws.rs.core.Response getScalingState()

doGetLog

public javax.ws.rs.core.Response doGetLog(String taskid,
                                          long offset)