Package | Description |
---|---|
org.apache.avro.ipc |
Support for inter-process calls.
|
org.apache.avro.ipc.generic | |
org.apache.avro.ipc.reflect | |
org.apache.avro.ipc.specific |
Modifier and Type | Class and Description |
---|---|
class |
DatagramTransceiver
A datagram-based
Transceiver implementation. |
class |
HttpTransceiver
An HTTP-based
Transceiver implementation. |
class |
LocalTransceiver
Implementation of IPC that remains in process.
|
class |
NettyTransceiver
A Netty-based
Transceiver implementation. |
class |
SaslSocketTransceiver
A
Transceiver that uses javax.security.sasl for
authentication and encryption. |
class |
SocketTransceiver
Deprecated.
use
SaslSocketTransceiver instead. |
Modifier and Type | Method and Description |
---|---|
static Transceiver |
Ipc.createTransceiver(URI uri)
Create a client
Transceiver connecting to the provided URI. |
Transceiver |
Requestor.getTransceiver() |
protected Transceiver |
SaslSocketServer.getTransceiver(SocketChannel channel) |
protected Transceiver |
SocketServer.getTransceiver(SocketChannel channel)
Deprecated.
Creates an appropriate
Transceiver for this server. |
Modifier and Type | Method and Description |
---|---|
List<ByteBuffer> |
Responder.respond(List<ByteBuffer> buffers,
Transceiver connection)
Called by a server to deserialize a request, compute and serialize a
response or error.
|
Constructor and Description |
---|
Requestor(Protocol local,
Transceiver transceiver) |
Constructor and Description |
---|
GenericRequestor(Protocol protocol,
Transceiver transceiver) |
GenericRequestor(Protocol protocol,
Transceiver transceiver,
GenericData data) |
Modifier and Type | Method and Description |
---|---|
static <T> T |
ReflectRequestor.getClient(Class<T> iface,
Transceiver transciever)
Create a proxy instance whose methods invoke RPCs.
|
static <T> T |
ReflectRequestor.getClient(Class<T> iface,
Transceiver transciever,
ReflectData reflectData)
Create a proxy instance whose methods invoke RPCs.
|
Constructor and Description |
---|
ReflectRequestor(Class<?> iface,
Transceiver transceiver) |
ReflectRequestor(Class<?> iface,
Transceiver transceiver,
ReflectData data) |
ReflectRequestor(Protocol protocol,
Transceiver transceiver) |
ReflectRequestor(Protocol protocol,
Transceiver transceiver,
ReflectData data) |
Modifier and Type | Method and Description |
---|---|
static <T> T |
SpecificRequestor.getClient(Class<T> iface,
Transceiver transciever)
Create a proxy instance whose methods invoke RPCs.
|
static <T> T |
SpecificRequestor.getClient(Class<T> iface,
Transceiver transciever,
SpecificData data)
Create a proxy instance whose methods invoke RPCs.
|
Constructor and Description |
---|
SpecificRequestor(Class<?> iface,
Transceiver transceiver) |
SpecificRequestor(Class<?> iface,
Transceiver transceiver,
SpecificData data) |
SpecificRequestor(Protocol protocol,
Transceiver transceiver) |
SpecificRequestor(Protocol protocol,
Transceiver transceiver,
SpecificData data) |
Copyright © 2009–2016 The Apache Software Foundation. All rights reserved.