io.druid.indexing.worker.http

Class WorkerResource

java.lang.Object

io.druid.indexing.worker.http.WorkerResource

public class WorkerResource
extends Object

Constructor Summary

Constructors

Constructor and Description
WorkerResource(Worker worker, WorkerCuratorCoordinator curatorCoordinator, ForkingTaskRunner taskRunner)

Method Summary

Modifier and Type	Method and Description
javax.ws.rs.core.Response	doDisable()
javax.ws.rs.core.Response	doEnable()
javax.ws.rs.core.Response	doGetLog(String taskid, long offset)
javax.ws.rs.core.Response	doShutdown(String taskid)
javax.ws.rs.core.Response	getTasks()
javax.ws.rs.core.Response	isEnabled()

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerResource

@Inject
public WorkerResource(Worker worker,
                              WorkerCuratorCoordinator curatorCoordinator,
                              ForkingTaskRunner taskRunner)
                       throws Exception

Throws:

Exception

Method Detail

doDisable

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

doEnable

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

isEnabled

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

getTasks

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

doShutdown

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

doGetLog

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