- java.lang.Object
-
- swim.runtime.AbstractSwimRef
-
- swim.runtime.AbstractTierBinding
-
- swim.fabric.FabricRoot
-
- All Implemented Interfaces:
DownlinkFactory
,PlaneContext
,SwimRef
,CellContext
,RootContext
,TierBinding
,TierContext
,Log
public class FabricRoot extends AbstractTierBinding implements RootContext, PlaneContext
-
-
Field Summary
Fields Modifier and Type Field Description protected KernelContext
kernel
protected Log
log
protected Plane
plane
protected PlaneDef
planeDef
protected String
planeName
protected PlanePolicy
policy
protected RootBinding
root
protected Stage
stage
protected StoreBinding
store
-
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 FabricRoot(String planeName, PlaneDef planeDef, KernelContext kernel)
-
Method Summary
All Methods Instance Methods Concrete Methods 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)
Collection<? extends Authenticator>
authenticators()
LinkBinding
bindDownlink(Downlink downlink)
void
close()
void
closeDownlink(LinkBinding link)
protected void
closeLog()
protected void
closePolicy()
protected void
closeStage()
protected void
closeStore()
<A extends Agent>
AgentFactory<A>createAgentFactory(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri, Class<? extends A> agentClass)
<A extends Agent>
AgentRoute<A>createAgentRoute(Class<? extends A> agentClass)
HostBinding
createHost(Uri meshUri, Value partKey, Uri hostUri)
MeshBinding
createMesh(Uri meshUri)
NodeBinding
createNode(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri)
PartBinding
createPart(Uri meshUri, Value partKey)
protected RootBinding
createRoot()
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()
void
error(Object message)
Logs an error-level message.<A extends Agent>
AgentFactory<A>getAgentFactory(Uri nodeUri)
<A extends Agent>
AgentRoute<A>getAgentRoute(String routeName)
void
httpDownlink(HttpBinding http)
void
info(Object message)
Logs an info-level message.protected void
initRoot(RootBinding root)
HostBinding
injectHost(Uri meshUri, Value partKey, Uri hostUri, HostBinding host)
LaneBinding
injectLane(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri, Uri laneUri, LaneBinding lane)
MeshBinding
injectMesh(Uri meshUri, MeshBinding mesh)
NodeBinding
injectNode(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri, NodeBinding node)
PartBinding
injectPart(Uri meshUri, Value partKey, PartBinding part)
KernelContext
kernel()
void
load()
Uri
meshUri()
void
open()
void
openAgents(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri, NodeBinding node)
void
openDownlink(LinkBinding link)
Log
openHostLog(Uri meshUri, Value partKey, Uri hostUri)
Policy
openHostPolicy(Uri meshUri, Value partKey, Uri hostUri)
Stage
openHostStage(Uri meshUri, Value partKey, Uri hostUri)
StoreBinding
openHostStore(Uri meshUri, Value partKey, Uri hostUri)
Log
openLaneLog(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri, Uri laneUri)
Policy
openLanePolicy(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri, Uri laneUri)
Stage
openLaneStage(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri, Uri laneUri)
StoreBinding
openLaneStore(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri, Uri laneUri)
protected Log
openLog()
Log
openMeshLog(Uri meshUri)
Policy
openMeshPolicy(Uri meshUri)
Stage
openMeshStage(Uri meshUri)
StoreBinding
openMeshStore(Uri meshUri)
Log
openNodeLog(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri)
Policy
openNodePolicy(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri)
Stage
openNodeStage(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri)
StoreBinding
openNodeStore(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri)
Log
openPartLog(Uri meshUri, Value partKey)
Policy
openPartPolicy(Uri meshUri, Value partKey)
Stage
openPartStage(Uri meshUri, Value partKey)
StoreBinding
openPartStore(Uri meshUri, Value partKey)
protected PlanePolicy
openPolicy()
protected Stage
openStage()
protected StoreBinding
openStore()
Plane
plane()
PlaneDef
planeDef()
String
planeName()
PlanePolicy
planePolicy()
Policy
policy()
void
pushDown(PushRequest pushRequest)
void
removeAgentRoute(String routeName)
RootBinding
root()
RootBinding
rootWrapper()
Schedule
schedule()
void
setPlane(Plane plane)
void
setPlanePolicy(PlanePolicy policy)
Stage
stage()
void
start()
void
stop()
StoreBinding
store()
TierContext
tierContext()
void
trace(Object message)
Logs a trace-level message.void
unload()
<T> T
unwrapRoot(Class<T> rootClass)
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, 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
-
-
-
-
Field Detail
-
planeName
protected final String planeName
-
planeDef
protected final PlaneDef planeDef
-
kernel
protected final KernelContext kernel
-
root
protected final RootBinding root
-
plane
protected Plane plane
-
log
protected Log log
-
policy
protected PlanePolicy policy
-
stage
protected Stage stage
-
store
protected StoreBinding store
-
-
Constructor Detail
-
FabricRoot
public FabricRoot(String planeName, PlaneDef planeDef, KernelContext kernel)
-
-
Method Detail
-
planeName
public final String planeName()
-
planeDef
public final PlaneDef planeDef()
-
tierContext
public final TierContext tierContext()
- Specified by:
tierContext
in interfaceTierBinding
- Specified by:
tierContext
in classAbstractTierBinding
-
rootWrapper
public final RootBinding rootWrapper()
- Specified by:
rootWrapper
in interfaceRootContext
-
unwrapRoot
public <T> T unwrapRoot(Class<T> rootClass)
- Specified by:
unwrapRoot
in interfaceRootContext
-
meshUri
public final Uri meshUri()
- Specified by:
meshUri
in interfaceCellContext
-
policy
public final Policy policy()
- Specified by:
policy
in interfaceCellContext
-
schedule
public Schedule schedule()
- Specified by:
schedule
in interfaceCellContext
- Specified by:
schedule
in interfacePlaneContext
-
stage
public final Stage stage()
- Specified by:
stage
in interfaceCellContext
- Specified by:
stage
in interfacePlaneContext
-
store
public final StoreBinding store()
- Specified by:
store
in interfaceCellContext
-
kernel
public final KernelContext kernel()
-
root
public final RootBinding root()
-
plane
public final Plane plane()
-
setPlane
public void setPlane(Plane plane)
-
planePolicy
public final PlanePolicy planePolicy()
- Specified by:
planePolicy
in interfacePlaneContext
-
setPlanePolicy
public void setPlanePolicy(PlanePolicy policy)
- Specified by:
setPlanePolicy
in interfacePlaneContext
-
createAgentRoute
public <A extends Agent> AgentRoute<A> createAgentRoute(Class<? extends A> agentClass)
- Specified by:
createAgentRoute
in interfacePlaneContext
-
getAgentRoute
public <A extends Agent> AgentRoute<A> getAgentRoute(String routeName)
- Specified by:
getAgentRoute
in interfacePlaneContext
-
addAgentRoute
public void addAgentRoute(String routeName, UriPattern pattern, AgentRoute<?> agentRoute)
- Specified by:
addAgentRoute
in interfacePlaneContext
-
addAgentRoute
public void addAgentRoute(String routeName, String pattern, AgentRoute<?> agentRoute)
- Specified by:
addAgentRoute
in interfacePlaneContext
-
removeAgentRoute
public void removeAgentRoute(String routeName)
- Specified by:
removeAgentRoute
in interfacePlaneContext
-
getAgentFactory
public <A extends Agent> AgentFactory<A> getAgentFactory(Uri nodeUri)
- Specified by:
getAgentFactory
in interfacePlaneContext
-
authenticators
public Collection<? extends Authenticator> authenticators()
- Specified by:
authenticators
in interfacePlaneContext
-
addAuthenticator
public void addAuthenticator(String authenticatorName, Authenticator authenticator)
- Specified by:
addAuthenticator
in interfacePlaneContext
-
createRoot
protected RootBinding createRoot()
-
initRoot
protected void initRoot(RootBinding root)
-
createMesh
public MeshBinding createMesh(Uri meshUri)
- Specified by:
createMesh
in interfaceRootContext
-
injectMesh
public MeshBinding injectMesh(Uri meshUri, MeshBinding mesh)
- Specified by:
injectMesh
in interfaceRootContext
-
createPart
public PartBinding createPart(Uri meshUri, Value partKey)
- Specified by:
createPart
in interfaceRootContext
-
injectPart
public PartBinding injectPart(Uri meshUri, Value partKey, PartBinding part)
- Specified by:
injectPart
in interfaceRootContext
-
createHost
public HostBinding createHost(Uri meshUri, Value partKey, Uri hostUri)
- Specified by:
createHost
in interfaceRootContext
-
injectHost
public HostBinding injectHost(Uri meshUri, Value partKey, Uri hostUri, HostBinding host)
- Specified by:
injectHost
in interfaceRootContext
-
createNode
public NodeBinding createNode(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri)
- Specified by:
createNode
in interfaceRootContext
-
injectNode
public NodeBinding injectNode(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri, NodeBinding node)
- Specified by:
injectNode
in interfaceRootContext
-
injectLane
public LaneBinding injectLane(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri, Uri laneUri, LaneBinding lane)
- Specified by:
injectLane
in interfaceRootContext
-
createAgentFactory
public <A extends Agent> AgentFactory<A> createAgentFactory(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri, Class<? extends A> agentClass)
- Specified by:
createAgentFactory
in interfaceRootContext
-
openAgents
public void openAgents(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri, NodeBinding node)
- Specified by:
openAgents
in interfaceRootContext
-
openLog
protected Log openLog()
-
closeLog
protected void closeLog()
-
openLaneLog
public Log openLaneLog(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri, Uri laneUri)
-
openPolicy
protected PlanePolicy openPolicy()
-
closePolicy
protected void closePolicy()
-
openLanePolicy
public Policy openLanePolicy(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri, Uri laneUri)
-
openStage
protected Stage openStage()
-
closeStage
protected void closeStage()
-
openLaneStage
public Stage openLaneStage(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri, Uri laneUri)
-
openStore
protected StoreBinding openStore()
-
closeStore
protected void closeStore()
-
openMeshStore
public StoreBinding openMeshStore(Uri meshUri)
-
openPartStore
public StoreBinding openPartStore(Uri meshUri, Value partKey)
-
openHostStore
public StoreBinding openHostStore(Uri meshUri, Value partKey, Uri hostUri)
-
openNodeStore
public StoreBinding openNodeStore(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri)
-
openLaneStore
public StoreBinding openLaneStore(Uri meshUri, Value partKey, Uri hostUri, Uri nodeUri, Uri laneUri)
-
authenticate
public PolicyDirective<Identity> authenticate(Credentials credentials)
- Specified by:
authenticate
in interfaceRootContext
-
bindDownlink
public LinkBinding bindDownlink(Downlink downlink)
- Specified by:
bindDownlink
in interfaceCellContext
-
openDownlink
public void openDownlink(LinkBinding link)
- Specified by:
openDownlink
in interfaceCellContext
-
closeDownlink
public void closeDownlink(LinkBinding link)
- Specified by:
closeDownlink
in interfaceCellContext
-
httpDownlink
public void httpDownlink(HttpBinding http)
- Specified by:
httpDownlink
in interfaceCellContext
-
pushDown
public void pushDown(PushRequest pushRequest)
- Specified by:
pushDown
in interfaceCellContext
-
trace
public void trace(Object message)
Description copied from interface:Log
Logs a trace-level message.
-
debug
public void debug(Object message)
Description copied from interface:Log
Logs a debug-level message.
-
info
public void info(Object message)
Description copied from interface:Log
Logs an info-level message.
-
warn
public void warn(Object message)
Description copied from interface:Log
Logs a warn-level message.
-
error
public void error(Object message)
Description copied from interface:Log
Logs an error-level message.
-
open
public void open()
- Specified by:
open
in interfaceTierBinding
- Overrides:
open
in classAbstractTierBinding
-
load
public void load()
- Specified by:
load
in interfaceTierBinding
- Overrides:
load
in classAbstractTierBinding
-
start
public void start()
- Specified by:
start
in interfaceTierBinding
- Overrides:
start
in classAbstractTierBinding
-
stop
public void stop()
- Specified by:
stop
in interfaceTierBinding
- Overrides:
stop
in classAbstractTierBinding
-
unload
public void unload()
- Specified by:
unload
in interfaceTierBinding
- Overrides:
unload
in classAbstractTierBinding
-
close
public void close()
- Specified by:
close
in interfaceSwimRef
- Specified by:
close
in interfaceTierBinding
- Specified by:
close
in interfaceTierContext
- Overrides:
close
in classAbstractTierBinding
-
willOpen
public void willOpen()
- Specified by:
willOpen
in interfaceTierContext
- Overrides:
willOpen
in classAbstractTierBinding
-
didOpen
public void didOpen()
- Specified by:
didOpen
in interfaceTierContext
- Overrides:
didOpen
in classAbstractTierBinding
-
willLoad
public void willLoad()
- Specified by:
willLoad
in interfaceTierContext
- Overrides:
willLoad
in classAbstractTierBinding
-
didLoad
public void didLoad()
- Specified by:
didLoad
in interfaceTierContext
- Overrides:
didLoad
in classAbstractTierBinding
-
willStart
public void willStart()
- Specified by:
willStart
in interfaceTierContext
- Overrides:
willStart
in classAbstractTierBinding
-
didStart
public void didStart()
- Specified by:
didStart
in interfaceTierContext
- Overrides:
didStart
in classAbstractTierBinding
-
willStop
public void willStop()
- Specified by:
willStop
in interfaceTierContext
- Overrides:
willStop
in classAbstractTierBinding
-
didStop
public void didStop()
- Specified by:
didStop
in interfaceTierContext
- Overrides:
didStop
in classAbstractTierBinding
-
willUnload
public void willUnload()
- Specified by:
willUnload
in interfaceTierContext
- Overrides:
willUnload
in classAbstractTierBinding
-
didUnload
public void didUnload()
- Specified by:
didUnload
in interfaceTierContext
- Overrides:
didUnload
in classAbstractTierBinding
-
willClose
public void willClose()
- Specified by:
willClose
in interfaceTierContext
- Overrides:
willClose
in classAbstractTierBinding
-
didClose
public void didClose()
- Specified by:
didClose
in interfaceTierBinding
- Overrides:
didClose
in classAbstractTierBinding
-
didFail
public void didFail(Throwable error)
- Specified by:
didFail
in interfaceTierBinding
- Overrides:
didFail
in classAbstractTierBinding
-
-