Module swim.actor

Package swim.actor

Class ActorSpace

java.lang.Object

swim.runtime.AbstractSwimRef

swim.runtime.AbstractTierBinding

swim.actor.ActorSpace

All Implemented Interfaces:

DownlinkFactory, PlaneContext, SwimRef, Space, CellContext, EdgeContext, TierBinding, TierContext, Log

public class ActorSpace
extends AbstractTierBinding
implements EdgeContext, PlaneContext, Space

Field Summary

Fields inherited from class swim.runtime.AbstractTierBinding

CLOSED_PHASE, CLOSED_STATE, CLOSING_STATE, FAILED_STATE, FAILING_STATE, LOADED_PHASE, LOADED_STATE, LOADING_STATE, OPENED_PHASE, OPENED_STATE, OPENING_STATE, PHASE_MASK, PHASE_SHIFT, RECOVERING_STATE, STARTED_PHASE, STARTED_STATE, STARTING_STATE, STATE_MASK, status, STATUS, STOPPING_STATE, UNLOADING_STATE

Constructor Summary

Constructors

Constructor	Description
ActorSpace(EdgeAddress edgeAddress, ActorSpaceDef spaceDef, KernelContext kernel)

Method Summary

Modifier and Type	Method	Description
void	addAgentRoute(String routeName, String pattern, AgentRoute<?> agentRoute)
void	addAgentRoute(String routeName, UriPattern pattern, AgentRoute<?> agentRoute)
void	addAuthenticator(String authenticatorName, Authenticator authenticator)
PolicyDirective<Identity>	authenticate(Credentials credentials)
LinkBinding	bindDownlink(Downlink downlink)
<T> T	bottomEdge(Class<T> edgeClass)
EdgeAddress	cellAddress()
void	close()
void	closeDownlink(LinkBinding link)
protected void	closeLog()
protected void	closePolicy()
protected void	closeStage()
protected void	closeStore()
<A extends Agent> AgentFactory<A>	createAgentFactory(NodeBinding node, Class<? extends A> agentClass)
AgentFactory<?>	createAgentFactory(NodeBinding node, AgentDef agentDef)
<A extends Agent> AgentRoute<A>	createAgentRoute(Class<? extends A> agentClass)
protected EdgeBinding	createEdge()
HostBinding	createHost(HostAddress hostAddress)
LaneBinding	createLane(LaneAddress laneAddress)
LaneBinding	createLane(NodeBinding node, LaneDef laneDef)
Log	createLog(CellAddress cellAddress)
Log	createLog(LogDef logDef)
MeshBinding	createMesh(MeshAddress meshAddress)
NodeBinding	createNode(NodeAddress nodeAddress)
PartBinding	createPart(PartAddress partAddress)
protected <P extends Plane> P	createPlane(PlaneFactory<P> planeFactory)
Policy	createPolicy(CellAddress cellAddress)
Policy	createPolicy(PolicyDef policyDef)
Stage	createStage(StageDef stageDef)
Stage	createStage(CellAddress cellAddress)
StoreBinding	createStore(CellAddress cellAddress)
StoreBinding	createStore(StoreDef storeDef)
void	debug(Object message)	Logs a debug-level message.
void	didClose()
void	didFail(Throwable error)
void	didLoad()
void	didOpen()
void	didStart()
void	didStop()
void	didUnload()
EdgeBinding	edge()
String	edgeName()
EdgeBinding	edgeWrapper()
void	error(Object message)	Logs an error-level message.
void	fail(Object message)	Logs an fail-level message.
AgentFactory<?>	getAgentFactory(Uri nodeUri)
<A extends Agent> AgentRoute<A>	getAgentRoute(String routeName)
Authenticator	getAuthenticator(String authenticatorName)
HostDef	getHostDef(HostAddress hostAddress)
LaneDef	getLaneDef(LaneAddress laneAddress)
MeshDef	getMeshDef(MeshAddress meshAddress)
NodeDef	getNodeDef(NodeAddress nodeAddress)
PartDef	getPartDef(PartAddress partAddress)
<P extends Plane> P	getPlane(Class<? extends P> planeClass)
Plane	getPlane(String planeName)
void	info(Object message)	Logs an info-level message.
protected EdgeBinding	injectEdge(EdgeAddress edgeAddress, EdgeBinding edge)
HostBinding	injectHost(HostAddress hostAddress, HostBinding host)
LaneBinding	injectLane(LaneAddress laneAddress, LaneBinding lane)
Log	injectLog(Log log)
MeshBinding	injectMesh(MeshAddress meshAddress, MeshBinding mesh)
NodeBinding	injectNode(NodeAddress nodeAddress, NodeBinding node)
PartBinding	injectPart(PartAddress partAddress, PartBinding part)
Policy	injectPolicy(Policy policy)
Stage	injectStage(Stage stage)
StoreBinding	injectStore(StoreBinding store)
KernelContext	kernel()
void	load()
Uri	meshUri()
void	open()
void	openAgents(NodeBinding node)
void	openDownlink(LinkBinding link)
void	openLanes(NodeBinding node)
protected Log	openLog()
void	openMetaDownlink(LinkBinding downlink, NodeBinding metaDownlink)
void	openMetaEdge(EdgeBinding edge, NodeBinding metaEdge)
void	openMetaHost(HostBinding host, NodeBinding metaHost)
void	openMetaLane(LaneBinding lane, NodeBinding metaLane)
void	openMetaMesh(MeshBinding mesh, NodeBinding metaMesh)
void	openMetaNode(NodeBinding node, NodeBinding metaNode)
void	openMetaPart(PartBinding part, NodeBinding metaPart)
void	openMetaUplink(LinkBinding uplink, NodeBinding metaUplink)
<P extends Plane> P	openPlane(String planeName, Class<? extends P> planeClass)
<P extends Plane> P	openPlane(String planeName, PlaneFactory<P> planeFactory)
protected PlanePolicy	openPolicy()
protected Stage	openStage()
protected StoreBinding	openStore()
Collection<? extends Plane>	planes()
PlanePolicy	policy()
void	pushDown(Push<?> push)
void	removeAgentRoute(String routeName)
void	reportDown(Metric metric)
Schedule	schedule()
protected void	seedEdge(EdgeBinding edge)
protected HostBinding	seedHost(PartBinding part, HostDef hostDef)
protected LaneBinding	seedLane(NodeBinding node, LaneDef laneDef)
protected MeshBinding	seedMesh(EdgeBinding edge, MeshDef meshDef)
protected NodeBinding	seedNode(HostBinding host, NodeDef nodeDef)
protected PartBinding	seedPart(MeshBinding mesh, PartDef partDef)
void	setPolicy(PlanePolicy policy)
ActorSpaceDef	spaceDef()
Stage	stage()
void	start()
void	stop()
StoreBinding	store()
TierContext	tierContext()
void	trace(Object message)	Logs a trace-level message.
void	unload()
<T> T	unwrapEdge(Class<T> edgeClass)
void	warn(Object message)	Logs a warn-level message.
void	willClose()
void	willLoad()
void	willOpen()
void	willStart()
void	willStop()
void	willUnload()

