cluster

func EnsureDef ¶

func EnsureDef(t *testing.T, db *sql.DB, name string, version int)

EnsureDef inserts the workflow_defs row a test's instances refer to.

migrations/postgres/001_schema.sql puts `FOREIGN KEY (def_name, def_version) REFERENCES workflow_defs(name, version)` on workflow_instances, and every test in this package inserts instances with a raw INSERT naming a definition it never created. Against the real schema all eleven failed on that constraint -- the suite is in UNWIRED_SUITES (scripts/check-ci-package-coverage.sh) and nothing had ever run it.

The bytes are a bare WASM header. Nothing here executes the module: these tests are about claiming, failover and replay bookkeeping, not about running guest code.

func GetDB ¶

func GetDB(t *testing.T) *sql.DB

GetDB returns a *sql.DB connected to the cluster's PostgreSQL instance.

func SetupCluster ¶

func SetupCluster(t *testing.T)

SetupCluster starts the cluster via docker compose and waits for all workers to become healthy.

`docker compose`, not `docker-compose`. The hyphenated v1 binary is gone from current GitHub runners and from Docker Desktop; ci.yml's cluster job has used the v2 plugin form throughout. This package still shelled out to v1, so the first thing it would have done on a runner is fail to find the command.

func TeardownCluster ¶

func TeardownCluster(t *testing.T)

TeardownCluster stops and removes all cluster containers and volumes.

func WaitForReady ¶

func WaitForReady(t *testing.T, timeout time.Duration)

WaitForReady polls each worker's /healthz endpoint until all respond or the timeout elapses.