public class OverlordResource extends Object
Constructor and Description |
---|
OverlordResource(TaskMaster taskMaster,
TaskStorageQueryAdapter taskStorageQueryAdapter,
IndexerMetadataStorageAdapter indexerMetadataStorageAdapter,
TaskLogStreamer taskLogStreamer,
JacksonConfigManager configManager,
AuditManager auditManager,
AuthorizerMapper authorizerMapper) |
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(Integer maxTaskStatuses,
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()
This is an unsecured endpoint, defined as such in UNSECURED_PATHS in CliOverlord
|
javax.ws.rs.core.Response |
killPendingSegments(String dataSource,
String deleteIntervalString,
javax.servlet.http.HttpServletRequest request) |
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) |
@Inject public OverlordResource(TaskMaster taskMaster, TaskStorageQueryAdapter taskStorageQueryAdapter, IndexerMetadataStorageAdapter indexerMetadataStorageAdapter, TaskLogStreamer taskLogStreamer, JacksonConfigManager configManager, AuditManager auditManager, AuthorizerMapper authorizerMapper)
public javax.ws.rs.core.Response taskPost(Task task, @Context javax.servlet.http.HttpServletRequest req)
public javax.ws.rs.core.Response getLeader()
public javax.ws.rs.core.Response isLeader()
public javax.ws.rs.core.Response getTaskPayload(String taskid)
public javax.ws.rs.core.Response getTaskStatus(String taskid)
public javax.ws.rs.core.Response getTaskSegments(String taskid)
public javax.ws.rs.core.Response doShutdown(String taskid)
public javax.ws.rs.core.Response getWorkerConfig()
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)
public javax.ws.rs.core.Response getWorkerConfigHistory(String interval, Integer count)
public javax.ws.rs.core.Response doAction(TaskActionHolder holder)
public javax.ws.rs.core.Response getWaitingTasks(@Context javax.servlet.http.HttpServletRequest req)
public javax.ws.rs.core.Response getPendingTasks(@Context javax.servlet.http.HttpServletRequest req)
public javax.ws.rs.core.Response getRunningTasks(@Context javax.servlet.http.HttpServletRequest req)
public javax.ws.rs.core.Response getCompleteTasks(Integer maxTaskStatuses, @Context javax.servlet.http.HttpServletRequest req)
public javax.ws.rs.core.Response killPendingSegments(String dataSource, String deleteIntervalString, @Context javax.servlet.http.HttpServletRequest request)
public javax.ws.rs.core.Response getWorkers()
public javax.ws.rs.core.Response getScalingState()
public javax.ws.rs.core.Response doGetLog(String taskid, long offset)
Copyright © 2011–2018. All rights reserved.