allPartitions | Striot.Partition |
allPartitionsPaired | Striot.Orchestration |
applyRule | Striot.LogicalOptimiser |
applyRules | Striot.LogicalOptimiser |
arrivalRate | Striot.Jackson |
arrivalRate' | Striot.Jackson |
arrRate | Striot.Jackson |
bandwidthLimit | Striot.CompileIoT, Striot.Orchestration |
calcAll | Striot.Jackson |
calcAllSg | Striot.Jackson |
chanSize | Striot.Nodes.Types |
chop | Striot.FunctionalProcessing, Striot.Simple |
chopAndChange | Striot.Orchestration |
chopTime | Striot.FunctionalProcessing, Striot.Simple |
complete | Striot.FunctionalProcessing, Striot.Simple |
connectedToSources | Striot.Bandwidth |
ConnectionConfig | Striot.Nodes.Types |
connectNodeId | Striot.CompileIoT |
ConnectProtocol | Striot.Nodes.Types |
connectTCP | Striot.Nodes.TCP |
ConnectType | Striot.Nodes.Types |
ConnKafkaConfig | Striot.Nodes.Types |
ConnMQTTConfig | Striot.Nodes.Types |
ConnTCPConfig | Striot.Nodes.Types |
Cost | Striot.Orchestration |
createPartitions | Striot.CompileIoT |
custInSys | Striot.Jackson |
dataEvent | Striot.FunctionalIoTtypes, Striot.Simple |
defaultConfig | Striot.Nodes |
defaultLink | Striot.Nodes |
defaultOpts | Striot.CompileIoT, Striot.Orchestration |
defaultRewriteRules | Striot.LogicalOptimiser |
defaultSink | Striot.Nodes |
defaultSource | Striot.Nodes |
departRate | Striot.Bandwidth |
deQ | Striot.StreamGraph |
deriveInputsArray | Striot.Jackson |
derivePropagationArray | Striot.Jackson |
deriveRewritesAndPartitionings | Striot.Orchestration |
deriveServiceTimes | Striot.Jackson |
displayGraph | Striot.VizGraph |
displayGraph' | Striot.VizGraph |
displayGraphDebug | Striot.VizGraph |
displayGraphKitty | Striot.VizGraph |
displayPartitionedGraph | Striot.VizGraph |
distributeProgram | Striot.Orchestration |
EGRESS | Striot.Nodes.Types |
egressConnConfig | Striot.Nodes.Types |
Event | |
1 (Type/Class) | Striot.FunctionalIoTtypes, Striot.Simple |
2 (Data Constructor) | Striot.FunctionalIoTtypes, Striot.Simple |
EventFilter | Striot.FunctionalProcessing, Striot.Simple |
EventMap | Striot.FunctionalProcessing, Striot.Simple |
Expand | Striot.StreamGraph |
expandExpand | Striot.LogicalOptimiser |
expandFilter | Striot.LogicalOptimiser |
expandFilterAcc | Striot.LogicalOptimiser |
expandMap | Striot.LogicalOptimiser |
expandMerge | Striot.LogicalOptimiser |
expandScan | Striot.LogicalOptimiser |
Filter | Striot.StreamGraph |
FilterAcc | Striot.StreamGraph |
filterAcc | Striot.FunctionalProcessing, Striot.Simple |
filterAccFilter | Striot.LogicalOptimiser |
filterAccFilterAcc | Striot.LogicalOptimiser |
filterAccWindow | Striot.LogicalOptimiser |
filterFilterAcc | Striot.LogicalOptimiser |
filterFuse | Striot.LogicalOptimiser |
filterMerge | Striot.LogicalOptimiser |
filterWindow | Striot.LogicalOptimiser |
firstMatch | Striot.LogicalOptimiser |
genDockerfile | Striot.CompileIoT |
generateCode | Striot.CompileIoT |
generateCodeFromStreamGraph | Striot.CompileIoT |
generateNodeSrc | Striot.CompileIoT |
GenerateOpts | |
1 (Type/Class) | Striot.CompileIoT, Striot.Orchestration |
2 (Data Constructor) | Striot.CompileIoT, Striot.Orchestration |
HasStriotConfig | Striot.Nodes.Types |
host | Striot.Nodes.Types |
howBig | Striot.Bandwidth |
htf_Striot_CompileIoT_thisModulesTests | Striot.CompileIoT |
htf_Striot_FunctionalProcessing_thisModulesTests | Striot.FunctionalProcessing, Striot.Simple |
htf_Striot_Jackson_thisModulesTests | Striot.Jackson |
htf_Striot_LogicalOptimiser_thisModulesTests | Striot.LogicalOptimiser |
htf_Striot_Orchestration_thisModulesTests | Striot.Orchestration |
htf_Striot_Partition_thisModulesTests | Striot.Partition |
htf_Striot_StreamGraph_thisModulesTests | Striot.StreamGraph |
htf_Striot_VizGraph_thisModulesTests | Striot.VizGraph |
imports | Striot.CompileIoT, Striot.Orchestration |
INGRESS | Striot.Nodes.Types |
ingressConnConfig | Striot.Nodes.Types |
intype | Striot.StreamGraph |
isOverUtilised | Striot.Jackson |
isSource | Striot.StreamGraph |
jacksonGraphToDot | Striot.VizGraph |
Join | Striot.StreamGraph |
JoinFilter | Striot.FunctionalProcessing, Striot.Simple |
JoinMap | Striot.FunctionalProcessing, Striot.Simple |
KAFKA | Striot.Nodes.Types |
KafkaConfig | |
1 (Type/Class) | Striot.Nodes.Types |
2 (Data Constructor) | Striot.Nodes.Types |
kafkaConGroup | Striot.Nodes.Types |
kafkaConn | Striot.Nodes.Types |
kafkaTopic | Striot.Nodes.Types |
knownEventSizes | Striot.Bandwidth |
Map | Striot.StreamGraph |
mapFilter | Striot.LogicalOptimiser |
mapFilterAcc | Striot.LogicalOptimiser |
mapFuse | Striot.LogicalOptimiser |
mapMerge | Striot.LogicalOptimiser |
mapScan | Striot.LogicalOptimiser |
mapWindow | Striot.LogicalOptimiser |
maxNodeUtil | Striot.CompileIoT, Striot.Orchestration |
Merge | Striot.StreamGraph |
mergeExpand | Striot.LogicalOptimiser |
mergeFilter | Striot.LogicalOptimiser |
mergeFuse | Striot.LogicalOptimiser |
mergeMap | Striot.LogicalOptimiser |
Metrics | |
1 (Type/Class) | Striot.Nodes.Types |
2 (Data Constructor) | Striot.Nodes.Types |
mkStream | Striot.Nodes, Striot.Simple |
MQTT | Striot.Nodes.Types |
MQTTConfig | |
1 (Type/Class) | Striot.Nodes.Types |
2 (Data Constructor) | Striot.Nodes.Types |
mqttConn | Striot.Nodes.Types |
mqttTopic | Striot.Nodes.Types |
nc | Striot.Nodes.Types |
NetConfig | |
1 (Type/Class) | Striot.Nodes.Types |
2 (Data Constructor) | Striot.Nodes.Types |
nodeFn | Striot.CompileIoT |
nodeLink | Striot.Nodes |
nodeLink2 | Striot.Nodes |
nodeName | Striot.Nodes.Types |
nodeSimple | Striot.Nodes, Striot.Simple |
nodeSink | Striot.Nodes |
nodeSink2 | Striot.Nodes |
nodeSource | Striot.Nodes |
nodeType | Striot.CompileIoT |
operator | Striot.StreamGraph |
OperatorInfo | |
1 (Type/Class) | Striot.Jackson |
2 (Data Constructor) | Striot.Jackson |
opId | Striot.Jackson |
outputRate | Striot.Jackson |
outtype | Striot.StreamGraph |
overBandwidthLimit | Striot.Bandwidth |
packages | Striot.CompileIoT, Striot.Orchestration |
parameters | Striot.StreamGraph |
Partition | Striot.CompileIoT |
PartitionedGraph | Striot.StreamGraph |
partitionedGraphToDot | Striot.VizGraph |
partitionGraph | Striot.CompileIoT, Striot.Orchestration |
PartitionMap | Striot.CompileIoT |
Plan | Striot.Orchestration |
planCost | Striot.Orchestration |
port | Striot.Nodes.Types |
preSource | Striot.CompileIoT, Striot.Orchestration |
processSocket | Striot.Nodes.TCP |
queueTime | Striot.Jackson |
readConf | Striot.Nodes.Types |
respTime | Striot.Jackson |
RewriteRule | Striot.LogicalOptimiser |
rules | Striot.CompileIoT, Striot.Orchestration |
runKafkaConsumer | Striot.Nodes.Kafka |
runMQTTSub | Striot.Nodes.MQTT |
Scan | Striot.StreamGraph |
sendStreamKafka | Striot.Nodes.Kafka |
sendStreamMQTT | Striot.Nodes.MQTT |
sendStreamTCP | Striot.Nodes.TCP |
serviceTime | |
1 (Function) | Striot.StreamGraph |
2 (Function) | Striot.Jackson |
showParam | Striot.StreamGraph |
simpleStream | Striot.StreamGraph, Striot.Orchestration |
singleton | Striot.Partition |
Sink | Striot.StreamGraph |
sliding | Striot.FunctionalProcessing, Striot.Simple |
slidingTime | Striot.FunctionalProcessing, Striot.Simple |
Source | Striot.StreamGraph |
stab | Striot.Jackson |
Stream | Striot.FunctionalIoTtypes, Striot.Simple |
streamExpand | Striot.FunctionalProcessing, Striot.Simple |
streamFilter | Striot.FunctionalProcessing, Striot.Simple |
streamFilterAcc | Striot.FunctionalProcessing, Striot.Simple |
StreamGraph | Striot.StreamGraph |
streamgraph | Striot.StreamGraph |
streamgraph' | Striot.StreamGraph |
streamGraphToDot | Striot.VizGraph |
streamJoin | Striot.FunctionalProcessing, Striot.Simple |
streamJoinE | Striot.FunctionalProcessing, Striot.Simple |
streamJoinW | Striot.FunctionalProcessing, Striot.Simple |
streamMap | Striot.FunctionalProcessing, Striot.Simple |
streamMerge | Striot.FunctionalProcessing, Striot.Simple |
StreamOperator | Striot.StreamGraph |
streamScan | Striot.FunctionalProcessing, Striot.Simple |
StreamVertex | |
1 (Type/Class) | Striot.StreamGraph |
2 (Data Constructor) | Striot.StreamGraph |
streamWindow | Striot.FunctionalProcessing, Striot.Simple |
streamWindowAggregate | Striot.FunctionalProcessing, Striot.Simple |
StriotApp | |
1 (Type/Class) | Striot.Nodes.Types |
2 (Data Constructor) | Striot.Nodes.Types |
StriotConfig | |
1 (Type/Class) | Striot.Nodes.Types |
2 (Data Constructor) | Striot.Nodes.Types |
striotConfig | Striot.Nodes.Types |
subGraphToPartition | Striot.VizGraph |
taxiQ1Array | Striot.Jackson |
taxiQ1arrivalRates | Striot.Jackson |
taxiQ1Calc | Striot.Jackson |
taxiQ1Inputs | Striot.Jackson |
taxiQ1meanServiceTimes | Striot.Jackson |
taxiQ1utilisation | Striot.Jackson |
TCP | Striot.Nodes.Types |
TCPConfig | |
1 (Type/Class) | Striot.Nodes.Types |
2 (Data Constructor) | Striot.Nodes.Types |
tcpConn | Striot.Nodes.Types |
time | Striot.FunctionalIoTtypes, Striot.Simple |
timedEvent | Striot.FunctionalIoTtypes, Striot.Simple |
Timestamp | Striot.FunctionalIoTtypes, Striot.Simple |
unApp | Striot.Nodes.Types |
unStream | Striot.Nodes, Striot.Simple |
util | Striot.Jackson |
value | Striot.FunctionalIoTtypes, Striot.Simple |
vertexId | Striot.StreamGraph |
viableRewrites | Striot.Orchestration |
whatBandwidth | Striot.Bandwidth |
whatBandwidthWeighted | Striot.Bandwidth |
Window | Striot.StreamGraph |
WindowAggregator | Striot.FunctionalProcessing, Striot.Simple |
WindowMaker | Striot.FunctionalProcessing, Striot.Simple |
writeConf | Striot.Nodes.Types |
writeGraph | Striot.VizGraph |
writePart | Striot.CompileIoT |
_chanSize | Striot.Nodes.Types |
_egressBytes | Striot.Nodes.Types |
_egressConn | Striot.Nodes.Types |
_egressConnConfig | Striot.Nodes.Types |
_egressEvents | Striot.Nodes.Types |
_host | Striot.Nodes.Types |
_ingressBytes | Striot.Nodes.Types |
_ingressConn | Striot.Nodes.Types |
_ingressConnConfig | Striot.Nodes.Types |
_ingressEvents | Striot.Nodes.Types |
_kafkaConGroup | Striot.Nodes.Types |
_kafkaConn | Striot.Nodes.Types |
_kafkaTopic | Striot.Nodes.Types |
_mqttConn | Striot.Nodes.Types |
_mqttTopic | Striot.Nodes.Types |
_nodeName | Striot.Nodes.Types |
_port | Striot.Nodes.Types |
_tcpConn | Striot.Nodes.Types |