Package | Description |
---|---|
org.apache.storm.container | |
org.apache.storm.container.cgroup | |
org.apache.storm.container.docker | |
org.apache.storm.container.oci | |
org.apache.storm.daemon.supervisor |
Modifier and Type | Method and Description |
---|---|
void |
ResourceIsolationInterface.launchWorkerProcess(String user,
String topologyId,
Map<String,Object> topoConf,
int port,
String workerId,
List<String> command,
Map<String,String> env,
String logPrefix,
ExitCodeCallback processExitCallback,
File targetDir)
After reserving resources for the worker (i.e.
|
void |
DefaultResourceIsolationManager.launchWorkerProcess(String user,
String topologyId,
Map<String,Object> topoConf,
int port,
String workerId,
List<String> command,
Map<String,String> env,
String logPrefix,
ExitCodeCallback processExitCallback,
File targetDir) |
Modifier and Type | Method and Description |
---|---|
void |
CgroupManager.launchWorkerProcess(String user,
String topologyId,
Map<String,Object> topoConf,
int port,
String workerId,
List<String> command,
Map<String,String> env,
String logPrefix,
ExitCodeCallback processExitCallback,
File targetDir) |
Modifier and Type | Method and Description |
---|---|
void |
DockerManager.launchWorkerProcess(String user,
String topologyId,
Map<String,Object> topoConf,
int port,
String workerId,
List<String> command,
Map<String,String> env,
String logPrefix,
ExitCodeCallback processExitCallback,
File targetDir) |
Modifier and Type | Method and Description |
---|---|
void |
RuncLibContainerManager.launchWorkerProcess(String user,
String topologyId,
Map<String,Object> topoConf,
int port,
String workerId,
List<String> command,
Map<String,String> env,
String logPrefix,
ExitCodeCallback processExitCallback,
File targetDir) |
Modifier and Type | Method and Description |
---|---|
static Process |
ClientSupervisorUtils.launchProcess(List<String> command,
Map<String,String> environment,
String logPrefix,
ExitCodeCallback exitCodeCallback,
File dir)
Launch a new process as per
ProcessBuilder with a given callback. |
static Process |
ClientSupervisorUtils.processLauncher(Map<String,Object> conf,
String user,
List<String> commandPrefix,
List<String> args,
Map<String,String> environment,
String logPreFix,
ExitCodeCallback exitCodeCallback,
File dir) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.