KSLCore/ksl.modeling.station/NetworkBuilder

NetworkBuilder

The receiver scope for queueingNetwork. Provides node-creation functions and routing operators. Routing targets may be given as live references or, for the string overloads, as node names resolved after the block completes (enabling forward references such as rework loops declared before their target).

Types

ConditionBuilder

class ConditionBuilder

Scope for declaring predicate-based routing cases.

Properties

network

val network: StationNetwork

The network being built; also its read-only view via StationNetworkCIfc.

Functions

batch

fun batch(name: String, batchSize: Int, nextReceiver: QObjectReceiverIfc = NotImplementedReceiver): BatchStation

Declares a batch-forming station. See StationNetwork.batchStation.

blocking

fun blocking(name: String, bufferCapacity: Int, activityTime: RVariableIfc, nextReceiver: QObjectReceiverIfc = NotImplementedReceiver): BlockingStation

Declares a finite-buffer blocking station. See StationNetwork.blockingStation.

delay

fun delay(name: String, activityTime: RVariableIfc = ConstantRV.ZERO, nextReceiver: QObjectReceiverIfc = NotImplementedReceiver): ActivityStation

Declares a pure-delay (infinite-server) station. See StationNetwork.activityStation.

fork

fun fork(name: String, join: JoinStation, childCount: ChildCountIfc, childFactory: ChildFactoryIfc? = null, childReceiver: QObjectReceiverIfc = NotImplementedReceiver, nextReceiver: QObjectReceiverIfc = NotImplementedReceiver): ForkStation

Declares the fork side of a fork-join pair. See StationNetwork.forkStation.

gate

fun gate(name: String, nextReceiver: QObjectReceiverIfc = NotImplementedReceiver, initiallyOpen: Boolean = true): GateStation

Declares a gate station (holds instances while closed). See StationNetwork.gateStation.

join

fun join(name: String, nextReceiver: QObjectReceiverIfc = NotImplementedReceiver): JoinStation

Declares the join side of a fork-join pair. See StationNetwork.joinStation.

nhppSource

fun nhppSource(name: String, durations: DoubleArray, rates: DoubleArray, firstReceiver: QObjectReceiverIfc = NotImplementedReceiver, streamNum: Int = 0, maxArrivals: Long = Long.MAX_VALUE, marking: (ModelElement.QObject) -> Unit? = null): NHPPSource

Declares a non-homogeneous Poisson arrival source from parallel durations and rates arrays. See StationNetwork.nhppSource.

pool

fun pool(name: String, capacity: Int = 1): SResourcePool

Declares a shared resource pool. See StationNetwork.resourcePool.

pooledStation

fun pooledStation(name: String, pool: SResourcePool, activityTime: RVariableIfc = ConstantRV.ZERO, nextReceiver: QObjectReceiverIfc = NotImplementedReceiver): ResourcePoolStation

Declares a station that seizes from a shared pool. See StationNetwork.resourcePoolStation.

release

fun release(name: String, resource: SResource, nextReceiver: QObjectReceiverIfc = NotImplementedReceiver): ReleaseStation

Declares an atomic release station. See StationNetwork.releaseStation.

resource

fun resource(name: String, capacity: Int = 1): SResource

Declares a free-standing resource. See StationNetwork.resource.

route

fun route(name: String, vararg steps: QObjectReceiverIfc): Route

Declares and registers a named Route over the given ordered steps.

routeByChance

fun Station.routeByChance(vararg branches: Pair<Double, QObjectReceiverIfc>, streamNum: Int = 0)

Routes probabilistically among branches (each probability to receiver). Probabilities must sum to 1.0.

routeByCondition

fun Station.routeByCondition(default: QObjectReceiverIfc, block: NetworkBuilder.ConditionBuilder.() -> Unit)

Routes by predicate, first match wins, falling back to default.

routeByType

fun Station.routeByType(vararg branches: Pair<Int, QObjectReceiverIfc>, default: QObjectReceiverIfc)

Routes by the instance's ModelElement.QObject.qObjectType among branches, falling back to default.

routeRoundRobinOf

fun Station.routeRoundRobinOf(vararg receivers: QObjectReceiverIfc)

Routes to receivers in cyclic (round-robin) order.

routeTo

infix fun SourceStation.routeTo(nodeName: String)

Routes a source's output to the node registered under nodeName (resolved after the block).

infix fun SourceStation.routeTo(receiver: QObjectReceiverIfc)

Routes a source's output directly to receiver.

infix fun Station.routeTo(nodeName: String)

Routes a station's output to the node registered under nodeName (resolved after the block).

infix fun Station.routeTo(receiver: QObjectReceiverIfc)

Routes a station's output directly to receiver.

routeToShortestQueueOf

fun Station.routeToShortestQueueOf(vararg stations: Station)

Routes to whichever of stations currently has the least work in process.

seize

fun seize(name: String, resource: SResource, amount: Int = 1, nextReceiver: QObjectReceiverIfc = NotImplementedReceiver): SeizeStation

Declares an atomic seize station. See StationNetwork.seizeStation.

separate

fun separate(name: String, nextReceiver: QObjectReceiverIfc = NotImplementedReceiver): SeparateStation

Declares a batch-separating station. See StationNetwork.separateStation.

sink

fun sink(name: String): SinkStation

Declares a disposal sink. See StationNetwork.sink.

source

fun source(name: String, interArrivalRV: RVariableIfc, firstReceiver: QObjectReceiverIfc = NotImplementedReceiver, timeUntilFirstRV: RVariableIfc = interArrivalRV, maxArrivals: Long = Long.MAX_VALUE, qObjectClass: QObjectClass? = null, marking: (ModelElement.QObject) -> Unit? = null): SourceStation

Declares an arrival source. See StationNetwork.source.

station

fun station(name: String, activityTime: RVariableIfc = ConstantRV.ZERO, capacity: Int = 1, nextReceiver: QObjectReceiverIfc = NotImplementedReceiver): SingleQStation

Declares a single-queue station. See StationNetwork.singleQStation.