Package | Description |
---|---|
org.apache.reef.io.network |
TODO: Document.
|
org.apache.reef.io.network.impl |
TODO: Document.
|
org.apache.reef.wake.remote.transport |
Wake's remote transportation.
|
org.apache.reef.wake.remote.transport.netty |
Netty-based remote transport implementation.
|
Modifier and Type | Method and Description |
---|---|
<T> ConnectionFactory<T> |
NetworkConnectionService.registerConnectionFactory(Identifier connectionFactoryId,
Codec<T> codec,
EventHandler<Message<T>> eventHandler,
LinkListener<Message<T>> linkListener,
Identifier localEndPointId)
Registers an instance of ConnectionFactory corresponding to the connectionFactoryId.
|
Modifier and Type | Method and Description |
---|---|
<T> ConnectionFactory<T> |
NetworkConnectionServiceImpl.registerConnectionFactory(Identifier connectionFactoryId,
Codec<T> codec,
EventHandler<Message<T>> eventHandler,
LinkListener<Message<T>> linkListener,
Identifier localEndPointId) |
Modifier and Type | Method and Description |
---|---|
<T> Link<T> |
Transport.open(SocketAddress remoteAddr,
Encoder<? super T> encoder,
LinkListener<? super T> listener)
Returns a link for the remote address if cached; otherwise opens, caches and returns.
|
Modifier and Type | Class and Description |
---|---|
class |
LoggingLinkListener<T>
Link listener that logs whether the message is sent successfully.
|
Modifier and Type | Method and Description |
---|---|
<T> Link<T> |
NettyMessagingTransport.open(SocketAddress remoteAddr,
Encoder<? super T> encoder,
LinkListener<? super T> listener)
Returns a link for the remote address if cached; otherwise opens, caches and returns.
|
Constructor and Description |
---|
NettyLink(io.netty.channel.Channel channel,
Encoder<? super T> encoder,
LinkListener<? super T> listener)
Constructs a link.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.