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, AuthConfig authConfig, AuthorizerMapper authorizerMapper)

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.servlet.http.HttpServletRequest req)
javax.ws.rs.core.Response	specGetAllHistory(javax.servlet.http.HttpServletRequest req)
javax.ws.rs.core.Response	specGetHistory(String id)
javax.ws.rs.core.Response	specGetStatus(String id)
javax.ws.rs.core.Response	specPost(SupervisorSpec spec, 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

SupervisorResource

@Inject
public SupervisorResource(TaskMaster taskMaster,
                                  AuthConfig authConfig,
                                  AuthorizerMapper authorizerMapper)

Method Detail

specPost

public javax.ws.rs.core.Response specPost(SupervisorSpec spec,
                                          @Context
                                          javax.servlet.http.HttpServletRequest req)

specGetAll

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

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(@Context
                                                   javax.servlet.http.HttpServletRequest req)

specGetHistory

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

reset

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