Apache REEF  0.16.0
Retainable Evaluator Execution Framework
Public Member Functions | Properties | List of all members
Org.Apache.REEF.Wake.Remote.IRemoteManager< T > Interface Template Reference

Inherits Org.Apache.REEF.Wake.IStage.

Inherited by Org.Apache.REEF.Wake.Remote.Impl.DefaultRemoteManager< T >, and Org.Apache.REEF.Wake.Remote.Impl.StreamingRemoteManager< T >.

Public Member Functions

IObserver< T > GetRemoteObserver (RemoteEventEndPoint< T > dest)
 
IObserver< T > GetRemoteObserver (IPEndPoint remoteEndpoint)
 
IRemoteObserver< T > GetUnmanagedRemoteObserver (RemoteEventEndPoint< T > dest)
 
IRemoteObserver< T > GetUnmanagedObserver (IPEndPoint remoteEndpoint)
 
IDisposable RegisterObserver (RemoteEventEndPoint< T > source, IObserver< T > theObserver)
 
IDisposable RegisterObserver (IPEndPoint remoteEndpoint, IObserver< T > theObserver)
 
IDisposable RegisterObserver (IObserver< IRemoteMessage< T >> theObserver)
 

Properties

IRemoteIdentifier Identifier [get]
 
IPEndPoint LocalEndpoint [get]
 

Member Function Documentation

◆ GetRemoteObserver() [1/2]

IObserver<T> Org.Apache.REEF.Wake.Remote.IRemoteManager< T >.GetRemoteObserver ( RemoteEventEndPoint< T >  dest)

◆ GetRemoteObserver() [2/2]

IObserver<T> Org.Apache.REEF.Wake.Remote.IRemoteManager< T >.GetRemoteObserver ( IPEndPoint  remoteEndpoint)

◆ GetUnmanagedObserver()

IRemoteObserver<T> Org.Apache.REEF.Wake.Remote.IRemoteManager< T >.GetUnmanagedObserver ( IPEndPoint  remoteEndpoint)

◆ GetUnmanagedRemoteObserver()

IRemoteObserver<T> Org.Apache.REEF.Wake.Remote.IRemoteManager< T >.GetUnmanagedRemoteObserver ( RemoteEventEndPoint< T >  dest)

◆ RegisterObserver() [1/3]

IDisposable Org.Apache.REEF.Wake.Remote.IRemoteManager< T >.RegisterObserver ( RemoteEventEndPoint< T >  source,
IObserver< T >  theObserver 
)

◆ RegisterObserver() [2/3]

IDisposable Org.Apache.REEF.Wake.Remote.IRemoteManager< T >.RegisterObserver ( IPEndPoint  remoteEndpoint,
IObserver< T >  theObserver 
)

◆ RegisterObserver() [3/3]

IDisposable Org.Apache.REEF.Wake.Remote.IRemoteManager< T >.RegisterObserver ( IObserver< IRemoteMessage< T >>  theObserver)

Property Documentation

◆ Identifier

◆ LocalEndpoint

IPEndPoint Org.Apache.REEF.Wake.Remote.IRemoteManager< T >.LocalEndpoint
get

The documentation for this interface was generated from the following file: