warkanum
4c8e1066d4
Replace the ad-hoc tables/procedures install layout with versioned, ordered SQL migrations tracked in broker_schema_migrations. Add optional least-privilege role provisioning (--with-roles), multi-tenant row-level security, lease-based job claiming with stale-lease recovery, and job dependencies -- both by job id and by fan-in job group. Add Docker/Compose support for running the broker and its test suite.
42 lines
1.6 KiB
PL/PgSQL
42 lines
1.6 KiB
PL/PgSQL
-- broker.broker_schedule
|
|
-- Stores scheduled jobs (cron-like functionality).
|
|
|
|
CREATE TABLE IF NOT EXISTS broker.broker_schedule (
|
|
id_broker_schedule BIGSERIAL PRIMARY KEY,
|
|
name VARCHAR(255) NOT NULL UNIQUE,
|
|
cron_expr VARCHAR(100) NOT NULL,
|
|
enabled BOOLEAN NOT NULL DEFAULT true,
|
|
job_name VARCHAR(255) NOT NULL,
|
|
job_priority INTEGER NOT NULL DEFAULT 0,
|
|
job_queue INTEGER NOT NULL DEFAULT 1,
|
|
job_language VARCHAR(50) NOT NULL DEFAULT 'sql',
|
|
execute_str TEXT NOT NULL,
|
|
run_as VARCHAR(100),
|
|
created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
|
|
updated_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
|
|
last_run_at TIMESTAMP WITH TIME ZONE,
|
|
next_run_at TIMESTAMP WITH TIME ZONE,
|
|
|
|
CONSTRAINT broker_schedule_job_queue_check CHECK (job_queue > 0)
|
|
);
|
|
|
|
CREATE INDEX IF NOT EXISTS idx_broker_schedule_enabled ON broker.broker_schedule(enabled);
|
|
CREATE INDEX IF NOT EXISTS idx_broker_schedule_next_run ON broker.broker_schedule(next_run_at) WHERE enabled = true;
|
|
CREATE INDEX IF NOT EXISTS idx_broker_schedule_name ON broker.broker_schedule(name);
|
|
|
|
COMMENT ON TABLE broker.broker_schedule IS 'Scheduled jobs (cron-like functionality)';
|
|
|
|
CREATE OR REPLACE FUNCTION broker.tf_broker_schedule_update_timestamp()
|
|
RETURNS TRIGGER AS $$
|
|
BEGIN
|
|
NEW.updated_at = NOW();
|
|
RETURN NEW;
|
|
END;
|
|
$$ LANGUAGE plpgsql;
|
|
|
|
DROP TRIGGER IF EXISTS t_broker_schedule_updated_at ON broker.broker_schedule;
|
|
CREATE TRIGGER t_broker_schedule_updated_at
|
|
BEFORE UPDATE ON broker.broker_schedule
|
|
FOR EACH ROW
|
|
EXECUTE FUNCTION broker.tf_broker_schedule_update_timestamp();
|