io.druid.indexing.overlord.supervisor

Class SupervisorResource

java.lang.Object

io.druid.indexing.overlord.supervisor.SupervisorResource

public class SupervisorResource
extends Object

Endpoints for submitting and starting a SupervisorSpec, getting running supervisors, stopping supervisors, and getting supervisor history.

Constructor Summary

Constructors

Constructor and Description
SupervisorResource(TaskMaster taskMaster)

Method Summary

Modifier and Type	Method and Description
javax.ws.rs.core.Response	reset(String id)
javax.ws.rs.core.Response	shutdown(String id)
javax.ws.rs.core.Response	specGet(String id)
javax.ws.rs.core.Response	specGetAll()
javax.ws.rs.core.Response	specGetAllHistory()
javax.ws.rs.core.Response	specGetHistory(String id)
javax.ws.rs.core.Response	specGetStatus(String id)
javax.ws.rs.core.Response	specPost(SupervisorSpec spec)

Methods inherited from class java.lang.Object

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

Constructor Detail

SupervisorResource

@Inject
public SupervisorResource(TaskMaster taskMaster)

Method Detail

specPost

public javax.ws.rs.core.Response specPost(SupervisorSpec spec)

specGetAll

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

specGet

public javax.ws.rs.core.Response specGet(String id)

specGetStatus

public javax.ws.rs.core.Response specGetStatus(String id)

shutdown

public javax.ws.rs.core.Response shutdown(String id)

specGetAllHistory

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

specGetHistory

public javax.ws.rs.core.Response specGetHistory(String id)

reset

public javax.ws.rs.core.Response reset(String id)