cloud.orbit.actors.runtime

Class Hosting

java.lang.Object

cloud.orbit.actors.runtime.Hosting

All Implemented Interfaces:

ActorObserver, ActorExtension, PipelineExtension, Handler, NodeCapabilities, Startable

public class Hosting
extends Object
implements NodeCapabilities, Startable, PipelineExtension

Nested Class Summary

Nested classes/interfaces inherited from interface cloud.orbit.actors.runtime.NodeCapabilities

NodeCapabilities.NodeState, NodeCapabilities.NodeTypeEnum

Field Summary

Fields inherited from interface cloud.orbit.actors.runtime.NodeCapabilities

actorSupported_no, actorSupported_noneSupported, actorSupported_yes

Constructor Summary

Constructors

Constructor and Description
Hosting()

Method Summary

Modifier and Type	Method and Description
void	actorDeactivated(RemoteReference remoteReference)
Task<Integer>	canActivate(String interfaceName) Asked a single time or infrequently to find out if this node knows and is able to serve this kind of actor.
void	cleanup()
Task	connect(HandlerContext ctx, Object param)
List<NodeAddress>	getAllNodes()
NodeAddress	getConsistentHashOwner(String key) Uses consistent hashing to determine the "owner" of a certain key.
int	getMaxLocalAddressCacheCount()
NodeAddress	getNodeAddress()
List<NodeAddress>	getServerNodes()
long	getTimeToWaitForServersMillis()
boolean	isConsistentHashOwner(String key) Uses consistent hashing to determine this node is the "owner" of a certain key.
Task<NodeAddress>	locateActor(RemoteReference reference, boolean forceActivation)
Task<Void>	moved(RemoteReference remoteReference, NodeAddress oldAddress, NodeAddress newAddress)
Task<Void>	nodeModeChanged(NodeAddress nodeAddress, NodeCapabilities.NodeState newState)
Task<?>	notifyStateChange()
void	onActive(HandlerContext ctx)
void	onRead(HandlerContext ctx, Object msg)
void	setClusterPeer(ClusterPeer clusterPeer)
void	setMaxLocalAddressCacheCount(int maxLocalAddressCacheCount)
void	setNodeType(NodeCapabilities.NodeTypeEnum nodeType)
void	setStage(Stage stage)
void	setTimeToWaitForServersMillis(long timeToWaitForServersMillis)
Task<Void>	start()
Task	write(HandlerContext ctx, Object msg)
protected Task<?>	writeInvocation(HandlerContext ctx, Invocation invocation)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface cloud.orbit.actors.ActorObserver

getObserverReference, ping

Methods inherited from interface cloud.orbit.actors.extensions.PipelineExtension

close, disconnect, getAfterHandlerName, getBeforeHandlerName, getName, onEventTriggered, onExceptionCaught, onInactive, onRegistered

Methods inherited from interface cloud.orbit.lifecycle.Startable

stop

Constructor Detail

Hosting

public Hosting()

Method Detail

getTimeToWaitForServersMillis

public long getTimeToWaitForServersMillis()

setTimeToWaitForServersMillis

public void setTimeToWaitForServersMillis(long timeToWaitForServersMillis)

setStage

public void setStage(Stage stage)

setNodeType

public void setNodeType(NodeCapabilities.NodeTypeEnum nodeType)

getAllNodes

public List<NodeAddress> getAllNodes()

getServerNodes

public List<NodeAddress> getServerNodes()

notifyStateChange

public Task<?> notifyStateChange()

getNodeAddress

public NodeAddress getNodeAddress()

canActivate

public Task<Integer> canActivate(String interfaceName)

Description copied from interface: NodeCapabilities

Asked a single time or infrequently to find out if this node knows and is able to serve this kind of actor.

Specified by:

canActivate in interface NodeCapabilities

Returns:

#actorSupported_yes, #actorSupported_no, or #actorSupported_noneSupported

nodeModeChanged

public Task<Void> nodeModeChanged(NodeAddress nodeAddress,
                                  NodeCapabilities.NodeState newState)

Specified by:

nodeModeChanged in interface NodeCapabilities

moved

public Task<Void> moved(RemoteReference remoteReference,
                        NodeAddress oldAddress,
                        NodeAddress newAddress)

Specified by:

moved in interface NodeCapabilities

setClusterPeer

public void setClusterPeer(ClusterPeer clusterPeer)

start

public Task<Void> start()

Specified by:

start in interface Startable

locateActor

public Task<NodeAddress> locateActor(RemoteReference reference,
                                     boolean forceActivation)

actorDeactivated

public void actorDeactivated(RemoteReference remoteReference)

getConsistentHashOwner

public NodeAddress getConsistentHashOwner(String key)

Uses consistent hashing to determine the "owner" of a certain key.

Parameters:

key -

Returns:

the NodeAddress of the node that's supposed to own the key.

isConsistentHashOwner

public boolean isConsistentHashOwner(String key)

Uses consistent hashing to determine this node is the "owner" of a certain key.

Parameters:

key -

Returns:

true if this node is assigned to "own" the key.

connect

public Task connect(HandlerContext ctx,
                    Object param)
             throws Exception

Specified by:

connect in interface PipelineExtension

Specified by:

connect in interface Handler

Throws:

Exception

onActive

public void onActive(HandlerContext ctx)
              throws Exception

Specified by:

onActive in interface PipelineExtension

Specified by:

onActive in interface Handler

Throws:

Exception

onRead

public void onRead(HandlerContext ctx,
                   Object msg)
            throws Exception

Specified by:

onRead in interface PipelineExtension

Specified by:

onRead in interface Handler

Throws:

Exception

write

public Task write(HandlerContext ctx,
                  Object msg)
           throws Exception

Specified by:

write in interface PipelineExtension

Specified by:

write in interface Handler

Throws:

Exception

writeInvocation

protected Task<?> writeInvocation(HandlerContext ctx,
                                  Invocation invocation)

cleanup

public void cleanup()

getMaxLocalAddressCacheCount

public int getMaxLocalAddressCacheCount()

setMaxLocalAddressCacheCount

public void setMaxLocalAddressCacheCount(int maxLocalAddressCacheCount)