Module swim.system

Package swim.system.router

Class PartTable

java.lang.Object

swim.system.AbstractWarpRef

swim.system.AbstractTierBinding

swim.system.router.PartTable

All Implemented Interfaces:

DownlinkFactory, WarpRef, CellBinding, CellContext, PartBinding, TierBinding, Log

public class PartTable
extends AbstractTierBinding
implements PartBinding

Field Summary

Fields

Modifier and Type	Field	Description
protected PartContext	partContext

Fields inherited from class swim.system.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
PartTable()
PartTable(PartPredicate predicate)

Method Summary

Modifier and Type	Method	Description
protected void	accumulateHostProfile(HostProfile profile)
protected void	accumulateWarpDownlinkProfile(WarpDownlinkProfile profile)
LinkBinding	bindDownlink(Downlink downlink)
<T> T	bottomPart(Class<T> partClass)
final PartAddress	cellAddress()
void	closeDownlink(LinkBinding link)
void	closeHost(Uri hostUri)
protected PartProfile	collectProfile(long dt)
protected HostContext	createHostContext(HostAddress hostAddress, HostBinding host)
void	debug(Object message)	Logs a debug-level message.
void	didClose()
protected void	didCloseHost(HostBinding host)
void	didFail(Throwable error)
protected void	didOpenHost(HostBinding host)
protected void	didUpdateMetrics()
final String	edgeName()
void	error(Object message)	Logs an error-level message.
void	fail(Object message)	Logs an fail-level message.
protected void	flushMetrics()
HostBinding	getHost(Uri hostUri)
void	hostDidConnect(Uri hostUri)
void	hostDidDisconnect(Uri hostUri)
HashTrieMap<Uri,HostBinding>	hosts()
void	info(Object message)	Logs an info-level message.
HostBinding	master()
final MeshBinding	mesh()
final Uri	meshUri()
void	openDownlink(LinkBinding link)
HostBinding	openHost(Uri hostUri)
HostBinding	openHost(Uri hostUri, HostBinding host)
protected void	openLogLanes(PartBinding part, AgentNode metaPart)
void	openMetaDownlink(LinkBinding downlink, NodeBinding metaDownlink)
void	openMetaHost(HostBinding host, NodeBinding metaHost)
void	openMetaLane(LaneBinding lane, NodeBinding metaLane)
protected void	openMetaLanes(PartBinding part, AgentNode metaPart)
void	openMetaNode(NodeBinding node, NodeBinding metaNode)
void	openMetaPart(PartBinding part, NodeBinding metaPart)
void	openMetaUplink(LinkBinding uplink, NodeBinding metaUplink)
protected void	openReflectLanes(PartBinding part, AgentNode metaPart)
void	openUplink(LinkBinding link)
final PartContext	partContext()
final Value	partKey()
final PartBinding	partWrapper()
Policy	policy()
PartPredicate	predicate()
void	pushDown(Push<?> push)
void	pushUp(Push<?> push)
void	reopenUplinks()
void	reportDown(Metric metric)
protected void	reportMetrics(long dt)
Schedule	schedule()
void	setMaster(HostBinding master)
void	setPartContext(PartContext partContext)
Stage	stage()
StoreBinding	store()
final TierContext	tierContext()
void	trace(Object message)	Logs a trace-level message.
<T> T	unwrapPart(Class<T> partClass)
void	warn(Object message)	Logs a warn-level message.
protected void	willClose()
protected void	willLoad()
protected void	willOpen()
protected void	willStart()
protected void	willStop()
protected void	willUnload()

Methods inherited from class swim.system.AbstractTierBinding

activate, awaitStart, close, didLoad, didOpen, didStart, didStop, didUnload, isClosed, isLoaded, isOpened, isStarted, load, open, start, stop, unload

Methods inherited from class swim.system.AbstractWarpRef

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.system.TierBinding

close, isClosed, isLoaded, isOpened, isStarted, load, open, start, stop, unload

Field Details

partContext

protected PartContext partContext

Constructor Details

PartTable

public PartTable(PartPredicate predicate)

PartTable

public PartTable()

Method Details

tierContext

public final TierContext tierContext()

Specified by:

tierContext in interface TierBinding

Specified by:

tierContext in class AbstractTierBinding

mesh

public final MeshBinding mesh()

Specified by:

mesh in interface PartBinding

partWrapper

public final PartBinding partWrapper()

Specified by:

partWrapper in interface PartBinding

partContext

public final PartContext partContext()

Specified by:

partContext in interface PartBinding

setPartContext

public void setPartContext(PartContext partContext)

Specified by:

setPartContext in interface PartBinding

unwrapPart

