Module swim.kernel

Package swim.kernel

Class KernelProxy

java.lang.Object

swim.kernel.KernelProxy

All Implemented Interfaces:

IpInterface, Kernel, KernelBinding, KernelContext, Log

Direct Known Subclasses:

ActorKernel, AuthenticatorKernel, BootKernel, DbStoreKernel, JavaKernel, JsKernel, MemStoreKernel, MetaKernel, RemoteKernel, ServiceKernel, WebServiceKernel

public abstract class KernelProxy
extends Object
implements KernelBinding, KernelContext

Field Summary

Fields

Modifier and Type	Field	Description
protected KernelBinding	kernelBinding
protected KernelContext	kernelContext
protected static int	STARTED
protected int	status
protected static AtomicIntegerFieldUpdater<KernelProxy>	STATUS

Constructor Summary

Constructors

Constructor	Description
KernelProxy()

Method Summary

Modifier and Type	Method	Description
IpServiceRef	bindTcp(InetSocketAddress localAddress, IpService service, IpSettings ipSettings)
IpServiceRef	bindTls(InetSocketAddress localAddress, IpService service, IpSettings ipSettings)
IpSocketRef	connectTcp(InetSocketAddress remoteAddress, IpSocket socket, IpSettings ipSettings)
IpSocketRef	connectTls(InetSocketAddress remoteAddress, IpSocket socket, IpSettings ipSettings)
<A extends Agent> AgentFactory<A>	createAgentFactory(Class<? extends A> agentClass)
AgentFactory<?>	createAgentFactory(AgentDef agentDef, ClassLoader classLoader)
<A extends Agent> AgentFactory<A>	createAgentFactory(NodeBinding node, Class<? extends A> agentClass)
AgentFactory<?>	createAgentFactory(NodeBinding node, AgentDef agentDef)
<A extends Agent> AgentRoute<A>	createAgentRoute(EdgeBinding edge, Class<? extends A> agentClass)
Authenticator	createAuthenticator(AuthenticatorDef authenticatorDef, ClassLoader classLoader)
EdgeBinding	createEdge(EdgeAddress edgeAddress)
HostBinding	createHost(HostAddress hostAddress)
HostBinding	createHost(PartBinding part, HostDef hostDef)
LaneBinding	createLane(LaneAddress laneAddress)
LaneBinding	createLane(NodeBinding node, LaneDef laneDef)
Log	createLog(CellAddress cellAddress)
Log	createLog(LogDef logDef)
MeshBinding	createMesh(EdgeBinding edge, MeshDef meshDef)
MeshBinding	createMesh(MeshAddress meshAddress)
NodeBinding	createNode(HostBinding host, NodeDef nodeDef)
NodeBinding	createNode(NodeAddress nodeAddress)
PartBinding	createPart(MeshBinding mesh, PartDef partDef)
PartBinding	createPart(PartAddress partAddress)
<P extends Plane> PlaneFactory<P>	createPlaneFactory(Class<? extends P> planeClass)
PlaneFactory<?>	createPlaneFactory(PlaneDef planeDef, ClassLoader classLoader)
Policy	createPolicy(CellAddress cellAddress)
Policy	createPolicy(PolicyDef policyDef)
Schedule	createSchedule(ScheduleDef scheduleDef, Stage stage)
ServiceFactory<?>	createServiceFactory(ServiceDef serviceDef, ClassLoader classLoader)
Stage	createStage(StageDef stageDef)
Stage	createStage(CellAddress cellAddress)
StoreBinding	createStore(StoreDef storeDef, ClassLoader classLoader)
StoreBinding	createStore(CellAddress cellAddress)
void	debug(Object message)	Logs a debug-level message.
AgentDef	defineAgent(Item agentConfig)
AuthenticatorDef	defineAuthenticator(Item authenticatorConfig)
HostDef	defineHost(Item hostConfig)
LaneDef	defineLane(Item laneConfig)
LogDef	defineLog(Item logConfig)
MeshDef	defineMesh(Item meshConfig)
NodeDef	defineNode(Item nodeConfig)
PartDef	definePart(Item partConfig)
PlaneDef	definePlane(Item planeConfig)
PolicyDef	definePolicy(Item policyConfig)
ScheduleDef	defineSchedule(Item scheduleConfig)
ServiceDef	defineService(Item serviceConfig)
SpaceDef	defineSpace(Item spaceConfig)
StageDef	defineStage(Item stageConfig)
StoreDef	defineStore(Item storeConfig)
protected void	didStart()
protected void	didStop()
void	error(Object message)	Logs an error-level message.
void	fail(Object message)	Logs an fail-level message.
HostDef	getHostDef(HostAddress hostAddress)
LaneDef	getLaneDef(LaneAddress laneAddress)
MeshDef	getMeshDef(MeshAddress meshAddress)
NodeDef	getNodeDef(NodeAddress nodeAddress)
PartDef	getPartDef(PartAddress partAddress)
Service	getService(String serviceName)
Space	getSpace(String spaceName)
void	info(Object message)	Logs an info-level message.
Authenticator	injectAuthenticator(Authenticator authenticator)
EdgeBinding	injectEdge(EdgeAddress edgeAddress, EdgeBinding edge)
HostBinding	injectHost(HostAddress hostAddress, HostBinding host)
Kernel	injectKernel(Kernel kernel)	Returns a Kernel implementation with the combined capabilities of this Kernel implementation and the given kernel implementation.
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)
Plane	injectPlane(Plane plane)
Policy	injectPolicy(Policy policy)
Schedule	injectSchedule(Schedule schedule)
Service	injectService(Service service)
Stage	injectStage(Stage stage)
StoreBinding	injectStore(StoreBinding store)
IpSettings	ipSettings()
boolean	isStarted()
KernelBinding	kernelBinding()
KernelContext	kernelContext()
abstract double	kernelPriority()	Returns the relative priority of this Kernel implementation.
KernelBinding	kernelWrapper()
FingerTrieSeq<Kernel>	modules()
void	openAgents(NodeBinding node)
void	openLanes(NodeBinding node)
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)
<S extends Service> S	openService(String serviceName, ServiceFactory<S> serviceFactory)
Space	openSpace(SpaceDef spaceDef)
void	reportDown(Metric metric)
WebResponse	routeRequest(WebRequest request)
void	run()
void	setKernelBinding(KernelBinding kernelBinding)
void	setKernelContext(KernelContext kernelContext)
Stage	stage()
void	start()
Station	station()
void	stop()
void	trace(Object message)	Logs a trace-level message.
<T> T	unwrapKernel(Class<T> kernelClass)
void	warn(Object message)	Logs a warn-level message.
protected void	willStart()
protected void	willStop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface swim.io.IpInterface

