Schema ‘pgq_node’, contains tables for cascaded pgq.
| pgq.location-info | ev_data: node_name, extra1: queue_name, extra2: location, extra3: dead It contains updated node connect string. |
| pgq.global-watermark | ev_data: tick_id, extra1: queue_name Root node sends minimal tick_id that must be kept. |
| pgq.tick-id | ev_data: tick_id, extra1: queue_name Partition node inserts its tick-id into combined queue. |
| Tables | Schema ‘pgq_node’, contains tables for cascaded pgq. |
| pgq_node. | Static table that just lists all members in set. |
| pgq_node. | Local node info. |
| pgq_node. | All cascaded consumers (both worker and non-worker) keep their state here. |
| pgq_node. | List of nodes that subscribe to local node. |
Local node info.
| queue_name | cascaded queue name |
| node_type | local node type |
| node_name | local node name |
| worker_name | consumer name that maintains this node |
| combined_queue | on ‘leaf’ the target combined set name |
| node_attrs | urlencoded fields for worker |
| root | data + batches is generated here |
| branch | replicates full queue contents and maybe contains some tables |
| leaf | does not replicate queue / or uses combined queue for that |
All cascaded consumers (both worker and non-worker) keep their state here.
| queue_name | cascaded queue name |
| consumer_name | cascaded consumer name |
| provider_node | node name the consumer reads from |
| last_tick_id | last committed tick id on this node |
| cur_error | reason why current batch failed |
| paused | whether consumer should wait |
| uptodate | if consumer has seen new state |