striot-0.1.1.0

Index

allPartitionsStriot.Partition
allPartitionsPairedStriot.Orchestration
applyRuleStriot.LogicalOptimiser
applyRulesStriot.LogicalOptimiser
arrivalRateStriot.Jackson
arrivalRate'Striot.Jackson
arrRateStriot.Jackson
bandwidthLimitStriot.CompileIoT, Striot.Orchestration
calcAllStriot.Jackson
calcAllSgStriot.Jackson
chanSizeStriot.Nodes.Types
chopStriot.FunctionalProcessing, Striot.Simple
chopAndChangeStriot.Orchestration
chopTimeStriot.FunctionalProcessing, Striot.Simple
completeStriot.FunctionalProcessing, Striot.Simple
connectedToSourcesStriot.Bandwidth
ConnectionConfigStriot.Nodes.Types
connectNodeIdStriot.CompileIoT
ConnectProtocolStriot.Nodes.Types
connectTCPStriot.Nodes.TCP
ConnectTypeStriot.Nodes.Types
ConnKafkaConfigStriot.Nodes.Types
ConnMQTTConfigStriot.Nodes.Types
ConnTCPConfigStriot.Nodes.Types
CostStriot.Orchestration
createPartitionsStriot.CompileIoT
custInSysStriot.Jackson
dataEventStriot.FunctionalIoTtypes, Striot.Simple
defaultConfigStriot.Nodes
defaultLinkStriot.Nodes
defaultOptsStriot.CompileIoT, Striot.Orchestration
defaultRewriteRulesStriot.LogicalOptimiser
defaultSinkStriot.Nodes
defaultSourceStriot.Nodes
departRateStriot.Bandwidth
deQStriot.StreamGraph
deriveInputsArrayStriot.Jackson
derivePropagationArrayStriot.Jackson
deriveRewritesAndPartitioningsStriot.Orchestration
deriveServiceTimesStriot.Jackson
displayGraphStriot.VizGraph
displayGraph'Striot.VizGraph
displayGraphDebugStriot.VizGraph
displayGraphKittyStriot.VizGraph
displayPartitionedGraphStriot.VizGraph
distributeProgramStriot.Orchestration
EGRESSStriot.Nodes.Types
egressConnConfigStriot.Nodes.Types
Event 
1 (Type/Class)Striot.FunctionalIoTtypes, Striot.Simple
2 (Data Constructor)Striot.FunctionalIoTtypes, Striot.Simple
EventFilterStriot.FunctionalProcessing, Striot.Simple
EventMapStriot.FunctionalProcessing, Striot.Simple
ExpandStriot.StreamGraph
expandExpandStriot.LogicalOptimiser
expandFilterStriot.LogicalOptimiser
expandFilterAccStriot.LogicalOptimiser
expandMapStriot.LogicalOptimiser
expandMergeStriot.LogicalOptimiser
expandScanStriot.LogicalOptimiser
FilterStriot.StreamGraph
FilterAccStriot.StreamGraph
filterAccStriot.FunctionalProcessing, Striot.Simple
filterAccFilterStriot.LogicalOptimiser
filterAccFilterAccStriot.LogicalOptimiser
filterAccWindowStriot.LogicalOptimiser
filterFilterAccStriot.LogicalOptimiser
filterFuseStriot.LogicalOptimiser
filterMergeStriot.LogicalOptimiser
filterWindowStriot.LogicalOptimiser
firstMatchStriot.LogicalOptimiser
genDockerfileStriot.CompileIoT
generateCodeStriot.CompileIoT
generateCodeFromStreamGraphStriot.CompileIoT
generateNodeSrcStriot.CompileIoT
GenerateOpts 
1 (Type/Class)Striot.CompileIoT, Striot.Orchestration
2 (Data Constructor)Striot.CompileIoT, Striot.Orchestration
HasStriotConfigStriot.Nodes.Types
hostStriot.Nodes.Types
howBigStriot.Bandwidth
htf_Striot_CompileIoT_thisModulesTestsStriot.CompileIoT
htf_Striot_FunctionalProcessing_thisModulesTestsStriot.FunctionalProcessing, Striot.Simple
htf_Striot_Jackson_thisModulesTestsStriot.Jackson
htf_Striot_LogicalOptimiser_thisModulesTestsStriot.LogicalOptimiser
htf_Striot_Orchestration_thisModulesTestsStriot.Orchestration
htf_Striot_Partition_thisModulesTestsStriot.Partition
htf_Striot_StreamGraph_thisModulesTestsStriot.StreamGraph
htf_Striot_VizGraph_thisModulesTestsStriot.VizGraph
importsStriot.CompileIoT, Striot.Orchestration
INGRESSStriot.Nodes.Types
ingressConnConfigStriot.Nodes.Types
intypeStriot.StreamGraph
isOverUtilisedStriot.Jackson
isSourceStriot.StreamGraph
jacksonGraphToDotStriot.VizGraph
JoinStriot.StreamGraph
JoinFilterStriot.FunctionalProcessing, Striot.Simple
JoinMapStriot.FunctionalProcessing, Striot.Simple
KAFKAStriot.Nodes.Types
KafkaConfig 
1 (Type/Class)Striot.Nodes.Types
2 (Data Constructor)Striot.Nodes.Types
kafkaConGroupStriot.Nodes.Types
kafkaConnStriot.Nodes.Types
kafkaTopicStriot.Nodes.Types
knownEventSizesStriot.Bandwidth
MapStriot.StreamGraph
mapFilterStriot.LogicalOptimiser
mapFilterAccStriot.LogicalOptimiser
mapFuseStriot.LogicalOptimiser
mapMergeStriot.LogicalOptimiser
mapScanStriot.LogicalOptimiser
mapWindowStriot.LogicalOptimiser
maxNodeUtilStriot.CompileIoT, Striot.Orchestration
MergeStriot.StreamGraph
mergeExpandStriot.LogicalOptimiser
mergeFilterStriot.LogicalOptimiser
mergeFuseStriot.LogicalOptimiser
mergeMapStriot.LogicalOptimiser
Metrics 
1 (Type/Class)Striot.Nodes.Types
2 (Data Constructor)Striot.Nodes.Types
mkStreamStriot.Nodes, Striot.Simple
MQTTStriot.Nodes.Types
MQTTConfig 
1 (Type/Class)Striot.Nodes.Types
2 (Data Constructor)Striot.Nodes.Types
mqttConnStriot.Nodes.Types
mqttTopicStriot.Nodes.Types
ncStriot.Nodes.Types
NetConfig 
1 (Type/Class)Striot.Nodes.Types
2 (Data Constructor)Striot.Nodes.Types
nodeFnStriot.CompileIoT
nodeLinkStriot.Nodes
nodeLink2Striot.Nodes
nodeNameStriot.Nodes.Types
nodeSimpleStriot.Nodes, Striot.Simple
nodeSinkStriot.Nodes
nodeSink2Striot.Nodes
nodeSourceStriot.Nodes
nodeTypeStriot.CompileIoT
operatorStriot.StreamGraph
OperatorInfo 
1 (Type/Class)Striot.Jackson
2 (Data Constructor)Striot.Jackson
opIdStriot.Jackson
outputRateStriot.Jackson
outtypeStriot.StreamGraph
overBandwidthLimitStriot.Bandwidth
packagesStriot.CompileIoT, Striot.Orchestration
parametersStriot.StreamGraph
PartitionStriot.CompileIoT
PartitionedGraphStriot.StreamGraph
partitionedGraphToDotStriot.VizGraph
partitionGraphStriot.CompileIoT, Striot.Orchestration
PartitionMapStriot.CompileIoT
PlanStriot.Orchestration
planCostStriot.Orchestration
portStriot.Nodes.Types
preSourceStriot.CompileIoT, Striot.Orchestration
processSocketStriot.Nodes.TCP
queueTimeStriot.Jackson
readConfStriot.Nodes.Types
respTimeStriot.Jackson
RewriteRuleStriot.LogicalOptimiser
rulesStriot.CompileIoT, Striot.Orchestration
runKafkaConsumerStriot.Nodes.Kafka
runMQTTSubStriot.Nodes.MQTT
ScanStriot.StreamGraph
sendStreamKafkaStriot.Nodes.Kafka
sendStreamMQTTStriot.Nodes.MQTT
sendStreamTCPStriot.Nodes.TCP
serviceTime 
1 (Function)Striot.StreamGraph
2 (Function)Striot.Jackson
showParamStriot.StreamGraph
simpleStreamStriot.StreamGraph, Striot.Orchestration
singletonStriot.Partition
SinkStriot.StreamGraph
slidingStriot.FunctionalProcessing, Striot.Simple
slidingTimeStriot.FunctionalProcessing, Striot.Simple
SourceStriot.StreamGraph
stabStriot.Jackson
StreamStriot.FunctionalIoTtypes, Striot.Simple
streamExpandStriot.FunctionalProcessing, Striot.Simple
streamFilterStriot.FunctionalProcessing, Striot.Simple
streamFilterAccStriot.FunctionalProcessing, Striot.Simple
StreamGraphStriot.StreamGraph
streamgraphStriot.StreamGraph
streamgraph'Striot.StreamGraph
streamGraphToDotStriot.VizGraph
streamJoinStriot.FunctionalProcessing, Striot.Simple
streamJoinEStriot.FunctionalProcessing, Striot.Simple
streamJoinWStriot.FunctionalProcessing, Striot.Simple
streamMapStriot.FunctionalProcessing, Striot.Simple
streamMergeStriot.FunctionalProcessing, Striot.Simple
StreamOperatorStriot.StreamGraph
streamScanStriot.FunctionalProcessing, Striot.Simple
StreamVertex 
1 (Type/Class)Striot.StreamGraph
2 (Data Constructor)Striot.StreamGraph
streamWindowStriot.FunctionalProcessing, Striot.Simple
streamWindowAggregateStriot.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
striotConfigStriot.Nodes.Types
subGraphToPartitionStriot.VizGraph
taxiQ1ArrayStriot.Jackson
taxiQ1arrivalRatesStriot.Jackson
taxiQ1CalcStriot.Jackson
taxiQ1InputsStriot.Jackson
taxiQ1meanServiceTimesStriot.Jackson
taxiQ1utilisationStriot.Jackson
TCPStriot.Nodes.Types
TCPConfig 
1 (Type/Class)Striot.Nodes.Types
2 (Data Constructor)Striot.Nodes.Types
tcpConnStriot.Nodes.Types
timeStriot.FunctionalIoTtypes, Striot.Simple
timedEventStriot.FunctionalIoTtypes, Striot.Simple
TimestampStriot.FunctionalIoTtypes, Striot.Simple
unAppStriot.Nodes.Types
unStreamStriot.Nodes, Striot.Simple
utilStriot.Jackson
valueStriot.FunctionalIoTtypes, Striot.Simple
vertexIdStriot.StreamGraph
viableRewritesStriot.Orchestration
whatBandwidthStriot.Bandwidth
whatBandwidthWeightedStriot.Bandwidth
WindowStriot.StreamGraph
WindowAggregatorStriot.FunctionalProcessing, Striot.Simple
WindowMakerStriot.FunctionalProcessing, Striot.Simple
writeConfStriot.Nodes.Types
writeGraphStriot.VizGraph
writePartStriot.CompileIoT
_chanSizeStriot.Nodes.Types
_egressBytesStriot.Nodes.Types
_egressConnStriot.Nodes.Types
_egressConnConfigStriot.Nodes.Types
_egressEventsStriot.Nodes.Types
_hostStriot.Nodes.Types
_ingressBytesStriot.Nodes.Types
_ingressConnStriot.Nodes.Types
_ingressConnConfigStriot.Nodes.Types
_ingressEventsStriot.Nodes.Types
_kafkaConGroupStriot.Nodes.Types
_kafkaConnStriot.Nodes.Types
_kafkaTopicStriot.Nodes.Types
_mqttConnStriot.Nodes.Types
_mqttTopicStriot.Nodes.Types
_nodeNameStriot.Nodes.Types
_portStriot.Nodes.Types
_tcpConnStriot.Nodes.Types