Skip to content

Commit 93f77d3

Browse files
committed
refactor: use regionId in sentinels
1 parent 68ef8b9 commit 93f77d3

21 files changed

+119
-100
lines changed

pkg/db/bulk_sentinel_insert.sql_generated.go

Lines changed: 2 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

pkg/db/models_generated.go

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

pkg/db/querier_generated.go

Lines changed: 8 additions & 8 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,2 @@
11
-- name: FindSentinelsByEnvironmentID :many
2-
SELECT * FROM sentinels WHERE environment_id = sqlc.arg(environment_id);
2+
SELECT sqlc.embed(s), sqlc.embed(r) FROM sentinels s LEFT JOIN regions r ON s.region_id = r.id WHERE s.environment_id = sqlc.arg(environment_id);

pkg/db/queries/sentinel_find_by_versions.sql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,6 @@
22
-- ListSentinelsByRegion returns sentinels for a region with version > after_version.
33
-- Used by WatchSentinels to stream sentinel state changes to krane agents.
44
SELECT * FROM `sentinels`
5-
WHERE region = sqlc.arg(region) AND version > sqlc.arg(afterVersion)
5+
WHERE region_id = sqlc.arg(region_id) AND version > sqlc.arg(afterVersion)
66
ORDER BY version ASC
77
LIMIT ?;

pkg/db/queries/sentinel_insert.sql

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ INSERT INTO sentinels (
66
project_id,
77
k8s_address,
88
k8s_name,
9-
region,
9+
region_id,
1010
image,
1111
health,
1212
desired_replicas,
@@ -22,7 +22,7 @@ INSERT INTO sentinels (
2222
sqlc.arg(project_id),
2323
sqlc.arg(k8s_address),
2424
sqlc.arg(k8s_name),
25-
sqlc.arg(region),
25+
sqlc.arg(region_id),
2626
sqlc.arg(image),
2727
sqlc.arg(health),
2828
sqlc.arg(desired_replicas),

pkg/db/queries/sentinel_list_desired.sql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
-- Used during bootstrap to stream all running sentinels to krane.
44
SELECT *
55
FROM `sentinels`
6-
WHERE (sqlc.arg(region) = '' OR region = sqlc.arg(region))
6+
WHERE (sqlc.arg(region_id) = '' OR region_id = sqlc.arg(region_id))
77
AND desired_state = sqlc.arg(desired_state)
88
AND id > sqlc.arg(pagination_cursor)
99
ORDER BY id ASC

pkg/db/schema.sql

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -606,7 +606,7 @@ CREATE TABLE `sentinels` (
606606
`environment_id` varchar(255) NOT NULL,
607607
`k8s_name` varchar(64) NOT NULL,
608608
`k8s_address` varchar(255) NOT NULL,
609-
`region` varchar(255) NOT NULL,
609+
`region_id` varchar(255) NOT NULL DEFAULT 'TODO',
610610
`image` varchar(255) NOT NULL,
611611
`desired_state` enum('running','standby','archived') NOT NULL DEFAULT 'running',
612612
`health` enum('unknown','paused','healthy','unhealthy') NOT NULL DEFAULT 'unknown',
@@ -621,8 +621,7 @@ CREATE TABLE `sentinels` (
621621
CONSTRAINT `sentinels_id_unique` UNIQUE(`id`),
622622
CONSTRAINT `sentinels_k8s_name_unique` UNIQUE(`k8s_name`),
623623
CONSTRAINT `sentinels_k8s_address_unique` UNIQUE(`k8s_address`),
624-
CONSTRAINT `one_env_per_region` UNIQUE(`environment_id`,`region`),
625-
CONSTRAINT `unique_version_per_region` UNIQUE(`region`,`version`)
624+
CONSTRAINT `unique_version_per_region` UNIQUE(`region_id`,`version`)
626625
);
627626

628627
CREATE TABLE `instances` (

pkg/db/sentinel_find_by_environment_id.sql_generated.go

Lines changed: 32 additions & 23 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

pkg/db/sentinel_find_by_id.sql_generated.go

Lines changed: 3 additions & 3 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)