GenerateSQLAndApply generates the SQL query for either creating or altering the Clickhouse schema for a given table and makes the given changes to the database.

GetDataByChannel transforms a slice of messages and return a map where they are grouped by <_channel>.

GetStorableData gets a list of transformed messages and return only a list of further transformed messages, with only the fields that will be stored on ClickHouse.

TODO: make configs.

SortMap takes a map and returns a sorted version of it.

IngesterWorker is responsible the handle the end-to-end dumping of data to ClickHouse.

Messages is the data structure holding the messages that will be written to ClickHouse.