blocks

Each block is briefly detailed below, along with the rules that define each block.

generator blocks

These blocks emit messages on their own.

• ticker. This block emits the time regularly. The time between emissions is specified by the Interval.
  • Rules:
    • Interval: duration string (1s)

flow blocks

These blocks are useful for shaping the stream in one way or another

• join
• map
• mask
• filter
• pack
• unpack
• sync
• gethttp

source blocks

These blocks hook into another system and collect messages to be emitted into streamtools.

• fromhttpstream
• fromnsq
  • Rules:
    • ReadTopic:
    • LookupdAddr:
    • ReadChannel:
    • MaxInFlight: (0)
• frompost
• fromsqs
• fromudp
• fromwebsocket

sink blocks

These blocks send data to external systems.

• toelasticsearch
• tofile
• tolog
• tonsq
• tonsqmulti
• towebsocket

state blocks

These blocks maintain a state, storing something about the stream of data

• histogram
• count
• timeseries
• set
• movingaverage

random number blocks

These blocks emit random numbers when polled.

• zipf
• poisson
• gaussian