bindTcp, bindTcp, bindTcp, bindTls, bindTls, bindTls, connectTcp, connectTcp, connectTcp, connectTcp, connectTcp, connectTcp, connectTcp, connectTls, connectTls, connectTls, connectTls, connectTls, connectTls, connectTls

Methods inherited from interface swim.kernel.Kernel

openService, openService

Field Detail

kernelBinding

protected KernelBinding kernelBinding

kernelContext

protected KernelContext kernelContext

status

protected volatile int status

STARTED

protected static final int STARTED

See Also:

Constant Field Values

STATUS

protected static final AtomicIntegerFieldUpdater<KernelProxy> STATUS

Constructor Detail

KernelProxy

public KernelProxy()

Method Detail

kernelWrapper

public final KernelBinding kernelWrapper()

Specified by:

kernelWrapper in interface KernelBinding

Specified by:

kernelWrapper in interface KernelContext

kernelBinding

public final KernelBinding kernelBinding()

Specified by:

kernelBinding in interface KernelContext

setKernelBinding

public void setKernelBinding(KernelBinding kernelBinding)

Specified by:

setKernelBinding in interface KernelContext

kernelContext

public final KernelContext kernelContext()

Specified by:

kernelContext in interface KernelBinding

setKernelContext

public void setKernelContext(KernelContext kernelContext)

Specified by:

setKernelContext in interface KernelBinding

unwrapKernel

public <T> T unwrapKernel(Class<T> kernelClass)

Specified by:

unwrapKernel in interface Kernel

kernelPriority

public abstract double kernelPriority()

Description copied from interface: Kernel

Returns the relative priority of this Kernel implementation. Kernel implementations with greater priority inject into kernel stacks before implementations with lower priority.

