public class DRPC extends Object implements AutoCloseable
| Constructor and Description |
|---|
DRPC(StormMetricsRegistry metricsRegistry,
IAuthorizer auth,
long timeoutMs) |
DRPC(StormMetricsRegistry metricsRegistry,
Map<String,Object> conf) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
<T extends OutstandingRequest> |
execute(String functionName,
String funcArgs,
RequestFactory<T> factory) |
String |
executeBlocking(String functionName,
String funcArgs) |
void |
failRequest(String id,
DRPCExecutionException e) |
DRPCRequest |
fetchRequest(String functionName) |
void |
returnResult(String id,
String result) |
public DRPC(StormMetricsRegistry metricsRegistry, Map<String,Object> conf)
public DRPC(StormMetricsRegistry metricsRegistry, IAuthorizer auth, long timeoutMs)
public void returnResult(String id, String result) throws AuthorizationException
AuthorizationExceptionpublic DRPCRequest fetchRequest(String functionName) throws AuthorizationException
AuthorizationExceptionpublic void failRequest(String id, DRPCExecutionException e) throws AuthorizationException
AuthorizationExceptionpublic <T extends OutstandingRequest> T execute(String functionName, String funcArgs, RequestFactory<T> factory) throws AuthorizationException
AuthorizationExceptionpublic String executeBlocking(String functionName, String funcArgs) throws DRPCExecutionException, AuthorizationException
public void close()
close in interface AutoCloseableCopyright © 2021 The Apache Software Foundation. All rights reserved.