Skip to main content

CREATE_CURSOR_TABLE_POSTGRES

Constant CREATE_CURSOR_TABLE_POSTGRES 

Source
pub const CREATE_CURSOR_TABLE_POSTGRES: &str = r#"
CREATE TABLE IF NOT EXISTS atrg_jetstream_cursors (
    consumer_id TEXT PRIMARY KEY,
    time_us BIGINT NOT NULL,
    updated_at BIGINT NOT NULL DEFAULT EXTRACT(EPOCH FROM NOW())::bigint
);
"#;
Expand description

SQL for creating the cursor table (PostgreSQL).