Specified by:

kernelPriority in interface Kernel

injectKernel

public Kernel injectKernel(Kernel kernel)

Description copied from interface: Kernel

Returns a Kernel implementation with the combined capabilities of this Kernel implementation and the given kernel implementation.

Specified by:

injectKernel in interface Kernel

modules

public FingerTrieSeq<Kernel> modules()

Specified by:

modules in interface KernelContext

isStarted

public final boolean isStarted()

Specified by:

isStarted in interface Kernel

stage

public Stage stage()

Specified by:

stage in interface KernelContext

station

public Station station()

Specified by:

station in interface KernelContext

defineLog

public LogDef defineLog(Item logConfig)

Specified by:

defineLog in interface KernelContext

createLog

public Log createLog(LogDef logDef)

Specified by:

createLog in interface KernelContext

createLog

public Log createLog(CellAddress cellAddress)

Specified by:

createLog in interface KernelContext

injectLog

public Log injectLog(Log log)

Specified by:

injectLog in interface KernelContext

definePolicy

public PolicyDef definePolicy(Item policyConfig)

Specified by:

definePolicy in interface KernelContext

createPolicy

public Policy createPolicy(PolicyDef policyDef)

Specified by:

createPolicy in interface KernelContext

createPolicy

public Policy createPolicy(CellAddress cellAddress)

Specified by:

createPolicy in interface KernelContext

injectPolicy

public Policy injectPolicy(Policy policy)

Specified by:

injectPolicy in interface KernelContext

defineSchedule

public ScheduleDef defineSchedule(Item scheduleConfig)

Specified by:

defineSchedule in interface KernelContext

createSchedule

public Schedule createSchedule(ScheduleDef scheduleDef,
                               Stage stage)

Specified by:

createSchedule in interface KernelContext

injectSchedule

public Schedule injectSchedule(Schedule schedule)

Specified by:

injectSchedule in interface KernelContext

defineStage

public StageDef defineStage(Item stageConfig)

Specified by:

defineStage in interface KernelContext

createStage

public Stage createStage(StageDef stageDef)

Specified by:

createStage in interface KernelContext

createStage

public Stage createStage(CellAddress cellAddress)

Specified by:

createStage in interface KernelContext

injectStage

public Stage injectStage(Stage stage)

Specified by:

injectStage in interface KernelContext

defineStore

public StoreDef defineStore(Item storeConfig)

Specified by:

defineStore in interface KernelContext

createStore

public StoreBinding createStore(StoreDef storeDef,
                                ClassLoader classLoader)

Specified by:

createStore in interface KernelContext

createStore

public StoreBinding createStore(CellAddress cellAddress)

Specified by:

createStore in interface KernelContext

injectStore

public StoreBinding injectStore(StoreBinding store)

Specified by:

injectStore in interface KernelContext

defineAuthenticator

public AuthenticatorDef defineAuthenticator(Item authenticatorConfig)

Specified by:

defineAuthenticator in interface KernelContext

createAuthenticator

public Authenticator createAuthenticator(AuthenticatorDef authenticatorDef,
                                         ClassLoader classLoader)

Specified by:

createAuthenticator in interface KernelContext

injectAuthenticator

public Authenticator injectAuthenticator(Authenticator authenticator)

Specified by:

injectAuthenticator in interface KernelContext

ipSettings

public IpSettings ipSettings()

Specified by:

ipSettings in interface IpInterface

Specified by:

ipSettings in interface KernelContext

bindTcp

public IpServiceRef bindTcp(InetSocketAddress localAddress,
                            IpService service,
                            IpSettings ipSettings)

Specified by:

bindTcp in interface IpInterface

Specified by:

bindTcp in interface KernelContext

bindTls

public IpServiceRef bindTls(InetSocketAddress localAddress,
                            IpService service,
                            IpSettings ipSettings)

Specified by:

bindTls in interface IpInterface

Specified by:

bindTls in interface KernelContext

connectTcp

public IpSocketRef connectTcp(InetSocketAddress remoteAddress,
                              IpSocket socket,
                              IpSettings ipSettings)

Specified by:

connectTcp in interface IpInterface

Specified by:

connectTcp in interface KernelContext

connectTls

public IpSocketRef connectTls(InetSocketAddress remoteAddress,
                              IpSocket socket,
                              IpSettings ipSettings)

