jprdonnelly/kestra
1
0
Fork 0
mirror of https://github.com/kestra-io/kestra.git synced 2025-12-25 02:14:38 -05:00
Code Issues Packages Projects Releases Wiki Activity

feat(system): add a lock mechanism

Browse Source
This commit is contained in:
Loïc Mathieu
2025-10-20 12:43:53 +02:00
parent 0df41b439d
commit d5ba7e7304
18 changed files with 687 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
jdbc-postgres/src/main/java/io/kestra/repository/postgres/PostgresLockRepository.java Normal file
View File

@@ -0,0 +1,15 @@
package io.kestra.repository.postgres;
import io.kestra.core.lock.Lock;
import io.kestra.jdbc.AbstractJdbcRepository;
import io.kestra.jdbc.repository.AbstractJdbcLockRepository;
import jakarta.inject.Named;
import jakarta.inject.Singleton;
@Singleton
@PostgresRepositoryEnabled
public class PostgresLockRepository extends AbstractJdbcLockRepository {
public PostgresLockRepository(@Named("locks") AbstractJdbcRepository<Lock> jdbcRepository) {
super(jdbcRepository);
}
}

9
jdbc-postgres/src/main/resources/migrations/postgres/V3_2__locks.sql Normal file
View File

@@ -0,0 +1,9 @@
CREATE TABLE IF NOT EXISTS locks (
key VARCHAR(250) NOT NULL PRIMARY KEY,
value JSONB NOT NULL,
category VARCHAR(250) NOT NULL GENERATED ALWAYS AS (value ->> 'category') STORED,
id VARCHAR(150) NOT NULL GENERATED ALWAYS AS (value ->> 'id') STORED,
owner VARCHAR(150) NOT NULL GENERATED ALWAYS AS (value ->> 'owner') STORED
);
CREATE INDEX IF NOT EXISTS locks__catefory_id ON locks (category, id);

6
jdbc-postgres/src/test/java/io/kestra/repository/postgres/PostgresRepositoryTest.java Normal file
View File

@@ -0,0 +1,6 @@
package io.kestra.repository.postgres;
import io.kestra.core.repositories.AbstractLockRepositoryTest;
public class PostgresRepositoryTest extends AbstractLockRepositoryTest {
}