Apache REEF
0.15.0
Retainable Evaluator Execution Framework
|
Network service used for Reef Task communication. More...
Inherits Org.Apache.REEF.Network.NetworkService.INetworkService< T >.
Public Member Functions | |
NetworkService ([Parameter(typeof(NetworkServiceOptions.NetworkServicePort))] int nsPort, IObserver< NsMessage< T >> messageHandler, IIdentifierFactory idFactory, ICodec< T > codec, INameClient nameClient, ILocalAddressProvider localAddressProvider, IRemoteManagerFactory remoteManagerFactory) | |
Create a new NetworkService. More... | |
IConnection< T > | NewConnection (IIdentifier destinationId) |
Open a new connection to the remote host registered to the name service with the given identifier More... | |
void | Register (IIdentifier id) |
Register the identifier for the NetworkService with the NameService. More... | |
void | Unregister () |
Unregister the identifier for the NetworkService with the NameService. More... | |
void | Dispose () |
Dispose of the NetworkService's resources More... | |
Properties | |
INameClient | NamingClient [get] |
Name client for registering ids More... | |
Properties inherited from Org.Apache.REEF.Network.NetworkService.INetworkService< T > | |
INameClient | NamingClient [get] |
Name client for registering ids More... | |
Network service used for Reef Task communication.
T | The message type |
|
inline |
Create a new NetworkService.
nsPort | The port that the NetworkService will listen on |
messageHandler | The observer to handle incoming messages |
idFactory | The factory used to create IIdentifiers |
codec | The codec used for serialization |
nameClient | |
localAddressProvider | The local address provider |
remoteManagerFactory | Used to instantiate remote manager instances. |
|
inline |
Dispose of the NetworkService's resources
|
inline |
Open a new connection to the remote host registered to the name service with the given identifier
destinationId | The identifier of the remote host |
Implements Org.Apache.REEF.Network.NetworkService.INetworkService< T >.
|
inline |
Register the identifier for the NetworkService with the NameService.
id | The identifier to register |
Implements Org.Apache.REEF.Network.NetworkService.INetworkService< T >.
|
inline |
Unregister the identifier for the NetworkService with the NameService.
Implements Org.Apache.REEF.Network.NetworkService.INetworkService< T >.
|
get |
Name client for registering ids