Specified by:

connectTls in interface IpInterface

Specified by:

connectTls in interface KernelContext

getService

public Service getService(String serviceName)

Specified by:

getService in interface Kernel

Specified by:

getService in interface KernelContext

defineService

public ServiceDef defineService(Item serviceConfig)

Specified by:

defineService in interface Kernel

Specified by:

defineService in interface KernelContext

createServiceFactory

public ServiceFactory<?> createServiceFactory(ServiceDef serviceDef,
                                              ClassLoader classLoader)

Specified by:

createServiceFactory in interface Kernel

Specified by:

createServiceFactory in interface KernelContext

injectService

public Service injectService(Service service)

Specified by:

injectService in interface KernelContext

openService

public <S extends Service> S openService(String serviceName,
                                         ServiceFactory<S> serviceFactory)

Specified by:

openService in interface Kernel

Specified by:

openService in interface KernelContext

routeRequest

public WebResponse routeRequest(WebRequest request)

Specified by:

routeRequest in interface KernelContext

getSpace

public Space getSpace(String spaceName)

Specified by:

getSpace in interface Kernel

Specified by:

getSpace in interface KernelContext

defineSpace

public SpaceDef defineSpace(Item spaceConfig)

Specified by:

defineSpace in interface Kernel

Specified by:

defineSpace in interface KernelContext

openSpace

public Space openSpace(SpaceDef spaceDef)

Specified by:

openSpace in interface Kernel

Specified by:

openSpace in interface KernelContext

definePlane

public PlaneDef definePlane(Item planeConfig)

Specified by:

definePlane in interface Kernel

Specified by:

definePlane in interface KernelContext

createPlaneFactory

public PlaneFactory<?> createPlaneFactory(PlaneDef planeDef,
                                          ClassLoader classLoader)

Specified by:

createPlaneFactory in interface Kernel

Specified by:

createPlaneFactory in interface KernelContext

createPlaneFactory

public <P extends Plane> PlaneFactory<P> createPlaneFactory(Class<? extends P> planeClass)

Specified by:

createPlaneFactory in interface Kernel

Specified by:

createPlaneFactory in interface KernelContext

injectPlane

public Plane injectPlane(Plane plane)

Specified by:

injectPlane in interface KernelContext

defineAgent

public AgentDef defineAgent(Item agentConfig)

Specified by:

defineAgent in interface Kernel

Specified by:

defineAgent in interface KernelContext

createAgentFactory

public AgentFactory<?> createAgentFactory(AgentDef agentDef,
                                          ClassLoader classLoader)

Specified by:

createAgentFactory in interface Kernel

Specified by:

createAgentFactory in interface KernelContext

createAgentFactory

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

Specified by:

createAgentFactory in interface KernelContext

createAgentFactory

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

Specified by:

createAgentFactory in interface Kernel

Specified by:

createAgentFactory in interface KernelContext

createAgentFactory

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

Specified by:

createAgentFactory in interface KernelContext

createAgentRoute

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

Specified by:

createAgentRoute in interface KernelContext

openAgents

public void openAgents(NodeBinding node)

Specified by:

openAgents in interface KernelContext

openLanes

public void openLanes(NodeBinding node)

Specified by:

openLanes in interface KernelContext

createEdge

public EdgeBinding createEdge(EdgeAddress edgeAddress)

Specified by:

createEdge in interface KernelContext

injectEdge

public EdgeBinding injectEdge(EdgeAddress edgeAddress,
                              EdgeBinding edge)

Specified by:

injectEdge in interface KernelContext

openMetaEdge

public void openMetaEdge(EdgeBinding edge,
                         NodeBinding metaEdge)

Specified by:

openMetaEdge in interface KernelContext

defineMesh

public MeshDef defineMesh(Item meshConfig)

Specified by:

defineMesh in interface KernelContext

getMeshDef

public MeshDef getMeshDef(MeshAddress meshAddress)

Specified by:

getMeshDef in interface KernelContext

createMesh

public MeshBinding createMesh(EdgeBinding edge,
                              MeshDef meshDef)

Specified by:

createMesh in interface KernelContext

createMesh

public MeshBinding createMesh(MeshAddress meshAddress)

