| Modifier and Type | Method and Description |
|---|---|
Invoker<T> |
Exporter.getInvoker()
get invoker.
|
Invoker<?> |
RpcInvocation.getInvoker() |
Invoker<?> |
RpcServiceContext.getInvoker()
Deprecated.
Replace to getUrl()
|
Invoker<?> |
Invocation.getInvoker()
get the invoker in current context.
|
Invoker<?> |
RpcContext.getInvoker()
Deprecated.
Replace to getUrl()
|
<T> Invoker<T> |
ProxyFactory.getInvoker(T proxy,
Class<T> type,
URL url)
create invoker.
|
Invoker<T> |
ServerService.getInvoker(URL url) |
<T> Invoker<T> |
Protocol.refer(Class<T> type,
URL url)
Refer a remote service:
1. |
Invoker<?> |
PathResolver.resolve(String path) |
| Modifier and Type | Method and Description |
|---|---|
List<Invoker<?>> |
RpcServiceContext.getInvokers()
Deprecated.
Replace to getUrls()
|
List<Invoker<?>> |
RpcContext.getInvokers()
Deprecated.
Replace to getUrls()
|
| Modifier and Type | Method and Description |
|---|---|
void |
PathResolver.add(String path,
Invoker<?> invoker) |
void |
InvokerListener.destroyed(Invoker<?> invoker)
The invoker destroyed.
|
<T> Exporter<T> |
Protocol.export(Invoker<T> invoker)
Export service for remote invocation:
1. |
<T> T |
ProxyFactory.getProxy(Invoker<T> invoker)
create proxy.
|
<T> T |
ProxyFactory.getProxy(Invoker<T> invoker,
boolean generic)
create proxy.
|
Result |
BaseFilter.invoke(Invoker<?> invoker,
Invocation invocation)
Always call invoker.invoke() in the implementation to hand over the request to the next filter node.
|
RpcInvocation |
HeaderFilter.invoke(Invoker<?> invoker,
RpcInvocation 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.
|
void |
InvokerListener.referred(Invoker<?> invoker)
The invoker referred
|
void |
RpcInvocation.setInvoker(Invoker<?> invoker) |
RpcServiceContext |
RpcServiceContext.setInvoker(Invoker<?> invoker) |
RpcContext |
RpcContext.setInvoker(Invoker<?> invoker) |
| Modifier and Type | Method and Description |
|---|---|
RpcServiceContext |
RpcServiceContext.setInvokers(List<Invoker<?>> invokers) |
RpcContext |
RpcContext.setInvokers(List<Invoker<?>> invokers) |
| Constructor and Description |
|---|
RpcInvocation(Invocation invocation,
Invoker<?> invoker) |
RpcInvocation(ServiceModel serviceModel,
String methodName,
String interfaceName,
String protocolServiceKey,
Class<?>[] parameterTypes,
Object[] arguments,
Map<String,Object> attachments,
Invoker<?> invoker,
Map<Object,Object> attributes) |
RpcInvocation(String targetServiceUniqueName,
ServiceModel serviceModel,
String methodName,
String interfaceName,
String protocolServiceKey,
Class<?>[] parameterTypes,
Object[] arguments,
Map<String,Object> attachments,
Invoker<?> invoker,
Map<Object,Object> attributes) |
RpcInvocation(String methodName,
String interfaceName,
String protocolServiceKey,
Class<?>[] parameterTypes,
Object[] arguments,
Map<String,Object> attachments,
Invoker<?> invoker,
Map<Object,Object> attributes)
Deprecated.
|
| 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) |
RpcInvocation |
TokenHeaderFilter.invoke(Invoker<?> invoker,
RpcInvocation invocation) |
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 | Class and Description |
|---|---|
class |
ListenerInvokerWrapper<T>
ListenerInvoker
|
| Modifier and Type | Method and Description |
|---|---|
Invoker<T> |
ListenerExporterWrapper.getInvoker() |
Invoker<T> |
ListenerInvokerWrapper.getInvoker() |
| Modifier and Type | Method and Description |
|---|---|
void |
InvokerListenerAdapter.destroyed(Invoker<?> invoker) |
void |
DeprecatedInvokerListener.referred(Invoker<?> invoker) |
void |
InvokerListenerAdapter.referred(Invoker<?> invoker) |
| Constructor and Description |
|---|
ListenerInvokerWrapper(Invoker<T> invoker,
List<InvokerListener> listeners) |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractInvoker<T>
This Invoker works on Consumer side.
|
class |
InvokerWrapper<T>
InvokerWrapper
|
| Modifier and Type | Method and Description |
|---|---|
Invoker<T> |
AbstractExporter.getInvoker() |
<T> Invoker<T> |
ProtocolListenerWrapper.refer(Class<T> type,
URL url) |
<T> Invoker<T> |
ProtocolSerializationWrapper.refer(Class<T> type,
URL url) |
<T> Invoker<T> |
AbstractProtocol.refer(Class<T> type,
URL url) |
| Modifier and Type | Method and Description |
|---|---|
<T> Exporter<T> |
ProtocolListenerWrapper.export(Invoker<T> invoker) |
<T> Exporter<T> |
AbstractProxyProtocol.export(Invoker<T> invoker) |
<T> Exporter<T> |
ProtocolSerializationWrapper.export(Invoker<T> invoker) |
| Constructor and Description |
|---|
AbstractExporter(Invoker<T> invoker) |
InvokerWrapper(Invoker<T> invoker,
URL url) |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractProxyInvoker<T>
This Invoker works on provider side, delegates RPC to interface implementation.
|
| Modifier and Type | Method and Description |
|---|---|
<T> T |
AbstractProxyFactory.getProxy(Invoker<T> invoker) |
<T> T |
AbstractProxyFactory.getProxy(Invoker<T> invoker,
boolean generic) |
abstract <T> T |
AbstractProxyFactory.getProxy(Invoker<T> invoker,
Class<?>[] types) |
static Object |
InvocationUtil.invoke(Invoker<?> invoker,
RpcInvocation rpcInvocation) |
| Constructor and Description |
|---|
InvokerInvocationHandler(Invoker<?> handler) |
| Modifier and Type | Method and Description |
|---|---|
<T> Invoker<T> |
JavassistProxyFactory.getInvoker(T proxy,
Class<T> type,
URL url) |
| Modifier and Type | Method and Description |
|---|---|
<T> T |
JavassistProxyFactory.getProxy(Invoker<T> invoker,
Class<?>[] interfaces) |
| Modifier and Type | Method and Description |
|---|---|
<T> Invoker<T> |
JdkProxyFactory.getInvoker(T proxy,
Class<T> type,
URL url) |
| Modifier and Type | Method and Description |
|---|---|
<T> T |
JdkProxyFactory.getProxy(Invoker<T> invoker,
Class<?>[] interfaces) |
| Modifier and Type | Method and Description |
|---|---|
<T> Invoker<T> |
StubProxyFactoryWrapper.getInvoker(T proxy,
Class<T> type,
URL url) |
| Modifier and Type | Method and Description |
|---|---|
<T> T |
StubProxyFactoryWrapper.getProxy(Invoker<T> invoker) |
<T> T |
StubProxyFactoryWrapper.getProxy(Invoker<T> invoker,
boolean generic) |
| Modifier and Type | Class and Description |
|---|---|
class |
StubInvoker<T> |
| Modifier and Type | Method and Description |
|---|---|
<T> Invoker<T> |
StubProxyFactory.getInvoker(T proxy,
Class<T> type,
URL url) |
| Modifier and Type | Method and Description |
|---|---|
static <T,R> StreamObserver<T> |
StubInvocationUtil.biOrClientStreamCall(Invoker<?> invoker,
MethodDescriptor method,
StreamObserver<R> responseObserver) |
static <T> T |
StubSuppliers.createStub(String interfaceName,
Invoker<T> invoker) |
<T> T |
StubProxyFactory.getProxy(Invoker<T> invoker) |
<T> T |
StubProxyFactory.getProxy(Invoker<T> invoker,
boolean generic) |
static <T,R> void |
StubInvocationUtil.serverStreamCall(Invoker<?> invoker,
MethodDescriptor method,
T request,
StreamObserver<R> responseObserver) |
static <T,R> R |
StubInvocationUtil.unaryCall(Invoker<?> invoker,
MethodDescriptor methodDescriptor,
T request) |
static <T,R> void |
StubInvocationUtil.unaryCall(Invoker<?> invoker,
MethodDescriptor method,
T request,
StreamObserver<R> responseObserver) |
| Modifier and Type | Method and Description |
|---|---|
static void |
StubSuppliers.addSupplier(String interfaceName,
Function<Invoker<?>,Object> supplier) |
| Modifier and Type | Class and Description |
|---|---|
class |
MockInvoker<T> |
| Modifier and Type | Method and Description |
|---|---|
<T> Invoker<T> |
MockProtocol.protocolBindingRefer(Class<T> type,
URL url) |
| Modifier and Type | Method and Description |
|---|---|
void |
AccessLogData.buildAccessLogData(Invoker<?> invoker,
Invocation inv) |
<T> Exporter<T> |
MockProtocol.export(Invoker<T> invoker) |
Copyright © 2011–2022 The Apache Software Foundation. All rights reserved.