Methods inherited from class swim.runtime.AbstractTierBinding

activate, isClosed, isLoaded, isOpened, isStarted

Methods inherited from class swim.runtime.AbstractSwimRef

command, command, command, command, command, command, command, command, command, command, command, command, command, command, command, command, downlink, downlinkHttp, downlinkList, downlinkMap, downlinkValue, downlinkWs, hostRef, hostRef, laneRef, laneRef, laneRef, laneRef, nodeRef, nodeRef, nodeRef, nodeRef

Methods inherited from class java.lang.Object

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

Methods inherited from interface swim.api.downlink.DownlinkFactory

downlink, downlinkHttp, downlinkList, downlinkMap, downlinkValue, downlinkWs

Methods inherited from interface swim.api.ref.SwimRef

command, command, command, command, command, command, command, command, command, command, command, command, command, command, command, command, hostRef, hostRef, laneRef, laneRef, laneRef, laneRef, nodeRef, nodeRef, nodeRef, nodeRef

Constructor Detail

ActorSpace

public ActorSpace(EdgeAddress edgeAddress,
                  ActorSpaceDef spaceDef,
                  KernelContext kernel)

Method Detail

spaceDef

public final ActorSpaceDef spaceDef()

tierContext

public final TierContext tierContext()

Specified by:

tierContext in interface TierBinding

Specified by:

tierContext in class AbstractTierBinding

