Module repr

basically a wrapper around the datatype crate for basic Data Representation

Modules

relation 🔒

Structs

Row

A row is a vector of values.

Constants

BATCH_SIZE

Flow worker will try to at least accumulate this many rows before processing them(if one second haven’t passed)

BROADCAST_CAP

broadcast channel capacity, can be important to memory consumption, since this influence how many updates can be buffered in memory in the entire dataflow TODO(discord9): add config for this, so cpu&mem usage can be balanced and configured by this

SEND_BUF_CAP

The maximum capacity of the send buffer, to prevent the buffer from growing too large

Functions

value_to_internal_ts

Convert a value that is or can be converted to Datetime to internal timestamp

Type Aliases

Diff

System-wide Record count difference type. Useful for capture data change

DiffRow

Default type for a repr of changes to a collection.

Duration

System-wide default duration type, in milliseconds

KeyValDiffRow

Row with key-value pair, timestamp and diff

Timestamp

System-wide default timestamp type, in milliseconds