com.baidu.brpc.client.channel

Interface BrpcChannel

All Known Implementing Classes:

AbstractBrpcChannel, BrpcPooledChannel, BrpcShortChannel, BrpcSingleChannel

public interface BrpcChannel

Method Summary

Modifier and Type	Method and Description
void	close()
io.netty.channel.Channel	connect()
int	getActiveConnectionNum()
io.netty.channel.Channel	getChannel()
int	getCurrentMaxConnection()
long	getFailedNum()
int	getIdleConnectionNum()
Queue<Integer>	getLatencyWindow()
Protocol	getProtocol()
ServiceInstance	getServiceInstance()
void	incFailedNum()
void	removeChannel(io.netty.channel.Channel channel)
void	returnChannel(io.netty.channel.Channel channel)
void	updateChannel(io.netty.channel.Channel channel)
void	updateLatency(int latency)
void	updateLatencyWithReadTimeOut()
void	updateMaxConnection(int num)

Method Detail

getChannel

io.netty.channel.Channel getChannel()
                             throws Exception,
                                    NoSuchElementException,
                                    IllegalStateException

Throws:

Exception

NoSuchElementException

IllegalStateException

returnChannel

void returnChannel(io.netty.channel.Channel channel)

removeChannel

void removeChannel(io.netty.channel.Channel channel)

updateChannel

void updateChannel(io.netty.channel.Channel channel)

close

void close()

connect

io.netty.channel.Channel connect()

getServiceInstance

ServiceInstance getServiceInstance()

getFailedNum

long getFailedNum()

incFailedNum

void incFailedNum()

getLatencyWindow

Queue<Integer> getLatencyWindow()

updateLatency

void updateLatency(int latency)

updateLatencyWithReadTimeOut

void updateLatencyWithReadTimeOut()

getProtocol

Protocol getProtocol()

updateMaxConnection

void updateMaxConnection(int num)

getCurrentMaxConnection

int getCurrentMaxConnection()

getActiveConnectionNum

int getActiveConnectionNum()

getIdleConnectionNum

int getIdleConnectionNum()