FsStorm


StormTest

Namespace: global

Support for unit-testing of components

Functions and values

Function or valueDescription
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

Fork me on GitHub