dbmigrate

Documentation

Index

• Constants
• func MigrateComponents(ctx context.Context, database *bun.DB, components []string) error
• func ParseComponents(raw string) ([]string, error)
• func PostgresComponents(ctx context.Context, dsn string, components []string) error
• func SwapLookupPostgresComponentForTest(...) (restore func())

Constants

const (
	ComponentUsageAuthority = "usage-authority"
	ComponentConcurrency    = "concurrency"
	ComponentMetering       = "metering"
	ComponentBilling        = "billing"
)

Functions

func MigrateComponents

func MigrateComponents(ctx context.Context, database *bun.DB, components []string) error

MigrateComponents runs DDL migrations for the named dual-plane components on an already-open admin handle. Verification stays with the caller (CLI verify pass or runtime OpenStore readiness).

func ParseComponents

func ParseComponents(raw string) ([]string, error)

func PostgresComponents

func PostgresComponents(ctx context.Context, dsn string, components []string) error

func SwapLookupPostgresComponentForTest

func SwapLookupPostgresComponentForTest(fn func(component string) (func(context.Context, *bun.DB) error, func(context.Context, *bun.DB) error, error)) (restore func())

SwapLookupPostgresComponentForTest replaces component lookup for tests outside this package. Call the returned restore from t.Cleanup.