Specified by:

createMesh in interface KernelContext

injectMesh

public MeshBinding injectMesh(MeshAddress meshAddress,
                              MeshBinding mesh)

Specified by:

injectMesh in interface KernelContext

openMetaMesh

public void openMetaMesh(MeshBinding mesh,
                         NodeBinding metaMesh)

Specified by:

openMetaMesh in interface KernelContext

definePart

public PartDef definePart(Item partConfig)

Specified by:

definePart in interface KernelContext

getPartDef

public PartDef getPartDef(PartAddress partAddress)

Specified by:

getPartDef in interface KernelContext

createPart

public PartBinding createPart(MeshBinding mesh,
                              PartDef partDef)

Specified by:

createPart in interface KernelContext

createPart

public PartBinding createPart(PartAddress partAddress)

Specified by:

createPart in interface KernelContext

injectPart

public PartBinding injectPart(PartAddress partAddress,
                              PartBinding part)

Specified by:

injectPart in interface KernelContext

openMetaPart

public void openMetaPart(PartBinding part,
                         NodeBinding metaPart)

Specified by:

openMetaPart in interface KernelContext

defineHost

public HostDef defineHost(Item hostConfig)

Specified by:

defineHost in interface KernelContext

getHostDef

public HostDef getHostDef(HostAddress hostAddress)

Specified by:

getHostDef in interface KernelContext

createHost

public HostBinding createHost(PartBinding part,
                              HostDef hostDef)

Specified by:

createHost in interface KernelContext

createHost

public HostBinding createHost(HostAddress hostAddress)

Specified by:

createHost in interface KernelContext

injectHost

public HostBinding injectHost(HostAddress hostAddress,
                              HostBinding host)

Specified by:

injectHost in interface KernelContext

openMetaHost

public void openMetaHost(HostBinding host,
                         NodeBinding metaHost)

Specified by:

openMetaHost in interface KernelContext

defineNode

public NodeDef defineNode(Item nodeConfig)

Specified by:

defineNode in interface KernelContext

getNodeDef

public NodeDef getNodeDef(NodeAddress nodeAddress)

Specified by:

getNodeDef in interface KernelContext

createNode

public NodeBinding createNode(HostBinding host,
                              NodeDef nodeDef)

Specified by:

createNode in interface KernelContext

createNode

public NodeBinding createNode(NodeAddress nodeAddress)

Specified by:

createNode in interface KernelContext

injectNode

public NodeBinding injectNode(NodeAddress nodeAddress,
                              NodeBinding node)

Specified by:

injectNode in interface KernelContext

openMetaNode

public void openMetaNode(NodeBinding node,
                         NodeBinding metaNode)

Specified by:

openMetaNode in interface KernelContext

defineLane

public LaneDef defineLane(Item laneConfig)

Specified by:

defineLane in interface KernelContext

getLaneDef

public LaneDef getLaneDef(LaneAddress laneAddress)

Specified by:

getLaneDef in interface KernelContext

createLane

public LaneBinding createLane(NodeBinding node,
                              LaneDef laneDef)

Specified by:

createLane in interface KernelContext

createLane

public LaneBinding createLane(LaneAddress laneAddress)

Specified by:

createLane in interface KernelContext

injectLane

public LaneBinding injectLane(LaneAddress laneAddress,
                              LaneBinding lane)

Specified by:

injectLane in interface KernelContext

openMetaLane

public void openMetaLane(LaneBinding lane,
                         NodeBinding metaLane)

Specified by:

openMetaLane in interface KernelContext

openMetaUplink

public void openMetaUplink(LinkBinding uplink,
                           NodeBinding metaUplink)

Specified by:

openMetaUplink in interface KernelContext

openMetaDownlink

public void openMetaDownlink(LinkBinding downlink,
                             NodeBinding metaDownlink)

Specified by:

openMetaDownlink in interface KernelContext

reportDown

public void reportDown(Metric metric)

Specified by:

reportDown in interface KernelContext

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

start

public void start()

Specified by:

start in interface Kernel

stop

public void stop()

Specified by:

stop in interface Kernel

run

public void run()

Specified by:

run in interface Kernel

willStart

protected void willStart()

didStart

protected void didStart()

willStop

protected void willStop()

didStop

protected void didStop()