edgeWrapper

public final EdgeBinding edgeWrapper()

Specified by:

edgeWrapper in interface EdgeContext

unwrapEdge

public <T> T unwrapEdge(Class<T> edgeClass)

Specified by:

unwrapEdge in interface EdgeContext

bottomEdge

public <T> T bottomEdge(Class<T> edgeClass)

Specified by:

bottomEdge in interface EdgeContext

cellAddress

public final EdgeAddress cellAddress()

Specified by:

cellAddress in interface CellContext

Specified by:

cellAddress in interface EdgeContext

edgeName

public final String edgeName()

Specified by:

edgeName in interface CellContext

Specified by:

edgeName in interface EdgeContext

meshUri

public final Uri meshUri()

Specified by:

meshUri in interface CellContext

policy

public final PlanePolicy policy()

Specified by:

policy in interface CellContext

Specified by:

policy in interface PlaneContext

Specified by:

policy in interface Space

setPolicy

public void setPolicy(PlanePolicy policy)

Specified by:

setPolicy in interface PlaneContext

schedule

public Schedule schedule()

Specified by:

schedule in interface CellContext

Specified by:

schedule in interface PlaneContext

Specified by:

schedule in interface Space

stage

public final Stage stage()

Specified by:

stage in interface CellContext

Specified by:

stage in interface PlaneContext

Specified by:

stage in interface Space

store

public final StoreBinding store()

Specified by:

store in interface CellContext

kernel

public final KernelContext kernel()

edge

public final EdgeBinding edge()

getAuthenticator

public Authenticator getAuthenticator(String authenticatorName)

Specified by:

getAuthenticator in interface PlaneContext

addAuthenticator

public void addAuthenticator(String authenticatorName,
                             Authenticator authenticator)

Specified by:

addAuthenticator in interface PlaneContext

planes

public Collection<? extends Plane> planes()

Specified by:

planes in interface Space

getPlane

public Plane getPlane(String planeName)

Specified by:

getPlane in interface Space

getPlane

public <P extends Plane> P getPlane(Class<? extends P> planeClass)

Specified by:

getPlane in interface Space

openPlane

public <P extends Plane> P openPlane(String planeName,
                                     PlaneFactory<P> planeFactory)

Specified by:

openPlane in interface Space

openPlane

public <P extends Plane> P openPlane(String planeName,
                                     Class<? extends P> planeClass)

Specified by:

openPlane in interface Space

createPlane

protected <P extends Plane> P createPlane(PlaneFactory<P> planeFactory)

getAgentRoute

public <A extends Agent> AgentRoute<A> getAgentRoute(String routeName)

Specified by:

getAgentRoute in interface PlaneContext

createAgentRoute

public <A extends Agent> AgentRoute<A> createAgentRoute(Class<? extends A> agentClass)

Specified by:

createAgentRoute in interface PlaneContext

addAgentRoute

public void addAgentRoute(String routeName,
                          UriPattern pattern,
                          AgentRoute<?> agentRoute)

Specified by:

addAgentRoute in interface PlaneContext

addAgentRoute

public void addAgentRoute(String routeName,
                          String pattern,
                          AgentRoute<?> agentRoute)

Specified by:

addAgentRoute in interface PlaneContext

removeAgentRoute

public void removeAgentRoute(String routeName)

Specified by:

removeAgentRoute in interface PlaneContext

getAgentFactory

public AgentFactory<?> getAgentFactory(Uri nodeUri)

Specified by:

getAgentFactory in interface PlaneContext

createAgentFactory

public AgentFactory<?> createAgentFactory(NodeBinding node,
                                          AgentDef agentDef)

Specified by:

createAgentFactory in interface EdgeContext

createAgentFactory

public <A extends Agent> AgentFactory<A> createAgentFactory(NodeBinding node,
                                                            Class<? extends A> agentClass)

Specified by:

createAgentFactory in interface EdgeContext

openAgents

public void openAgents(NodeBinding node)

Specified by:

openAgents in interface EdgeContext

createLog

public Log createLog(LogDef logDef)

createLog

public Log createLog(CellAddress cellAddress)

injectLog

public Log injectLog(Log log)

openLog

protected Log openLog()

closeLog

protected void closeLog()

createPolicy

public Policy createPolicy(PolicyDef policyDef)