public <T> T unwrapPart(Class<T> partClass)

Specified by:

unwrapPart in interface PartBinding

bottomPart

public <T> T bottomPart(Class<T> partClass)

Specified by:

bottomPart in interface PartBinding

createHostContext

protected HostContext createHostContext(HostAddress hostAddress,
 HostBinding host)

cellAddress

public final PartAddress cellAddress()

Specified by:

cellAddress in interface CellContext

Specified by:

cellAddress in interface PartBinding

edgeName

public final String edgeName()

Specified by:

edgeName in interface CellContext

meshUri

public final Uri meshUri()

Specified by:

meshUri in interface CellContext

Specified by:

meshUri in interface PartBinding

partKey

public final Value partKey()

Specified by:

partKey in interface PartBinding

policy

public Policy policy()

Specified by:

policy in interface CellContext

schedule

public Schedule schedule()

Specified by:

schedule in interface CellContext

stage

public Stage stage()

Specified by:

stage in interface CellContext

store

public StoreBinding store()

Specified by:

store in interface CellContext

predicate

public PartPredicate predicate()

Specified by:

predicate in interface PartBinding

openMetaPart

public void openMetaPart(PartBinding part,
 NodeBinding metaPart)

Specified by:

openMetaPart in interface PartBinding

openMetaLanes

protected void openMetaLanes(PartBinding part,
 AgentNode metaPart)

openReflectLanes

protected void openReflectLanes(PartBinding part,
 AgentNode metaPart)

openLogLanes

protected void openLogLanes(PartBinding part,
 AgentNode metaPart)

master

public HostBinding master()

Specified by:

master in interface PartBinding

setMaster

public void setMaster(HostBinding master)

Specified by:

setMaster in interface PartBinding

hosts

public HashTrieMap<Uri,HostBinding> hosts()

Specified by:

hosts in interface PartBinding

getHost

public HostBinding getHost(Uri hostUri)

Specified by:

getHost in interface PartBinding

openHost

public HostBinding openHost(Uri hostUri)

Specified by:

openHost in interface PartBinding

openHost

public HostBinding openHost(Uri hostUri,
 HostBinding host)

Specified by:

openHost in interface PartBinding

closeHost

public void closeHost(Uri hostUri)

didOpenHost

protected void didOpenHost(HostBinding host)

didCloseHost

protected void didCloseHost(HostBinding host)

hostDidConnect

public void hostDidConnect(Uri hostUri)

hostDidDisconnect

public void hostDidDisconnect(Uri hostUri)

reopenUplinks

public void reopenUplinks()

Specified by:

reopenUplinks in interface PartBinding

openMetaHost

public void openMetaHost(HostBinding host,
 NodeBinding metaHost)

Specified by:

openMetaHost in interface PartBinding

openMetaNode

public void openMetaNode(NodeBinding node,
 NodeBinding metaNode)

Specified by:

openMetaNode in interface PartBinding

openMetaLane

public void openMetaLane(LaneBinding lane,
 NodeBinding metaLane)

Specified by:

openMetaLane in interface PartBinding

openMetaUplink

public void openMetaUplink(LinkBinding uplink,
 NodeBinding metaUplink)

Specified by:

openMetaUplink in interface PartBinding

openMetaDownlink

public void openMetaDownlink(LinkBinding downlink,
 NodeBinding metaDownlink)

Specified by:

openMetaDownlink in interface CellContext

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

openUplink

public void openUplink(LinkBinding link)

Specified by:

openUplink in interface CellBinding

pushDown

public void pushDown(Push<?> push)

Specified by:

pushDown in interface CellContext

pushUp

public void pushUp(Push<?> push)

Specified by:

pushUp in interface CellBinding

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

willOpen

protected void willOpen()

Overrides:

willOpen in class AbstractTierBinding

willLoad

protected void willLoad()

Overrides:

willLoad in class AbstractTierBinding

willStart

protected void willStart()

Overrides:

willStart in class AbstractTierBinding

willStop

protected void willStop()

Overrides:

willStop in class AbstractTierBinding

willUnload

protected void willUnload()

Overrides:

willUnload in class AbstractTierBinding

willClose

protected void willClose()

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

reportDown

public void reportDown(Metric metric)

Specified by:

reportDown in interface CellContext

accumulateHostProfile

protected void accumulateHostProfile(HostProfile profile)

accumulateWarpDownlinkProfile

protected void accumulateWarpDownlinkProfile(WarpDownlinkProfile profile)

didUpdateMetrics

protected void didUpdateMetrics()

flushMetrics

protected void flushMetrics()

reportMetrics

protected void reportMetrics(long dt)

collectProfile

protected PartProfile collectProfile(long dt)