Add migrations for shards table in postgres metastore (#4119)

quickwit-oss · Nov 16, 2023 · 749c170 · 749c170
1 parent 26350df
commit 749c170
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 0 deletions.
diff --git a/quickwit/quickwit-metastore/migrations/postgresql/12_create-shards.down.sql b/quickwit/quickwit-metastore/migrations/postgresql/12_create-shards.down.sql
@@ -0,0 +1,3 @@
+DROP TABLE shards;
+
+DROP TYPE IF EXISTS SHARD_STATE;
diff --git a/quickwit/quickwit-metastore/migrations/postgresql/12_create-shards.up.sql b/quickwit/quickwit-metastore/migrations/postgresql/12_create-shards.up.sql
@@ -0,0 +1,14 @@
+CREATE TYPE SHARD_STATE AS ENUM ('unspecified', 'open', 'unavailable', 'closed');
+
+CREATE TABLE IF NOT EXISTS shards (
+    index_uid VARCHAR(282) NOT NULL,
+    source_id VARCHAR(255) NOT NULL,
+    shard_id BIGSERIAL,
+    leader_id VARCHAR(255) NOT NULL,
+    follower_id VARCHAR(255),
+    shard_state SHARD_STATE NOT NULL,
+    publish_position_inclusive VARCHAR(255) NOT NULL,
+    publish_token VARCHAR(255),
+    PRIMARY KEY (index_uid, source_id, shard_id),
+    FOREIGN KEY (index_uid) REFERENCES indexes (index_uid)
+);
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,3 @@
		DROP TABLE shards;

		DROP TYPE IF EXISTS SHARD_STATE;