createPolicy

public Policy createPolicy(CellAddress cellAddress)

injectPolicy

public Policy injectPolicy(Policy policy)

openPolicy

protected PlanePolicy openPolicy()

closePolicy

protected void closePolicy()

createStage

public Stage createStage(StageDef stageDef)

createStage

public Stage createStage(CellAddress cellAddress)

injectStage

public Stage injectStage(Stage stage)

openStage

protected Stage openStage()

closeStage

protected void closeStage()

createStore

public StoreBinding createStore(StoreDef storeDef)

createStore

public StoreBinding createStore(CellAddress cellAddress)

injectStore

public StoreBinding injectStore(StoreBinding store)

openStore

protected StoreBinding openStore()

closeStore

protected void closeStore()

createEdge

protected EdgeBinding createEdge()

seedEdge

protected void seedEdge(EdgeBinding edge)

seedMesh

protected MeshBinding seedMesh(EdgeBinding edge,
                               MeshDef meshDef)

seedPart

protected PartBinding seedPart(MeshBinding mesh,
                               PartDef partDef)

seedHost

protected HostBinding seedHost(PartBinding part,
                               HostDef hostDef)

seedNode

protected NodeBinding seedNode(HostBinding host,
                               NodeDef nodeDef)

seedLane

protected LaneBinding seedLane(NodeBinding node,
                               LaneDef laneDef)

injectEdge

protected EdgeBinding injectEdge(EdgeAddress edgeAddress,
                                 EdgeBinding edge)

openMetaEdge

public void openMetaEdge(EdgeBinding edge,
                         NodeBinding metaEdge)

Specified by:

openMetaEdge in interface EdgeContext

getMeshDef

public MeshDef getMeshDef(MeshAddress meshAddress)

createMesh

public MeshBinding createMesh(MeshAddress meshAddress)

Specified by:

createMesh in interface EdgeContext

injectMesh

public MeshBinding injectMesh(MeshAddress meshAddress,
                              MeshBinding mesh)

Specified by:

injectMesh in interface EdgeContext

openMetaMesh

public void openMetaMesh(MeshBinding mesh,
                         NodeBinding metaMesh)

Specified by:

openMetaMesh in interface EdgeContext

getPartDef

public PartDef getPartDef(PartAddress partAddress)

createPart

public PartBinding createPart(PartAddress partAddress)

Specified by:

createPart in interface EdgeContext

injectPart

public PartBinding injectPart(PartAddress partAddress,
                              PartBinding part)

Specified by:

injectPart in interface EdgeContext

openMetaPart

public void openMetaPart(PartBinding part,
                         NodeBinding metaPart)

Specified by:

openMetaPart in interface EdgeContext

getHostDef

public HostDef getHostDef(HostAddress hostAddress)

createHost

public HostBinding createHost(HostAddress hostAddress)

Specified by:

createHost in interface EdgeContext

injectHost

public HostBinding injectHost(HostAddress hostAddress,
                              HostBinding host)

Specified by:

injectHost in interface EdgeContext

openMetaHost

public void openMetaHost(HostBinding host,
                         NodeBinding metaHost)

Specified by:

openMetaHost in interface EdgeContext

getNodeDef

public NodeDef getNodeDef(NodeAddress nodeAddress)

createNode

public NodeBinding createNode(NodeAddress nodeAddress)

Specified by:

createNode in interface EdgeContext

injectNode

public NodeBinding injectNode(NodeAddress nodeAddress,
                              NodeBinding node)

Specified by:

injectNode in interface EdgeContext

openMetaNode

public void openMetaNode(NodeBinding node,
                         NodeBinding metaNode)

Specified by:

openMetaNode in interface EdgeContext

getLaneDef

public LaneDef getLaneDef(LaneAddress laneAddress)

createLane

public LaneBinding createLane(LaneAddress laneAddress)

Specified by:

createLane in interface EdgeContext

injectLane

public LaneBinding injectLane(LaneAddress laneAddress,
                              LaneBinding lane)

Specified by:

injectLane in interface EdgeContext

openMetaLane

public void openMetaLane(LaneBinding lane,
                         NodeBinding metaLane)

Specified by:

openMetaLane in interface EdgeContext

openMetaUplink

public void openMetaUplink(LinkBinding uplink,
                           NodeBinding metaUplink)

