| Modifier and Type | Class and Description |
|---|---|
class |
RpcInvocation
RPC Invocation.
|
| Modifier and Type | Method and Description |
|---|---|
Invocation |
RpcServiceContext.getInvocation()
Deprecated.
Replace to getMethodName(), getParameterTypes(), getArguments()
|
Invocation |
RpcContext.getInvocation()
Deprecated.
Replace to getMethodName(), getParameterTypes(), getArguments()
|
| Modifier and Type | Method and Description |
|---|---|
void |
ListenableFilter.addListener(Invocation invocation,
BaseFilter.Listener listener)
Deprecated.
|
static void |
InvocationProfilerUtils.enterDetailProfiler(Invocation invocation,
Callable<String> messageCallable) |
static void |
InvocationProfilerUtils.enterProfiler(Invocation invocation,
Callable<String> messageCallable) |
static void |
InvocationProfilerUtils.enterProfiler(Invocation invocation,
String message) |
static void |
InvocationProfilerUtils.enterSimpleProfiler(Invocation invocation,
Callable<String> messageCallable) |
String |
ZoneDetector.getZoneOfCurrentRequest(Invocation invocation) |
Result |
Invoker.invoke(Invocation invocation)
invoke.
|
Result |
BaseFilter.invoke(Invoker<?> invoker,
Invocation invocation)
Always call invoker.invoke() in the implementation to hand over the request to the next filter node.
|
String |
ZoneDetector.isZoneForcingEnabled(Invocation invocation,
String zone) |
BaseFilter.Listener |
ListenableFilter.listener(Invocation invocation)
Deprecated.
|
static AsyncRpcResult |
AsyncRpcResult.newDefaultAsyncResult(AppResponse appResponse,
Invocation invocation)
Some utility methods used to quickly generate default AsyncRpcResult instance.
|
static AsyncRpcResult |
AsyncRpcResult.newDefaultAsyncResult(Invocation invocation) |
static AsyncRpcResult |
AsyncRpcResult.newDefaultAsyncResult(Object value,
Invocation invocation) |
static AsyncRpcResult |
AsyncRpcResult.newDefaultAsyncResult(Object value,
Throwable t,
Invocation invocation) |
static AsyncRpcResult |
AsyncRpcResult.newDefaultAsyncResult(Throwable t,
Invocation invocation) |
void |
BaseFilter.Listener.onError(Throwable t,
Invoker<?> invoker,
Invocation invocation)
This method will be called on detection of framework exceptions, for example, TimeoutException, NetworkException
Exception raised in Filters, etc.
|
void |
BaseFilter.Listener.onResponse(Result appResponse,
Invoker<?> invoker,
Invocation invocation)
This method will only be called on successful remote rpc execution, that means, the service in on remote received
the request and the result (normal or exceptional) returned successfully.
|
static void |
InvocationProfilerUtils.releaseDetailProfiler(Invocation invocation) |
static void |
InvocationProfilerUtils.releaseProfiler(Invocation invocation) |
static void |
InvocationProfilerUtils.releaseSimpleProfiler(Invocation invocation) |
void |
ListenableFilter.removeListener(Invocation invocation)
Deprecated.
|
RpcServiceContext |
RpcServiceContext.setInvocation(Invocation invocation) |
RpcContext |
RpcContext.setInvocation(Invocation invocation) |
| Constructor and Description |
|---|
AppResponse(Invocation invocation) |
AsyncRpcResult(CompletableFuture<AppResponse> future,
Invocation invocation) |
RpcInvocation(Invocation invocation) |
RpcInvocation(Invocation invocation,
Invoker<?> invoker) |
| Modifier and Type | Method and Description |
|---|---|
Result |
AccessLogFilter.invoke(Invoker<?> invoker,
Invocation inv)
This method logs the access log for service method invocation call.
|
Result |
CompatibleFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
ClassLoaderFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
ProfilerServerFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
ExecuteLimitFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
TpsLimitFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
ActiveLimitFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
ExceptionFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
GenericImplFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
EchoFilter.invoke(Invoker<?> invoker,
Invocation inv) |
Result |
ClassLoaderCallbackFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
TokenFilter.invoke(Invoker<?> invoker,
Invocation inv) |
Result |
ContextFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
DeprecatedFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
TimeoutFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
GenericFilter.invoke(Invoker<?> invoker,
Invocation inv) |
void |
CompatibleFilter.onError(Throwable t,
Invoker<?> invoker,
Invocation invocation) |
void |
ClassLoaderFilter.onError(Throwable t,
Invoker<?> invoker,
Invocation invocation) |
void |
ProfilerServerFilter.onError(Throwable t,
Invoker<?> invoker,
Invocation invocation) |
void |
ExecuteLimitFilter.onError(Throwable t,
Invoker<?> invoker,
Invocation invocation) |
void |
ActiveLimitFilter.onError(Throwable t,
Invoker<?> invoker,
Invocation invocation) |
void |
ExceptionFilter.onError(Throwable e,
Invoker<?> invoker,
Invocation invocation) |
void |
GenericImplFilter.onError(Throwable t,
Invoker<?> invoker,
Invocation invocation) |
void |
ClassLoaderCallbackFilter.onError(Throwable t,
Invoker<?> invoker,
Invocation invocation) |
void |
ContextFilter.onError(Throwable t,
Invoker<?> invoker,
Invocation invocation) |
void |
TimeoutFilter.onError(Throwable t,
Invoker<?> invoker,
Invocation invocation) |
void |
GenericFilter.onError(Throwable t,
Invoker<?> invoker,
Invocation invocation) |
void |
CompatibleFilter.onResponse(Result appResponse,
Invoker<?> invoker,
Invocation invocation) |
void |
ClassLoaderFilter.onResponse(Result appResponse,
Invoker<?> invoker,
Invocation invocation) |
void |
ProfilerServerFilter.onResponse(Result appResponse,
Invoker<?> invoker,
Invocation invocation) |
void |
ExecuteLimitFilter.onResponse(Result appResponse,
Invoker<?> invoker,
Invocation invocation) |
void |
ActiveLimitFilter.onResponse(Result appResponse,
Invoker<?> invoker,
Invocation invocation) |
void |
ExceptionFilter.onResponse(Result appResponse,
Invoker<?> invoker,
Invocation invocation) |
void |
GenericImplFilter.onResponse(Result appResponse,
Invoker<?> invoker,
Invocation invocation) |
void |
ClassLoaderCallbackFilter.onResponse(Result appResponse,
Invoker<?> invoker,
Invocation invocation) |
void |
ContextFilter.onResponse(Result appResponse,
Invoker<?> invoker,
Invocation invocation) |
void |
TimeoutFilter.onResponse(Result appResponse,
Invoker<?> invoker,
Invocation invocation) |
void |
GenericFilter.onResponse(Result appResponse,
Invoker<?> invoker,
Invocation inv) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
DefaultTPSLimiter.isAllowable(URL url,
Invocation invocation) |
boolean |
TPSLimiter.isAllowable(URL url,
Invocation invocation)
judge if the current invocation is allowed by TPS rule
|
| Modifier and Type | Method and Description |
|---|---|
Result |
ListenerInvokerWrapper.invoke(Invocation invocation) |
| Modifier and Type | Method and Description |
|---|---|
Result |
AbstractInvoker.invoke(Invocation inv) |
Result |
InvokerWrapper.invoke(Invocation invocation) |
| Modifier and Type | Method and Description |
|---|---|
Result |
AbstractProxyInvoker.invoke(Invocation invocation) |
| Modifier and Type | Method and Description |
|---|---|
static void |
RpcUtils.attachInvocationIdIfAsync(URL url,
Invocation inv)
Idempotent operation: invocation id will be added in async operation by default
|
void |
AccessLogData.buildAccessLogData(Invoker<?> invoker,
Invocation inv) |
static Object[] |
RpcUtils.getArguments(Invocation invocation) |
static Long |
RpcUtils.getInvocationId(Invocation inv) |
static InvokeMode |
RpcUtils.getInvokeMode(URL url,
Invocation inv) |
static String |
RpcUtils.getMethodName(Invocation invocation) |
static Class<?>[] |
RpcUtils.getParameterTypes(Invocation invocation) |
static Class<?> |
RpcUtils.getReturnType(Invocation invocation) |
static Type[] |
RpcUtils.getReturnTypes(Invocation invocation) |
static long |
RpcUtils.getTimeout(Invocation invocation,
long defaultTimeout) |
Result |
MockInvoker.invoke(Invocation invocation) |
static boolean |
RpcUtils.isAsync(URL url,
Invocation inv) |
static boolean |
RpcUtils.isGenericAsync(Invocation inv) |
static boolean |
RpcUtils.isOneway(URL url,
Invocation inv) |
static boolean |
RpcUtils.isReturnTypeFuture(Invocation inv) |
Copyright © 2011–2022 The Apache Software Foundation. All rights reserved.