dataflow.md

Angara.Met: data flow structures

Redis keys

• event_queue
  inbound event queue

• event_queue_seq
  eid sequence counter

Event structure

Basic fields:

{
  eid:  "seq++",
  ts:   "milliseconds",
  type: "event_type",
  // payload: { ... }
}

Forum message event

{
  eid,
  ts,
  type: "forum_msg",    // changed to "forum_message"
  forum_msg: {          // changed to `forum_message:`
    msg_id: "\d+",
    user_id: "\d+",
    topic_id: "\d+",
    text: "...",
    file?: "???
  }
}

Forum topic event

{
  eid,
  ts,
  type: "forum_topic",
  forum_topic: {
    user_id: "\d+",
    topic_id: "\d+",
    group_id: "\d+",
    title: "..."
    text: "...."
  }
}

Private message notify

{
  eid, ts,
  type: "private_message",
  private_message: {
    id: "\d+",    // msg_id
    user_id: "\d+",
    to_id: "\d+",
    text: "...."
  }
}