core blocks

[nytlabs]

core blocks

[mikedewar]

Pusher, Sink

The pusher block emits a constant stream of messages. The message can be set by setting the value input to something. Sink discards any message it receives immediately upon receipt.

-- update
don't need a pusher, because every inbound route can essentially act as a pushed. Do need a sink, though, as messages won't be automatically discarded on unconnected routes.

[mikedewar]

Delay

Upon receiving a message Delay blocks for a specified duration before emitting the message.

[mikedewar]

Log

Log writes inbound messages to stdout (or somewhere).

[mikedewar]

+ - × ÷ ^ %

These basic operators operate on two inputs, returning the output of the operation or an error on type failure.

[mikedewar]

> < == !=

These comparisons operate on two inputs, returning a boolean or an error on type failure.

[mikedewar]

inArray, inObject, inString, hasPrefix, hasSuffix

These membership operators operate on a value and an array/object/string returning a boolean or an error on type failure. Note that inObject is a bit vague and maybe "hasField" or something like that might be better...?

[mikedewar]

Latch

A latch has a value input and a control input, and left and right outputs. If the control input is true, then the value will be emitted on the left output. If the control input is false the value will be emitted from the right output.

[mikedewar]

kvGet, kvSet, kvDump, kvClear

These blocks perform get, set and dump operations against a key-value store. Get accepts a key and emits a value, Set accepts a key and a value, Dump responds to a bang with the whole key-value store as an object.

[mikedewar]

pqPush, pqPop, pqPeek, pqLen, pqClear, pqDump

These blocks perform push, pop, and peek operations against a key-value store. Push accepts a value and a priority, pop responds to a bang and removes the last value from the queue before emitting, and peek responds to a bang, returning an object containing the last value and its priority.

[mikedewar]

Uniform, Zipf, Poisson, Categorical, Gaussian, Bernoulli

These blocks emit a random number in response to a bang

[mikedewar]

exp, log10, ln, sqrt, sin, cos, tan

These blocks perform a single operation on an inbound number emitting the result or error on a type problem.

[mikedewar]

toLower, toUpper, toTitle

These blocks perform a single operation on an inbound string, emitting the result or error on type failure.

[mikedewar]

fields

Outputs the fields of an inbound object as an array. Emits a type error if the inbound message is not an object. Could be called "keys" instead depending where we end up with the vocabulary. I think I prefer fields but I've not had any coffee yet.

[mikedewar]

set

Set has two inputs, a key and a value, and it outputs the object key:value.

[mikedewar]

merge

Merge has two inputs, both expecting objects. The Merge block creates a new object by combining the two inbound objects at the root of the block, favouring the left input for any conflicts.

[mikedewar]

gate

Gate has two inputs, value and trigger. When messages exist at value and trigger, the value is emitted.

[mikedewar]

append

Append has two inputs, array and value. When messages exist at both inputs, the value is appended to the array.

[mikedewar]

first

First emits the first N values it sees.

[mikedewar]

qPush, qPop, qPeek, qLen, qClear, qDump

These blocks perform operations on a queue, analogous the priority queue.

[mikedewar]

identity

This block has a single input and a single output and does nothing.

[mikedewar]

head, tail

head accepts an array and has two outputs. One output emits the first element in the array and the other output emits the remainder of the array. The empty array will cause nothing to be emitted on either outbound channel.

Tail does the opposite.

[mikedewar]

JSONUmarshal, XMLUnmarshal

These accept strings and try to turn them into map[string]interface{}s, accordingly. Failure to unmarshal results in emitting an error.

[nikhan]

💃