# Index

C D E G I J L N O R S T U W
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.

C D E G I J L N O R S T U W
All Classes and Interfaces|All Packages|Constant Field Values