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(int localAddressCacheMaximumSize, long localAddressCacheTTL)

Method Summary

Modifier and Type	Method and Description
void	actorDeactivated(RemoteReference remoteReference)
Task<Integer>	canActivate(String interfaceName)
Task	connect(HandlerContext ctx, Object param)
List<NodeAddress>	getAllNodes()
NodeAddress	getConsistentHashOwner(String key) Uses consistent hashing to determine the "owner" of a certain key.
boolean	getFlushPlacementGroupCache()
NodeAddress	getNodeAddress()
Task<String>	getPlacementGroup()
List<NodeAddress>	getServerNodes()
Set<String>	getTargetPlacementGroups()
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	pulse()
Task<Void>	remove(RemoteReference<?> remoteReference)
void	setClusterPeer(ClusterPeer clusterPeer)
Hosting	setFlushPlacementGroupCache(boolean flushPlacementCache)
void	setNodeSelector(NodeSelectorExtension nodeSelector)
void	setNodeType(NodeCapabilities.NodeTypeEnum nodeType)
void	setStage(Stage stage)
void	setTargetPlacementGroups(Set<String> targetPlacementGroups)
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(int localAddressCacheMaximumSize,
               long localAddressCacheTTL)

Method Detail

getTimeToWaitForServersMillis

public long getTimeToWaitForServersMillis()

setTimeToWaitForServersMillis

public void setTimeToWaitForServersMillis(long timeToWaitForServersMillis)

setStage

public void setStage(Stage stage)

setNodeSelector

public void setNodeSelector(NodeSelectorExtension nodeSelector)

getTargetPlacementGroups

public Set<String> getTargetPlacementGroups()

setTargetPlacementGroups

public void setTargetPlacementGroups(Set<String> targetPlacementGroups)

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()

getPlacementGroup

public Task<String> getPlacementGroup()

Specified by:

getPlacementGroup in interface NodeCapabilities

canActivate

public Task<Integer> canActivate(String interfaceName)

Specified by:

canActivate in interface NodeCapabilities

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

remove

public Task<Void> remove(RemoteReference<?> remoteReference)

Specified by:

remove in interface NodeCapabilities

setClusterPeer

public void setClusterPeer(ClusterPeer clusterPeer)

start

public Task<Void> start()

Specified by:

start in interface Startable

getFlushPlacementGroupCache

public boolean getFlushPlacementGroupCache()

setFlushPlacementGroupCache

public Hosting setFlushPlacementGroupCache(boolean flushPlacementCache)

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

pulse

public void pulse()

writeInvocation

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