Specified by:

openMetaUplink in interface EdgeContext

openMetaDownlink

public void openMetaDownlink(LinkBinding downlink,
                             NodeBinding metaDownlink)

Specified by:

openMetaDownlink in interface CellContext

createLane

public LaneBinding createLane(NodeBinding node,
                              LaneDef laneDef)

Specified by:

createLane in interface EdgeContext

openLanes

public void openLanes(NodeBinding node)

Specified by:

openLanes in interface EdgeContext

authenticate

public PolicyDirective<Identity> authenticate(Credentials credentials)

Specified by:

authenticate in interface EdgeContext

bindDownlink

public LinkBinding bindDownlink(Downlink downlink)

Specified by:

bindDownlink in interface CellContext

openDownlink

public void openDownlink(LinkBinding link)

Specified by:

openDownlink in interface CellContext

closeDownlink

public void closeDownlink(LinkBinding link)

Specified by:

closeDownlink in interface CellContext

pushDown

public void pushDown(Push<?> push)

Specified by:

pushDown in interface CellContext

reportDown

public void reportDown(Metric metric)

Specified by:

reportDown in interface CellContext

trace

public void trace(Object message)

Description copied from interface: Log

Logs a trace-level message.

Specified by:

trace in interface Log

debug

public void debug(Object message)

Description copied from interface: Log

Logs a debug-level message.

Specified by:

debug in interface Log

info

public void info(Object message)

Description copied from interface: Log

Logs an info-level message.

Specified by:

info in interface Log

warn

public void warn(Object message)

Description copied from interface: Log

Logs a warn-level message.

Specified by:

warn in interface Log

error

public void error(Object message)

Description copied from interface: Log

Logs an error-level message.

Specified by:

error in interface Log

fail

public void fail(Object message)

Description copied from interface: Log

Logs an fail-level message.

Specified by:

fail in interface Log

open

public void open()

Specified by:

open in interface TierBinding

Overrides:

open in class AbstractTierBinding

load

public void load()

Specified by:

load in interface TierBinding

Overrides:

load in class AbstractTierBinding

start

public void start()

Specified by:

start in interface TierBinding

Overrides:

start in class AbstractTierBinding

stop

public void stop()

Specified by:

stop in interface TierBinding

Overrides:

stop in class AbstractTierBinding

unload

public void unload()

Specified by:

unload in interface TierBinding

Overrides:

unload in class AbstractTierBinding

close

public void close()

Specified by:

close in interface SwimRef

Specified by:

close in interface TierBinding

Specified by:

close in interface TierContext

Overrides:

close in class AbstractTierBinding

willOpen

public void willOpen()

Specified by:

willOpen in interface TierContext

Overrides:

willOpen in class AbstractTierBinding

didOpen

public void didOpen()

Specified by:

didOpen in interface TierContext

Overrides:

didOpen in class AbstractTierBinding

willLoad

public void willLoad()

Specified by:

willLoad in interface TierContext

Overrides:

willLoad in class AbstractTierBinding

didLoad

public void didLoad()

Specified by:

didLoad in interface TierContext

Overrides:

didLoad in class AbstractTierBinding

willStart

public void willStart()

Specified by:

willStart in interface TierContext

Overrides:

willStart in class AbstractTierBinding

didStart

public void didStart()

Specified by:

didStart in interface TierContext

Overrides:

didStart in class AbstractTierBinding

willStop

public void willStop()

Specified by:

willStop in interface TierContext

Overrides:

willStop in class AbstractTierBinding

didStop

public void didStop()

Specified by:

didStop in interface TierContext

Overrides:

didStop in class AbstractTierBinding

willUnload

public void willUnload()

Specified by:

willUnload in interface TierContext

Overrides:

willUnload in class AbstractTierBinding

didUnload

public void didUnload()

Specified by:

didUnload in interface TierContext

Overrides:

didUnload in class AbstractTierBinding

willClose

public void willClose()

Specified by:

willClose in interface TierContext

Overrides:

willClose in class AbstractTierBinding

didClose

public void didClose()

Specified by:

didClose in interface TierBinding

Overrides:

didClose in class AbstractTierBinding

didFail

public void didFail(Throwable error)

Specified by:

didFail in interface TierBinding

Overrides:

didFail in class AbstractTierBinding