postgres

Sep 20, 2026

Changes in this version

+ func ExtractReferencedRoles(sql string) []string

type EmbeddedPostgresConfig

+ Extensions map[string]string

+ type NoEffectKind string

+ const NoEffectGlobalDefaultPrivileges

+ const NoEffectOwner

+ type NoEffectStatement struct

+ Kind NoEffectKind

+ Partial bool

+ SQL string

+ func StripNoEffectStatements(sql string) (string, []NoEffectStatement)

Aug 21, 2026

Changes in this version

+ func ExtractDefaultPrivilegeRoles(sql string) []string

type ExternalDatabaseConfig

+ TargetExtensions map[string]string

type PostgresVersion

+ func DetectPostgresVersionAndExtensionsFromDB(host string, port int, database, user, password, sslmode string) (PostgresVersion, map[string]string, error)

+ type QualifiedName struct

+ Schema string

+ Table string

+ func ExtractCreateTableNames(sql, defaultSchema string) []QualifiedName

+ func ExtractForeignKeyTargets(sql, defaultSchema string) []QualifiedName

+ func ExtractPartitionOfTargets(sql, defaultSchema string) []QualifiedName

Mar 26, 2026

Changes in this version

type ExternalDatabaseConfig

+ SSLMode string

Feb 9, 2026

Changes in this version

+ func GenerateTempSchemaName() string

+ type DesiredStateProvider interface

+ ApplySchema func(ctx context.Context, schema string, sql string) error

+ GetConnectionDetails func() (string, int, string, string, string)

+ GetSchemaName func() string

+ Stop func() error

+ type EmbeddedPostgres struct

+ func StartEmbeddedPostgres(config *EmbeddedPostgresConfig) (*EmbeddedPostgres, error)

+ func (ep *EmbeddedPostgres) ApplySchema(ctx context.Context, schema string, sql string) error

+ func (ep *EmbeddedPostgres) GetConnectionDetails() (host string, port int, database, username, password string)

+ func (ep *EmbeddedPostgres) GetSchemaName() string

+ func (ep *EmbeddedPostgres) Stop() error

+ type EmbeddedPostgresConfig struct

+ Database string

+ Password string

+ Username string

+ Version PostgresVersion

+ type ExternalDatabase struct

+ func NewExternalDatabase(config *ExternalDatabaseConfig) (*ExternalDatabase, error)

+ func (ed *ExternalDatabase) ApplySchema(ctx context.Context, schema string, sql string) error

+ func (ed *ExternalDatabase) GetConnectionDetails() (host string, port int, database, username, password string)

+ func (ed *ExternalDatabase) GetSchemaName() string

+ func (ed *ExternalDatabase) Stop() error

+ type ExternalDatabaseConfig struct

+ Database string

+ Host string

+ Password string

+ Port int

+ TargetMajorVersion int

+ Username string

+ type PostgresVersion = embeddedpostgres.PostgresVersion

+ func DetectPostgresVersionFromDB(host string, port int, database, user, password string) (PostgresVersion, error)