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, io.druid.tasklogs.TaskLogStreamer taskLogStreamer, JacksonConfigManager configManager)

Method Summary

Methods

Modifier and Type	Method and Description
<T> javax.ws.rs.core.Response	doAction(TaskActionHolder<T> 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.ws.rs.core.Response	getLeader()
javax.ws.rs.core.Response	getPendingTasks()
javax.ws.rs.core.Response	getRunningTasks()
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.ws.rs.core.Response	getWorkerConfig()
javax.ws.rs.core.Response	getWorkers()
javax.ws.rs.core.Response	setWorkerConfig(WorkerBehaviorConfig workerBehaviorConfig)
javax.ws.rs.core.Response	taskPost(Task task)

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,
                       io.druid.tasklogs.TaskLogStreamer taskLogStreamer,
                       JacksonConfigManager configManager)
                 throws Exception

Throws:

Exception

Method Detail

taskPost

public javax.ws.rs.core.Response taskPost(Task task)

getLeader

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

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)

doAction

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

getWaitingTasks

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

getPendingTasks

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

getRunningTasks

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

getCompleteTasks

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

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)