StormTest
Namespace: global
Support for unit-testing of components
Functions and values
| Function or value | Description |
autoAckBoltRunner (...)
Signature: testData:seq<Json> -> stormAck:(String -> unit) -> fReaderCreator:(Json -> Async<unit>) -> Async<unit>
|
test bolt runner that auto acks received msgs |
heartbeat
Signature: Json
|
multilang empty tuple for heartbeat stream |
next
Signature: Json
|
multilang next command |
parallelAutoAckBoltRunner (...)
Signature: testData:seq<Json> -> stormAck:(String -> unit) -> fReaderCreator:(Json -> Async<unit>) -> Async<unit>
|
test bolt runner that auto acks received msgs in parallel |
reliableSpoutRunner (...)
Signature: reliableEmit:((Json -> unit) -> '?7165) -> cmds:seq<Json> -> housekeeper:(Json -> unit) -> fCreateEmitter:('?7165 -> unit -> Async<unit>) -> Async<unit>
Type parameters: '?7165 |
test runner for reliable spouts |
simpleSpoutRunner (...)
Signature: emit:'?7167 -> cmds:seq<Json> -> fCreateEmitter:('?7167 -> unit -> Async<unit>) -> Async<unit>
Type parameters: '?7167 |
test runner loop for simple spouts |
src name msg
Signature: name:'?7171 -> msg:Json -> Json
Type parameters: '?7171 |
source the tuple - set the comp propery |
