Uses of Class
ru.pathcreator.pyc.rpc.core.RpcChannel

Packages that use RpcChannel

Package	Description
ru.pathcreator.pyc.rpc.core
ru.pathcreator.pyc.rpc.metrics

Uses of RpcChannel in ru.pathcreator.pyc.rpc.core

Methods in ru.pathcreator.pyc.rpc.core that return RpcChannel

Modifier and Type	Method	Description
RpcChannel	RpcNode.channel(ChannelConfig channelConfig)	Создаёт новый канал и добавляет его в node-owned список каналов.

Methods in ru.pathcreator.pyc.rpc.core with parameters of type RpcChannel

Modifier and Type	Method	Description
Resp	RpcMethod.call(RpcChannel channel, Req request)	Вызывает метод через указанный канал с default timeout канала.
Resp	RpcMethod.call(RpcChannel channel, Req request, long timeout, TimeUnit unit)	Вызывает метод через указанный канал с явным timeout.
default void	RpcChannelListener.onCallFailed(RpcChannel channel, int requestMessageTypeId, long correlationId, RpcException failure)	Вызывается при локальном сбое client-side call.
default void	RpcChannelListener.onCallStarted(RpcChannel channel, int requestMessageTypeId, long correlationId)	Вызывается при старте client-side call.
default void	RpcChannelListener.onCallSucceeded(RpcChannel channel, int requestMessageTypeId, long correlationId)	Вызывается при успешном завершении client-side call.
default void	RpcChannelListener.onCallTimedOut(RpcChannel channel, int requestMessageTypeId, long correlationId, long timeoutNs)	Вызывается при timeout client-side call.
default void	RpcChannelListener.onChannelDown(RpcChannel channel)	Вызывается, когда канал считается down.
default void	RpcChannelListener.onChannelUp(RpcChannel channel)	Вызывается, когда канал считается поднятым.
default void	RpcChannelListener.onDrainFinished(RpcChannel channel)	Вызывается по завершении drain mode.
default void	RpcChannelListener.onDrainStarted(RpcChannel channel)	Вызывается при старте drain mode.
default void	RpcChannelListener.onProtocolHandshakeFailed(RpcChannel channel, RpcException failure)	Вызывается при провале protocol handshake.
default void	RpcChannelListener.onProtocolHandshakeStarted(RpcChannel channel)	Вызывается при старте protocol handshake.
default void	RpcChannelListener.onProtocolHandshakeSucceeded(RpcChannel channel, int remoteVersion, long remoteCapabilities)	Вызывается при успешном protocol handshake.
default void	RpcChannelListener.onReconnectAttempt(RpcChannel channel, ReconnectStrategy strategy)	Вызывается при попытке reconnect/recovery.
default void	RpcChannelListener.onReconnectFailed(RpcChannel channel, ReconnectStrategy strategy, Throwable failure)	Вызывается при неуспешном reconnect/recovery.
default void	RpcChannelListener.onReconnectSucceeded(RpcChannel channel, ReconnectStrategy strategy)	Вызывается при успешном reconnect/recovery.
default void	RpcChannelListener.onRemoteError(RpcChannel channel, int responseMessageTypeId, long correlationId, RpcException failure)	Вызывается при structured remote error от другой стороны.
void	RpcMethod.register(RpcChannel channel, RequestHandler<Req,Resp> handler)	Регистрирует handler этого метода на указанном канале.

Uses of RpcChannel in ru.pathcreator.pyc.rpc.metrics

Methods in ru.pathcreator.pyc.rpc.metrics with parameters of type RpcChannel

Modifier and Type	Method	Description
void	RpcMetricsListener.onCallFailed(RpcChannel channel, int requestMessageTypeId, long correlationId, RpcException failure)
void	RpcMetricsListener.onCallStarted(RpcChannel channel, int requestMessageTypeId, long correlationId)
void	RpcMetricsListener.onCallSucceeded(RpcChannel channel, int requestMessageTypeId, long correlationId)
void	RpcMetricsListener.onCallTimedOut(RpcChannel channel, int requestMessageTypeId, long correlationId, long timeoutNs)
void	RpcMetricsListener.onChannelDown(RpcChannel channel)
void	RpcMetricsListener.onChannelUp(RpcChannel channel)
void	RpcMetricsListener.onDrainFinished(RpcChannel channel)
void	RpcMetricsListener.onDrainStarted(RpcChannel channel)
void	RpcMetricsListener.onProtocolHandshakeFailed(RpcChannel channel, RpcException failure)
void	RpcMetricsListener.onProtocolHandshakeStarted(RpcChannel channel)
void	RpcMetricsListener.onProtocolHandshakeSucceeded(RpcChannel channel, int remoteVersion, long remoteCapabilities)
void	RpcMetricsListener.onReconnectAttempt(RpcChannel channel, ReconnectStrategy strategy)
void	RpcMetricsListener.onReconnectFailed(RpcChannel channel, ReconnectStrategy strategy, Throwable failure)
void	RpcMetricsListener.onReconnectSucceeded(RpcChannel channel, ReconnectStrategy strategy)
void	RpcMetricsListener.onRemoteError(RpcChannel channel, int responseMessageTypeId, long correlationId, RpcException failure)