Dispatch (FsShelter) | FsShelter

Dispatch Module

Namespace: FsShelter
Assembly: FsShelter.dll

Dispatch functions for spouts and bolts

Functions and values

Function or value	Description
`autoAckBolt mkArgs consume (getAnchors, act, deact) getStream conf out` Full Usage: `autoAckBolt mkArgs consume (getAnchors, act, deact) getStream conf out` Parameters: mkArgs : `(LogLevel -> string -> unit) -> 'a -> 'b -> ('c -> unit) -> 'd` consume : `'d -> unit` getAnchors : `string * string -> TupleId -> TupleId list` act : `'b option` deact : `'b option` getStream : `'c -> string` conf : `'a` out : `OutCommand<'c> -> unit` Returns: `InCommand<'b> -> unit` Type parameters: 'a, 'b, 'c, 'd	Dispatch bolt commands and auto ack/nack handled messages mkArgs : `(LogLevel -> string -> unit) -> 'a -> 'b -> ('c -> unit) -> 'd` consume : `'d -> unit` getAnchors : `string * string -> TupleId -> TupleId list` act : `'b option` deact : `'b option` getStream : `'c -> string` conf : `'a` out : `OutCommand<'c> -> unit` Returns: `InCommand<'b> -> unit`
`autoNackBolt mkArgs consume conf out` Full Usage: `autoNackBolt mkArgs consume conf out` Parameters: mkArgs : `(LogLevel -> string -> unit) -> 'a -> 'b -> 'c` consume : `'c -> unit` conf : `'a` out : `OutCommand<'d> -> unit` Returns: `InCommand<'b> -> unit` Type parameters: 'a, 'b, 'c, 'd	Dispatch bolt commands and auto-nack all incoming messages mkArgs : `(LogLevel -> string -> unit) -> 'a -> 'b -> 'c` consume : `'c -> unit` conf : `'a` out : `OutCommand<'d> -> unit` Returns: `InCommand<'b> -> unit`
`reliableSpout mkArgs mkAcker deactivate next getStream conf out` Full Usage: `reliableSpout mkArgs mkAcker deactivate next getStream conf out` Parameters: mkArgs : `(LogLevel -> string -> unit) -> 'a -> 'b` mkAcker : `'b -> (TupleId -> unit) * (TupleId -> unit)` deactivate : `'b -> unit` next : `'b -> (TupleId * 'c) option` getStream : `'c -> string` conf : `'a` out : `OutCommand<'c> -> unit` Returns: `InCommand<'d> -> unit` Type parameters: 'a, 'b, 'c, 'd	Dispatch spout commands and handle acknowledgements mkArgs : `(LogLevel -> string -> unit) -> 'a -> 'b` mkAcker : `'b -> (TupleId -> unit) * (TupleId -> unit)` deactivate : `'b -> unit` next : `'b -> (TupleId * 'c) option` getStream : `'c -> string` conf : `'a` out : `OutCommand<'c> -> unit` Returns: `InCommand<'d> -> unit`
`unreliableSpout mkArgs deactivate next getStream conf out` Full Usage: `unreliableSpout mkArgs deactivate next getStream conf out` Parameters: mkArgs : `(LogLevel -> string -> unit) -> 'a -> 'b` deactivate : `'b -> unit` next : `'b -> 'c option` getStream : `'c -> string` conf : `'a` out : `OutCommand<'c> -> unit` Returns: `InCommand<'d> -> unit` Type parameters: 'a, 'b, 'c, 'd	Dispatch commands for spouts that don't provide unique ids to emitted tuples mkArgs : `(LogLevel -> string -> unit) -> 'a -> 'b` deactivate : `'b -> unit` next : `'b -> 'c option` getStream : `'c -> string` conf : `'a` out : `OutCommand<'c> -> unit` Returns: `InCommand<'d> -> unit`