@Path(value="/") public class StormApiResource extends Object
Root resource (exposed at “storm” path).
| Modifier and Type | Field and Description |
|---|---|
static String |
callbackParameterName |
static Map<String,Object> |
config |
static org.slf4j.Logger |
LOG |
| Constructor and Description |
|---|
StormApiResource(StormMetricsRegistry metricsRegistry) |
| Modifier and Type | Method and Description |
|---|---|
javax.ws.rs.core.Response |
getClusterConfiguration(String callback)
/api/v1/cluster/configuration -> nimbus configuration.
|
javax.ws.rs.core.Response |
getClusterSummary(String callback)
/api/v1/cluster/summary -> cluster summary.
|
javax.ws.rs.core.Response |
getHistorySummary(String callback)
/api/v1/history/summary -> topo history.
|
javax.ws.rs.core.Response |
getNimbusSummary(String callback)
/api/v1/nimbus/summary -> nimbus summary.
|
javax.ws.rs.core.Response |
getOwnerResource(String id,
String callback)
/api/v1/owner-resources/:id -> owner resources.
|
javax.ws.rs.core.Response |
getOwnerResources(String callback)
/api/v1/owner-resources -> owner resources.
|
javax.ws.rs.core.Response |
getSupervisor(String id,
String host,
boolean sys,
String callback)
/api/v1/supervisor -> topo history.
|
javax.ws.rs.core.Response |
getSupervisorSummary(javax.ws.rs.core.SecurityContext securityContext,
String callback)
/api/v1/supervisor/summary -> supervisor summary.
|
javax.ws.rs.core.Response |
getTopology(String id,
String window,
boolean sys,
String callback)
/api/v1/topology -> topo.
|
javax.ws.rs.core.Response |
getTopologyComponent(String id,
String component,
boolean sys,
String callback,
String window)
/api/v1/topology/:id/component/:component -> component.
|
javax.ws.rs.core.Response |
getTopologyLag(String id,
String callback)
/api/v1/topology/:id/lag -> lag.
|
javax.ws.rs.core.Response |
getTopologyLogconfig(String id,
String callback)
/api/v1/topology/:id/logconfig -> logconfig.
|
javax.ws.rs.core.Response |
getTopologyMetrics(String id,
String window,
boolean sys,
String callback)
/api/v1/topology/:id/metrics -> metrics.
|
javax.ws.rs.core.Response |
getTopologyProfilingDumpheap(String id,
String hostPort,
String callback)
/api/v1/topology/:id/profiling/dumpheap/:host-port -> dump heap.
|
javax.ws.rs.core.Response |
getTopologyProfilingDumpJstack(String id,
String hostPort,
String callback)
/api/v1/topology/:id/profiling/dumpjstack/:host-port -> dump jstack.
|
javax.ws.rs.core.Response |
getTopologyProfilingDumpProfile(String id,
String hostPort,
String callback)
/api/v1/topology/:id/profiling/dumpprofile/:host-port -> dump profile.
|
javax.ws.rs.core.Response |
getTopologyProfilingRestartWorker(String id,
String hostPort,
String callback)
/api/v1/topology/:id/profiling/restartworker/:host-port -> restart worker.
|
javax.ws.rs.core.Response |
getTopologyProfilingStart(String id,
String hostPort,
String timeout,
String callback)
/api/v1/topology/:id/profiling/start/:host-port/:timeout -> profiling start.
|
javax.ws.rs.core.Response |
getTopologyProfilingStop(String id,
String hostPort,
String callback)
/api/v1/topology/:id/profiling/stop/:host-port -> profiling stop.
|
javax.ws.rs.core.Response |
getTopologySummary(javax.ws.rs.core.SecurityContext securityContext,
String callback)
/api/v1/topology/summary -> topo history.
|
javax.ws.rs.core.Response |
getTopologyVisializationInit(String id,
boolean sys,
String callback,
String window)
/api/v1/topology/:id/visualization-init -> visualization-init.
|
javax.ws.rs.core.Response |
getTopologyVisualization(String id,
boolean sys,
String callback,
String window)
/api/v1/topology/:id/visualization -> visualization.
|
javax.ws.rs.core.Response |
getTopologyWorkers(String id,
String callback)
/api/v1/topology-workers/:id -> topo workers.
|
javax.ws.rs.core.Response |
putTopologyActivate(String id,
String callback)
/api/v1/topology/:id/activate -> topology activate.
|
javax.ws.rs.core.Response |
putTopologyComponentDebugActionSpct(String id,
String component,
String action,
String spct,
String callback)
/api/v1/topology/:id/component/:component/debug/:action/:spct -> debug component action.
|
javax.ws.rs.core.Response |
putTopologyDeactivate(String id,
String callback)
/api/v1/topology/:id/deactivate -> topology deactivate.
|
javax.ws.rs.core.Response |
putTopologyDebugActionSpct(String id,
String action,
String spct,
String callback)
/api/v1/topology/:id/debug/:action/:spct -> debug action.
|
javax.ws.rs.core.Response |
putTopologyKill(String id,
String waitTime,
String callback)
/api/v1/topology/:id/kill/:wait-time -> topology kill.
|
javax.ws.rs.core.Response |
putTopologyLogconfig(String id,
String body,
String callback)
/api/v1/topology/:id/logconfig -> logconfig.
|
javax.ws.rs.core.Response |
putTopologyRebalance(String id,
String waitTime,
String callback)
/api/v1/topology/:id/rebalance/:wait-time -> topology rebalance.
|
public static final org.slf4j.Logger LOG
public static final String callbackParameterName
@Inject public StormApiResource(StormMetricsRegistry metricsRegistry)
@GET
@Path(value="/cluster/configuration")
@Produces(value="application/json")
public javax.ws.rs.core.Response getClusterConfiguration(@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/cluster/configuration -> nimbus configuration.
org.apache.storm.thrift.TException@GET @Path(value="/cluster/summary") @AuthNimbusOp(value="getClusterInfo") @Produces(value="application/json") public javax.ws.rs.core.Response getClusterSummary(@QueryParam(value="callback") String callback) throws org.apache.storm.thrift.TException
/api/v1/cluster/summary -> cluster summary.
org.apache.storm.thrift.TException@GET @Path(value="/nimbus/summary") @AuthNimbusOp(value="getClusterInfo") @Produces(value="application/json") public javax.ws.rs.core.Response getNimbusSummary(@QueryParam(value="callback") String callback) throws org.apache.storm.thrift.TException
/api/v1/nimbus/summary -> nimbus summary.
org.apache.storm.thrift.TException@GET @Path(value="/owner-resources") @AuthNimbusOp(value="getOwnerResourceSummaries") @Produces(value="application/json") public javax.ws.rs.core.Response getOwnerResources(@QueryParam(value="callback") String callback) throws org.apache.storm.thrift.TException
/api/v1/owner-resources -> owner resources.
org.apache.storm.thrift.TException@GET
@Path(value="/owner-resources/{id}")
@AuthNimbusOp(value="getOwnerResourceSummaries")
@Produces(value="application/json")
public javax.ws.rs.core.Response getOwnerResource(@PathParam(value="id")
String id,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/owner-resources/:id -> owner resources.
org.apache.storm.thrift.TException@GET
@Path(value="/history/summary")
@Produces(value="application/json")
public javax.ws.rs.core.Response getHistorySummary(@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/history/summary -> topo history.
org.apache.storm.thrift.TException@GET @Path(value="/supervisor/summary") @AuthNimbusOp(value="getClusterInfo") @Produces(value="application/json") public javax.ws.rs.core.Response getSupervisorSummary(@Context javax.ws.rs.core.SecurityContext securityContext, @QueryParam(value="callback") String callback) throws org.apache.storm.thrift.TException
/api/v1/supervisor/summary -> supervisor summary.
org.apache.storm.thrift.TException@GET @Path(value="/supervisor") @AuthNimbusOp(value="getSupervisorPageInfo") @Produces(value="application/json") public javax.ws.rs.core.Response getSupervisor(@QueryParam(value="id") String id, @QueryParam(value="host") String host, @QueryParam(value="sys") boolean sys, @QueryParam(value="callback") String callback) throws org.apache.storm.thrift.TException
/api/v1/supervisor -> topo history.
org.apache.storm.thrift.TException@GET @Path(value="/topology/summary") @AuthNimbusOp(value="getClusterInfo") @Produces(value="application/json") public javax.ws.rs.core.Response getTopologySummary(@Context javax.ws.rs.core.SecurityContext securityContext, @QueryParam(value="callback") String callback) throws org.apache.storm.thrift.TException
/api/v1/topology/summary -> topo history.
org.apache.storm.thrift.TException@GET
@Path(value="/topology/{id}")
@AuthNimbusOp(value="getTopology",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response getTopology(@PathParam(value="id")
String id,
@DefaultValue(value=":all-time") @QueryParam(value="window")
String window,
@QueryParam(value="sys")
boolean sys,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/topology -> topo.
org.apache.storm.thrift.TException@GET
@Path(value="/topology-workers/{id}")
@AuthNimbusOp(value="getTopology",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response getTopologyWorkers(@PathParam(value="id")
String id,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/topology-workers/:id -> topo workers.
org.apache.storm.thrift.TException@GET
@Path(value="/topology/{id}/metrics")
@AuthNimbusOp(value="getTopology",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response getTopologyMetrics(@PathParam(value="id")
String id,
@DefaultValue(value=":all-time") @QueryParam(value="window")
String window,
@QueryParam(value="sys")
boolean sys,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/metrics -> metrics.
org.apache.storm.thrift.TException@GET
@Path(value="/topology/{id}/lag")
@AuthNimbusOp(value="getTopology",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response getTopologyLag(@PathParam(value="id")
String id,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/lag -> lag.
org.apache.storm.thrift.TException@GET
@Path(value="/topology/{id}/visualization-init")
@AuthNimbusOp(value="getTopology",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response getTopologyVisializationInit(@PathParam(value="id")
String id,
@QueryParam(value="sys")
boolean sys,
@QueryParam(value="callback")
String callback,
@DefaultValue(value=":all-time") @QueryParam(value="window")
String window)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/visualization-init -> visualization-init.
org.apache.storm.thrift.TException@GET
@Path(value="/topology/{id}/visualization")
@AuthNimbusOp(value="getTopology",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response getTopologyVisualization(@PathParam(value="id")
String id,
@QueryParam(value="sys")
boolean sys,
@QueryParam(value="callback")
String callback,
@DefaultValue(value=":all-time") @QueryParam(value="window")
String window)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/visualization -> visualization.
org.apache.storm.thrift.TException@GET
@Path(value="/topology/{id}/component/{component}")
@AuthNimbusOp(value="getTopology",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response getTopologyComponent(@PathParam(value="id")
String id,
@PathParam(value="component")
String component,
@QueryParam(value="sys")
boolean sys,
@QueryParam(value="callback")
String callback,
@DefaultValue(value=":all-time") @QueryParam(value="window")
String window)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/component/:component -> component.
org.apache.storm.thrift.TException@GET
@Path(value="/topology/{id}/logconfig")
@AuthNimbusOp(value="getTopology",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response getTopologyLogconfig(@PathParam(value="id")
String id,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/logconfig -> logconfig.
org.apache.storm.thrift.TException@POST
@Path(value="/topology/{id}/logconfig")
@AuthNimbusOp(value="setLogConfig",
needsTopoId=true)
@Produces(value="application/json")
@Consumes(value="application/json")
public javax.ws.rs.core.Response putTopologyLogconfig(@PathParam(value="id")
String id,
String body,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/logconfig -> logconfig.
org.apache.storm.thrift.TException@POST
@Path(value="/topology/{id}/activate")
@AuthNimbusOp(value="activate",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response putTopologyActivate(@PathParam(value="id")
String id,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/activate -> topology activate.
org.apache.storm.thrift.TException@POST
@Path(value="/topology/{id}/deactivate")
@AuthNimbusOp(value="deactivate",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response putTopologyDeactivate(@PathParam(value="id")
String id,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/deactivate -> topology deactivate.
org.apache.storm.thrift.TException@POST
@Path(value="/topology/{id}/debug/{action}/{spct}")
@AuthNimbusOp(value="debug",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response putTopologyDebugActionSpct(@PathParam(value="id")
String id,
@PathParam(value="action")
String action,
@PathParam(value="spct")
String spct,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/debug/:action/:spct -> debug action.
org.apache.storm.thrift.TException@POST
@Path(value="/topology/{id}/component/{component}/debug/{action}/{spct}")
@AuthNimbusOp(value="debug",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response putTopologyComponentDebugActionSpct(@PathParam(value="id")
String id,
@PathParam(value="component")
String component,
@PathParam(value="action")
String action,
@PathParam(value="spct")
String spct,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/component/:component/debug/:action/:spct -> debug component action.
org.apache.storm.thrift.TException@POST
@Path(value="/topology/{id}/rebalance/{wait-time}")
@AuthNimbusOp(value="rebalance",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response putTopologyRebalance(@PathParam(value="id")
String id,
@PathParam(value="wait-time")
String waitTime,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/rebalance/:wait-time -> topology rebalance.
org.apache.storm.thrift.TException@POST
@Path(value="/topology/{id}/kill/{wait-time}")
@AuthNimbusOp(value="killTopology",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response putTopologyKill(@PathParam(value="id")
String id,
@PathParam(value="wait-time")
String waitTime,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/kill/:wait-time -> topology kill.
org.apache.storm.thrift.TException@GET
@Path(value="/topology/{id}/profiling/start/{host-port}/{timeout}")
@AuthNimbusOp(value="setWorkerProfiler",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response getTopologyProfilingStart(@PathParam(value="id")
String id,
@PathParam(value="host-port")
String hostPort,
@PathParam(value="timeout")
String timeout,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/profiling/start/:host-port/:timeout -> profiling start.
org.apache.storm.thrift.TException@GET
@Path(value="/topology/{id}/profiling/stop/{host-port}")
@AuthNimbusOp(value="setWorkerProfiler",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response getTopologyProfilingStop(@PathParam(value="id")
String id,
@PathParam(value="host-port")
String hostPort,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/profiling/stop/:host-port -> profiling stop.
org.apache.storm.thrift.TException@GET
@Path(value="/topology/{id}/profiling/dumpprofile/{host-port}")
@AuthNimbusOp(value="setWorkerProfiler",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response getTopologyProfilingDumpProfile(@PathParam(value="id")
String id,
@PathParam(value="host-port")
String hostPort,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/profiling/dumpprofile/:host-port -> dump profile.
org.apache.storm.thrift.TException@GET
@Path(value="/topology/{id}/profiling/dumpjstack/{host-port}")
@AuthNimbusOp(value="setWorkerProfiler",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response getTopologyProfilingDumpJstack(@PathParam(value="id")
String id,
@PathParam(value="host-port")
String hostPort,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/profiling/dumpjstack/:host-port -> dump jstack.
org.apache.storm.thrift.TException@GET
@Path(value="/topology/{id}/profiling/restartworker/{host-port}")
@AuthNimbusOp(value="setWorkerProfiler",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response getTopologyProfilingRestartWorker(@PathParam(value="id")
String id,
@PathParam(value="host-port")
String hostPort,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/profiling/restartworker/:host-port -> restart worker.
org.apache.storm.thrift.TException@GET
@Path(value="/topology/{id}/profiling/dumpheap/{host-port}")
@AuthNimbusOp(value="setWorkerProfiler",
needsTopoId=true)
@Produces(value="application/json")
public javax.ws.rs.core.Response getTopologyProfilingDumpheap(@PathParam(value="id")
String id,
@PathParam(value="host-port")
String hostPort,
@QueryParam(value="callback")
String callback)
throws org.apache.storm.thrift.TException
/api/v1/topology/:id/profiling/dumpheap/:host-port -> dump heap.
org.apache.storm.thrift.TExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.