provision

type ClusterOps interface {
	// CreateDatabase ensures the database exists on the cluster.
	CreateDatabase(ctx context.Context, clusterID, database string) error
	// Migrate runs fabriq's migration chain against the database and
	// returns the resulting head version.
	Migrate(ctx context.Context, clusterID, database string) (version string, err error)
}

type MigrateAllOpts struct {
	// Batch is the number of tenant databases migrated concurrently
	// (default 8).
	Batch int
	// MaxFailures stops the roll after this many failed tenants
	// (default 3). The roll is always safe to re-run.
	MaxFailures int
	// TargetVersion skips tenants already recorded at it ("" = always run;
	// the migration chain itself is idempotent).
	TargetVersion string
}

type Provisioner struct {
	// contains filtered or unexported fields
}

type Report struct {
	Migrated int            `json:"migrated"`
	Skipped  int            `json:"skipped"`
	Failed   int            `json:"failed"`
	Results  []TenantResult `json:"results"`
}

type SchemaClusterOps interface {
	// EnsureBootstrap prepares a consolidation database ONCE: creates the
	// shared schema and its extensions (pgvector/postgis) so every tenant
	// schema resolves their types via search_path. Idempotent per database.
	EnsureBootstrap(ctx context.Context, clusterID, database, sharedSchema string) error
	// CreateSchema ensures a tenant's schema exists in the consolidation
	// database.
	CreateSchema(ctx context.Context, clusterID, database, schema string) error
	// MigrateSchema runs fabriq's migration chain inside a tenant schema
	// (bare-named DDL + grove_migrations land there via search_path) and
	// returns the resulting head version.
	MigrateSchema(ctx context.Context, clusterID, database, schema, sharedSchema string) (version string, err error)
}

type SchemaProvisioner struct {
	// contains filtered or unexported fields
}

type TenantResult struct {
	TenantID string `json:"tenantId"`
	Version  string `json:"version,omitempty"`
	Skipped  bool   `json:"skipped,omitempty"`
	Err      string `json:"error,omitempty"`
}