| Modifier and Type | Class and Description |
|---|---|
class |
JprotobufRpcMethodInfo
jprotobuf method info, which can be encode/decode jprotobuf class.
|
class |
ProtobufRpcMethodInfo |
| Modifier and Type | Field and Description |
|---|---|
protected RpcMethodInfo |
RpcFuture.rpcMethodInfo |
| Modifier and Type | Method and Description |
|---|---|
static RpcMethodInfo |
MethodUtils.getRpcMethodInfo(Class clazz,
String methodName) |
| Modifier and Type | Method and Description |
|---|---|
void |
RpcFuture.init(io.netty.util.Timeout timeout,
RpcMethodInfo rpcMethodInfo,
RpcCallback<T> callback,
ChannelInfo channelInfo) |
| Modifier and Type | Method and Description |
|---|---|
io.netty.buffer.ByteBuf |
GzipCompress.compressInput(Object proto,
RpcMethodInfo rpcMethodInfo) |
io.netty.buffer.ByteBuf |
Compress.compressInput(Object proto,
RpcMethodInfo rpcMethodInfo)
client端encode request并压缩
|
io.netty.buffer.ByteBuf |
ZlibCompress.compressInput(Object proto,
RpcMethodInfo rpcMethodInfo) |
io.netty.buffer.ByteBuf |
NoneCompress.compressInput(Object proto,
RpcMethodInfo rpcMethodInfo) |
io.netty.buffer.ByteBuf |
SnappyCompress.compressInput(Object proto,
RpcMethodInfo rpcMethodInfo) |
io.netty.buffer.ByteBuf |
GzipCompress.compressOutput(Object proto,
RpcMethodInfo rpcMethodInfo) |
io.netty.buffer.ByteBuf |
Compress.compressOutput(Object proto,
RpcMethodInfo rpcMethodInfo)
server序列化response并压缩
|
io.netty.buffer.ByteBuf |
ZlibCompress.compressOutput(Object proto,
RpcMethodInfo rpcMethodInfo) |
io.netty.buffer.ByteBuf |
NoneCompress.compressOutput(Object proto,
RpcMethodInfo rpcMethodInfo) |
io.netty.buffer.ByteBuf |
SnappyCompress.compressOutput(Object proto,
RpcMethodInfo rpcMethodInfo) |
Object |
GzipCompress.uncompressInput(byte[] bytes,
RpcMethodInfo rpcMethodInfo) |
Object |
Compress.uncompressInput(byte[] bytes,
RpcMethodInfo rpcMethodInfo) |
Object |
ZlibCompress.uncompressInput(byte[] bytes,
RpcMethodInfo rpcMethodInfo) |
Object |
NoneCompress.uncompressInput(byte[] bytes,
RpcMethodInfo rpcMethodInfo) |
Object |
SnappyCompress.uncompressInput(byte[] bytes,
RpcMethodInfo rpcMethodInfo) |
Object |
GzipCompress.uncompressInput(io.netty.buffer.ByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo) |
Object |
Compress.uncompressInput(io.netty.buffer.ByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo)
server端解压缩并decode request
|
Object |
ZlibCompress.uncompressInput(io.netty.buffer.ByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo) |
Object |
NoneCompress.uncompressInput(io.netty.buffer.ByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo) |
Object |
SnappyCompress.uncompressInput(io.netty.buffer.ByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo) |
Object |
GzipCompress.uncompressInput(DynamicCompositeByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo) |
Object |
Compress.uncompressInput(DynamicCompositeByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo) |
Object |
ZlibCompress.uncompressInput(DynamicCompositeByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo) |
Object |
NoneCompress.uncompressInput(DynamicCompositeByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo) |
Object |
SnappyCompress.uncompressInput(DynamicCompositeByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo) |
Object |
GzipCompress.uncompressOutput(byte[] bytes,
RpcMethodInfo rpcMethodInfo) |
Object |
Compress.uncompressOutput(byte[] bytes,
RpcMethodInfo rpcMethodInfo) |
Object |
ZlibCompress.uncompressOutput(byte[] bytes,
RpcMethodInfo rpcMethodInfo) |
Object |
NoneCompress.uncompressOutput(byte[] bytes,
RpcMethodInfo rpcMethodInfo) |
Object |
SnappyCompress.uncompressOutput(byte[] bytes,
RpcMethodInfo rpcMethodInfo) |
Object |
GzipCompress.uncompressOutput(io.netty.buffer.ByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo) |
Object |
Compress.uncompressOutput(io.netty.buffer.ByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo)
client端解压缩并反序列化response
|
Object |
ZlibCompress.uncompressOutput(io.netty.buffer.ByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo) |
Object |
NoneCompress.uncompressOutput(io.netty.buffer.ByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo) |
Object |
SnappyCompress.uncompressOutput(io.netty.buffer.ByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo) |
Object |
GzipCompress.uncompressOutput(DynamicCompositeByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo) |
Object |
Compress.uncompressOutput(DynamicCompositeByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo) |
Object |
ZlibCompress.uncompressOutput(DynamicCompositeByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo) |
Object |
NoneCompress.uncompressOutput(DynamicCompositeByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo) |
Object |
SnappyCompress.uncompressOutput(DynamicCompositeByteBuf byteBuf,
RpcMethodInfo rpcMethodInfo) |
| Modifier and Type | Method and Description |
|---|---|
RpcMethodInfo |
Request.getRpcMethodInfo() |
RpcMethodInfo |
Response.getRpcMethodInfo() |
| Modifier and Type | Method and Description |
|---|---|
void |
Request.setRpcMethodInfo(RpcMethodInfo rpcMethodInfo) |
void |
Response.setRpcMethodInfo(RpcMethodInfo rpcMethodInfo) |
| Modifier and Type | Method and Description |
|---|---|
byte[] |
HttpRpcProtocol.encodeBody(int protocolType,
String encoding,
Object body,
RpcMethodInfo rpcMethodInfo) |
Object |
HttpRpcProtocol.parseHttpResponse(Object body,
RpcMethodInfo rpcMethodInfo) |
Object[] |
HttpRpcProtocol.parseRequestParam(int protocolType,
Object body,
RpcMethodInfo rpcMethodInfo) |
| Modifier and Type | Method and Description |
|---|---|
Object |
NSHeadProtobufProtocol.decodeBody(io.netty.buffer.ByteBuf bodyBuf,
RpcMethodInfo rpcMethodInfo) |
Object |
NSHeadJsonProtocol.decodeBody(io.netty.buffer.ByteBuf bodyBuf,
RpcMethodInfo rpcMethodInfo) |
abstract Object |
NSHeadRpcProtocol.decodeBody(io.netty.buffer.ByteBuf bodyBuf,
RpcMethodInfo rpcMethodInfo) |
byte[] |
NSHeadProtobufProtocol.encodeBody(Object body,
RpcMethodInfo rpcMethodInfo) |
byte[] |
NSHeadJsonProtocol.encodeBody(Object body,
RpcMethodInfo rpcMethodInfo) |
abstract byte[] |
NSHeadRpcProtocol.encodeBody(Object body,
RpcMethodInfo rpcMethodInfo) |
| Modifier and Type | Method and Description |
|---|---|
io.netty.buffer.ByteBuf |
DefaultServerPushProtocol.encodeRequestBody(Request request,
RpcMethodInfo rpcMethodInfo) |
io.netty.buffer.ByteBuf |
DefaultServerPushProtocol.encodeResponseBody(Object result,
RpcMethodInfo rpcMethodInfo) |
| Modifier and Type | Method and Description |
|---|---|
RpcMethodInfo |
ServiceManager.getService(String serviceMethodName) |
RpcMethodInfo |
ServiceManager.getService(String serviceName,
String methodName) |
| Modifier and Type | Method and Description |
|---|---|
Map<String,RpcMethodInfo> |
BrpcPushProxy.getRpcMethodMap() |
Map<String,RpcMethodInfo> |
ServiceManager.getServiceMap() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
ServiceManager.registerService(RpcMethodInfo methodInfo) |
Copyright © 2022 Baidu, Inc.. All rights reserved.