Skip to content
This repository has been archived by the owner on Oct 17, 2023. It is now read-only.

Messages

Dj Walker-Morgan edited this page Mar 7, 2017 · 2 revisions

Messages within Transporter are emitted by Sources as data is read and consumed by Sinks as data to be written. They are manipulated by Transformers. The Message itself is a JavaScript data object comprised of four fields.

data

This field is the root of a tree which contains the data that is being passed as part of the message. Typically, it is the root of a JSON document expanded into a key/value structure.

ns

This field contains the namespace string which is matched with the namespace parameters in the Transporter pipeline.

op

The operation that this data should be used to reflect when being written by a Sink. The op field is determined by the Source when being read and can be insert, update, delete, command or noop.

ts

The timestamp for the message. This is a Unix epoch time which reflects when the message was created.

Clone this wiki locally