| 限定符和类型 | 方法和说明 |
|---|---|
CopyOnWriteArrayList<BrpcChannelGroup> |
RpcClient.getHealthyInstances() |
| 限定符和类型 | 类和说明 |
|---|---|
class |
AbstractBrpcChannelGroup |
class |
BrpcPooledChannel
BrpcPooledChannelGroup class keeps fixed connections with one server
Created by wenweihu86 on 2017/9/29.
|
class |
BrpcShortChannel
BrpcShortChannel build single & short connection with server
and channel will be closed by brpc after communication with server
|
class |
BrpcSingleChannel
BrpcSingleChannel class keeps single persistent connection with one server
|
| 限定符和类型 | 方法和说明 |
|---|---|
static BrpcChannelGroup |
BrpcChannelFactory.createChannelGroup(String ip,
int port,
RpcClient rpcClient) |
| 限定符和类型 | 方法和说明 |
|---|---|
CopyOnWriteArrayList<BrpcChannelGroup> |
EndPointProcessor.getHealthyInstances() |
CopyOnWriteArrayList<BrpcChannelGroup> |
EnhancedEndPointProcessor.getHealthyInstances() |
CopyOnWriteArrayList<BrpcChannelGroup> |
BasicEndPointProcessor.getHealthyInstances() |
CopyOnWriteArrayList<BrpcChannelGroup> |
EndPointProcessor.getUnHealthyInstances() |
CopyOnWriteArrayList<BrpcChannelGroup> |
EnhancedEndPointProcessor.getUnHealthyInstances() |
CopyOnWriteArrayList<BrpcChannelGroup> |
BasicEndPointProcessor.getUnHealthyInstances() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
EndPointProcessor.updateUnHealthyInstances(List<BrpcChannelGroup> channelGroups) |
void |
EnhancedEndPointProcessor.updateUnHealthyInstances(List<BrpcChannelGroup> channelGroups) |
void |
BasicEndPointProcessor.updateUnHealthyInstances(List<BrpcChannelGroup> channelGroups) |
| 限定符和类型 | 方法和说明 |
|---|---|
protected BrpcChannelGroup |
FairStrategy.fairSelect(com.baidu.brpc.client.loadbalance.FairStrategy.Node root) |
protected BrpcChannelGroup |
FairStrategy.randomSelect(CopyOnWriteArrayList<BrpcChannelGroup> instances) |
BrpcChannelGroup |
WeightStrategy.selectInstance(CopyOnWriteArrayList<BrpcChannelGroup> instances) |
BrpcChannelGroup |
RandomStrategy.selectInstance(CopyOnWriteArrayList<BrpcChannelGroup> instances) |
BrpcChannelGroup |
LoadBalanceStrategy.selectInstance(CopyOnWriteArrayList<BrpcChannelGroup> instances) |
BrpcChannelGroup |
RoundRobinStrategy.selectInstance(CopyOnWriteArrayList<BrpcChannelGroup> instances) |
BrpcChannelGroup |
FairStrategy.selectInstance(CopyOnWriteArrayList<BrpcChannelGroup> instances) |
| 限定符和类型 | 方法和说明 |
|---|---|
protected int |
FairStrategy.calculateWeight(BrpcChannelGroup group,
int timeOut)
Calculate the weight of a rpc server
|
| 限定符和类型 | 方法和说明 |
|---|---|
void |
FairStrategy.markInvalidInstance(List<BrpcChannelGroup> instances)
Since the weight tree will update by a period of time, so if there's any invalid instance,
the business should notify the fair strategy.
|
protected BrpcChannelGroup |
FairStrategy.randomSelect(CopyOnWriteArrayList<BrpcChannelGroup> instances) |
BrpcChannelGroup |
WeightStrategy.selectInstance(CopyOnWriteArrayList<BrpcChannelGroup> instances) |
BrpcChannelGroup |
RandomStrategy.selectInstance(CopyOnWriteArrayList<BrpcChannelGroup> instances) |
BrpcChannelGroup |
LoadBalanceStrategy.selectInstance(CopyOnWriteArrayList<BrpcChannelGroup> instances) |
BrpcChannelGroup |
RoundRobinStrategy.selectInstance(CopyOnWriteArrayList<BrpcChannelGroup> instances) |
BrpcChannelGroup |
FairStrategy.selectInstance(CopyOnWriteArrayList<BrpcChannelGroup> instances) |
| 构造器和说明 |
|---|
ChannelPooledObjectFactory(BrpcChannelGroup channelGroup,
String ip,
int port) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
AbstractProtocol.beforeRequestSent(Request request,
RpcClient rpcClient,
BrpcChannelGroup channelGroup) |
void |
Protocol.beforeRequestSent(Request request,
RpcClient rpcClient,
BrpcChannelGroup channelGroup)
do something if needed before client send request
|
| 限定符和类型 | 方法和说明 |
|---|---|
void |
HttpRpcProtocol.beforeRequestSent(Request request,
RpcClient rpcClient,
BrpcChannelGroup channelGroup) |
Copyright © 2019 Baidu, Inc.. All rights reserved.