Package org.apache.storm.daemon.drpc
Class DRPC
- java.lang.Object
-
- org.apache.storm.daemon.drpc.DRPC
-
- All Implemented Interfaces:
AutoCloseable
public class DRPC extends Object implements AutoCloseable
-
-
Constructor Summary
Constructors Constructor Description DRPC(StormMetricsRegistry metricsRegistry, Map<String,Object> conf)DRPC(StormMetricsRegistry metricsRegistry, IAuthorizer auth, long timeoutMs)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()<T extends OutstandingRequest>
Texecute(String functionName, String funcArgs, RequestFactory<T> factory)StringexecuteBlocking(String functionName, String funcArgs)voidfailRequest(String id, DRPCExecutionException e)DRPCRequestfetchRequest(String functionName)voidreturnResult(String id, String result)
-
-
-
Constructor Detail
-
DRPC
public DRPC(StormMetricsRegistry metricsRegistry, Map<String,Object> conf)
-
DRPC
public DRPC(StormMetricsRegistry metricsRegistry, IAuthorizer auth, long timeoutMs)
-
-
Method Detail
-
returnResult
public void returnResult(String id, String result) throws AuthorizationException
- Throws:
AuthorizationException
-
fetchRequest
public DRPCRequest fetchRequest(String functionName) throws AuthorizationException
- Throws:
AuthorizationException
-
failRequest
public void failRequest(String id, DRPCExecutionException e) throws AuthorizationException
- Throws:
AuthorizationException
-
execute
public <T extends OutstandingRequest> T execute(String functionName, String funcArgs, RequestFactory<T> factory) throws AuthorizationException
- Throws:
AuthorizationException
-
executeBlocking
public String executeBlocking(String functionName, String funcArgs) throws DRPCExecutionException, AuthorizationException
-
close
public void close()
- Specified by:
closein interfaceAutoCloseable
-
-