public.process_queue
Description
process queue for async job
Columns
| Name | Type | Default | Nullable | Comment |
|---|---|---|---|---|
| channel | text | false | ||
| id | bigint | false | bigint primary key (upgraded from integer to avoid sequence exhaustion at sustained load). | |
| payload | text | false | ||
| processed | timestamp with time zone | true | ||
| ref_id | text | false | either user_id or vessel_id | |
| stored | timestamp with time zone | false |
Constraints
| Name | Type | Definition |
|---|---|---|
| process_queue_channel_not_null | n | NOT NULL channel |
| process_queue_id_not_null | n | NOT NULL id |
| process_queue_payload_length | CHECK | CHECK ((char_length(payload) < 2048)) |
| process_queue_payload_not_null | n | NOT NULL payload |
| process_queue_pkey | PRIMARY KEY | PRIMARY KEY (id) |
| process_queue_ref_id_not_null | n | NOT NULL ref_id |
| process_queue_stored_not_null | n | NOT NULL stored |
Indexes
| Name | Definition | Comment |
|---|---|---|
| process_queue_channel_idx | CREATE INDEX process_queue_channel_idx ON public.process_queue USING btree (channel) | |
| process_queue_pkey | CREATE UNIQUE INDEX process_queue_pkey ON public.process_queue USING btree (id) | |
| process_queue_processed_idx | CREATE INDEX process_queue_processed_idx ON public.process_queue USING btree (processed) | |
| process_queue_ref_id_idx | CREATE INDEX process_queue_ref_id_idx ON public.process_queue USING btree (ref_id) | |
| process_queue_ref_id_processed_idx | CREATE INDEX process_queue_ref_id_processed_idx ON public.process_queue USING btree (ref_id, id DESC) WHERE (processed IS NOT NULL) | Optimizes: eventlogs_view user-facing event log Query pattern: WHERE (ref_id = user.id OR ref_id = vessel.id) AND processed IS NOT NULL ORDER BY id DESC Partial index: processed rows only (mirrors pending_idx which covers IS NULL side) INCLUDE id DESC for ORDER BY pushdown |
Relations
erDiagram
"public.process_queue" {
text channel ""
bigint id "bigint primary key (upgraded from integer to avoid sequence exhaustion at sustained load)."
text payload ""
timestamp_with_time_zone processed ""
text ref_id "either user_id or vessel_id"
timestamp_with_time_zone stored ""
}
Generated by tbls