Index
All Classes and Interfaces|All Packages|Constant Field Values
C
- callback - Variable in class org.apache.avro.ipc.netty.NettyTransceiver.WriteFutureListener
- channelInactive(ChannelHandlerContext) - Method in class org.apache.avro.ipc.netty.NettyTransceiver.NettyClientAvroHandler
- channelRead0(ChannelHandlerContext, NettyTransportCodec.NettyDataPack) - Method in class org.apache.avro.ipc.netty.NettyTransceiver.NettyClientAvroHandler
- close() - Method in class org.apache.avro.ipc.netty.NettyServer
- close() - Method in class org.apache.avro.ipc.netty.NettyTransceiver
-
Closes this transceiver and disconnects from the remote peer.
- close(boolean) - Method in class org.apache.avro.ipc.netty.NettyTransceiver
-
Closes this transceiver and disconnects from the remote peer.
- createNettyClientAvroHandler() - Method in class org.apache.avro.ipc.netty.NettyTransceiver
-
Creates a Netty ChannelUpstreamHandler for handling events on the Netty client channel.
D
- decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class org.apache.avro.ipc.netty.NettyTransportCodec.NettyFrameDecoder
-
decode buffer to NettyDataPack
- DEFAULT_CONNECTION_TIMEOUT_MILLIS - Static variable in class org.apache.avro.ipc.netty.NettyTransceiver
-
If not specified, the default connection timeout will be used (60 sec).
- DEFAULT_TCP_NODELAY_VALUE - Static variable in class org.apache.avro.ipc.netty.NettyTransceiver
E
- encode(ChannelHandlerContext, NettyTransportCodec.NettyDataPack, List<Object>) - Method in class org.apache.avro.ipc.netty.NettyTransportCodec.NettyFrameEncoder
-
encode msg to ChannelBuffer
- exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.apache.avro.ipc.netty.NettyTransceiver.NettyClientAvroHandler
G
- getDatas() - Method in class org.apache.avro.ipc.netty.NettyTransportCodec.NettyDataPack
- getNumActiveConnections() - Method in class org.apache.avro.ipc.netty.NettyServer
- getPort() - Method in class org.apache.avro.ipc.netty.NettyServer
- getRemote() - Method in class org.apache.avro.ipc.netty.NettyTransceiver
- getRemoteName() - Method in class org.apache.avro.ipc.netty.NettyTransceiver
- getSerial() - Method in class org.apache.avro.ipc.netty.NettyTransportCodec.NettyDataPack
I
- isConnected() - Method in class org.apache.avro.ipc.netty.NettyTransceiver
J
- join() - Method in class org.apache.avro.ipc.netty.NettyServer
L
- lockChannel() - Method in class org.apache.avro.ipc.netty.NettyTransceiver
-
Netty channels are thread-safe, so there is no need to acquire locks.
N
- NETTY_CONNECT_TIMEOUT_OPTION - Static variable in class org.apache.avro.ipc.netty.NettyTransceiver
- NETTY_KEEPALIVE_OPTION - Static variable in class org.apache.avro.ipc.netty.NettyTransceiver
- NETTY_TCP_NODELAY_OPTION - Static variable in class org.apache.avro.ipc.netty.NettyTransceiver
- NettyClientAvroHandler() - Constructor for class org.apache.avro.ipc.netty.NettyTransceiver.NettyClientAvroHandler
- NettyDataPack() - Constructor for class org.apache.avro.ipc.netty.NettyTransportCodec.NettyDataPack
- NettyDataPack(int, List<ByteBuffer>) - Constructor for class org.apache.avro.ipc.netty.NettyTransportCodec.NettyDataPack
- NettyFrameDecoder() - Constructor for class org.apache.avro.ipc.netty.NettyTransportCodec.NettyFrameDecoder
- NettyFrameEncoder() - Constructor for class org.apache.avro.ipc.netty.NettyTransportCodec.NettyFrameEncoder
- NettyServer - Class in org.apache.avro.ipc.netty
-
A Netty-based RPC
Server
implementation. - NettyServer(Responder, InetSocketAddress) - Constructor for class org.apache.avro.ipc.netty.NettyServer
- NettyServer(Responder, InetSocketAddress, Consumer<SocketChannel>) - Constructor for class org.apache.avro.ipc.netty.NettyServer
- NettyServer(Responder, InetSocketAddress, Consumer<SocketChannel>, Consumer<ServerBootstrap>) - Constructor for class org.apache.avro.ipc.netty.NettyServer
- NettyServer(Responder, InetSocketAddress, Consumer<SocketChannel>, Consumer<ServerBootstrap>, EventLoopGroup, EventLoopGroup, EventLoopGroup) - Constructor for class org.apache.avro.ipc.netty.NettyServer
- NettyTransceiver - Class in org.apache.avro.ipc.netty
-
A Netty-based
Transceiver
implementation. - NettyTransceiver(InetSocketAddress) - Constructor for class org.apache.avro.ipc.netty.NettyTransceiver
-
Creates a NettyTransceiver, and attempts to connect to the given address.
- NettyTransceiver(InetSocketAddress, Integer) - Constructor for class org.apache.avro.ipc.netty.NettyTransceiver
-
Creates a NettyTransceiver, and attempts to connect to the given address.
- NettyTransceiver(InetSocketAddress, Integer, Consumer<SocketChannel>) - Constructor for class org.apache.avro.ipc.netty.NettyTransceiver
-
Creates a NettyTransceiver, and attempts to connect to the given address.
- NettyTransceiver(InetSocketAddress, Integer, Consumer<SocketChannel>, Consumer<Bootstrap>) - Constructor for class org.apache.avro.ipc.netty.NettyTransceiver
-
Creates a NettyTransceiver, and attempts to connect to the given address.
- NettyTransceiver(InetSocketAddress, Consumer<SocketChannel>) - Constructor for class org.apache.avro.ipc.netty.NettyTransceiver
-
Creates a NettyTransceiver, and attempts to connect to the given address.
- NettyTransceiver.NettyClientAvroHandler - Class in org.apache.avro.ipc.netty
-
Avro client handler for the Netty transport
- NettyTransceiver.NettyTransceiverThreadFactory - Class in org.apache.avro.ipc.netty
-
Creates threads with unique names based on a specified name prefix.
- NettyTransceiver.WriteFutureListener - Class in org.apache.avro.ipc.netty
-
A ChannelFutureListener for channel write operations that notifies a
Callback
if an error occurs while writing to the channel. - NettyTransceiverThreadFactory(String) - Constructor for class org.apache.avro.ipc.netty.NettyTransceiver.NettyTransceiverThreadFactory
-
Creates a NettyTransceiverThreadFactory that creates threads with the specified name.
- NettyTransportCodec - Class in org.apache.avro.ipc.netty
-
Data structure, encoder and decoder classes for the Netty transport.
- NettyTransportCodec() - Constructor for class org.apache.avro.ipc.netty.NettyTransportCodec
- NettyTransportCodec.NettyDataPack - Class in org.apache.avro.ipc.netty
-
Transport protocol data structure when using Netty.
- NettyTransportCodec.NettyFrameDecoder - Class in org.apache.avro.ipc.netty
-
Protocol decoder which converts Netty's ChannelBuffer to NettyDataPack which contains a List<ByteBuffer> needed by Avro Responder.
- NettyTransportCodec.NettyFrameEncoder - Class in org.apache.avro.ipc.netty
-
Protocol encoder which converts NettyDataPack which contains the Responder's output List<ByteBuffer> to ChannelBuffer needed by Netty.
- newThread(Runnable) - Method in class org.apache.avro.ipc.netty.NettyTransceiver.NettyTransceiverThreadFactory
O
- operationComplete(ChannelFuture) - Method in class org.apache.avro.ipc.netty.NettyTransceiver.WriteFutureListener
- org.apache.avro.ipc.netty - package org.apache.avro.ipc.netty
R
- readBuffers() - Method in class org.apache.avro.ipc.netty.NettyTransceiver
S
- setDatas(List<ByteBuffer>) - Method in class org.apache.avro.ipc.netty.NettyTransportCodec.NettyDataPack
- setRemote(Protocol) - Method in class org.apache.avro.ipc.netty.NettyTransceiver
- setSerial(int) - Method in class org.apache.avro.ipc.netty.NettyTransportCodec.NettyDataPack
- start() - Method in class org.apache.avro.ipc.netty.NettyServer
T
- transceive(List<ByteBuffer>) - Method in class org.apache.avro.ipc.netty.NettyTransceiver
-
Override as non-synchronized method because the method is thread safe.
- transceive(List<ByteBuffer>, Callback<List<ByteBuffer>>) - Method in class org.apache.avro.ipc.netty.NettyTransceiver
U
- unlockChannel() - Method in class org.apache.avro.ipc.netty.NettyTransceiver
-
Netty channels are thread-safe, so there is no need to acquire locks.
W
- writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.netty.NettyTransceiver
- WriteFutureListener(Callback<List<ByteBuffer>>) - Constructor for class org.apache.avro.ipc.netty.NettyTransceiver.WriteFutureListener
-
Creates a WriteFutureListener that notifies the given callback if an error occurs writing data to the channel.
All Classes and Interfaces|All Packages|Constant Field Values