reset

Documentation

Index

• Constants
• Variables
• func DisconnectClients(ctx context.Context, conn *pgx.Conn) error
• func InitSchema15(ctx context.Context, host string) error
• func InitialiseDatabase(ctx context.Context, conn *pgx.Conn, fsys afero.Fs) error
• func ListSchemas(ctx context.Context, conn *pgx.Conn, exclude ...string) ([]string, error)
• func RestartDatabase(ctx context.Context, w io.Writer) error
• func RetryEverySecond(ctx context.Context, callback func() bool, timeout time.Duration) bool
• func Run(ctx context.Context, config pgconn.Config, fsys afero.Fs, ...) error
• func SeedDatabase(ctx context.Context, conn *pgx.Conn, fsys afero.Fs) error
• func WaitForHealthyService(ctx context.Context, container string, timeout time.Duration) bool
• func WaitForServiceReady(ctx context.Context, started []string) error

Constants

const (
	SET_POSTGRES_ROLE = "SET ROLE postgres;"
	LIST_SCHEMAS      = "SELECT schema_name FROM information_schema.schemata WHERE NOT schema_name LIKE ANY($1) ORDER BY schema_name"
)

Variables

var (
	ErrUnhealthy = errors.New("service not healthy")
	ErrDatabase  = errors.New("database is not healthy")
)

Functions

func DisconnectClients

func DisconnectClients(ctx context.Context, conn *pgx.Conn) error

func InitSchema15

func InitSchema15(ctx context.Context, host string) error

func InitialiseDatabase

func InitialiseDatabase(ctx context.Context, conn *pgx.Conn, fsys afero.Fs) error

func ListSchemas

func ListSchemas(ctx context.Context, conn *pgx.Conn, exclude ...string) ([]string, error)

func RestartDatabase

func RestartDatabase(ctx context.Context, w io.Writer) error

func RetryEverySecond

func RetryEverySecond(ctx context.Context, callback func() bool, timeout time.Duration) bool

func Run

func Run(ctx context.Context, config pgconn.Config, fsys afero.Fs, options ...func(*pgx.ConnConfig)) error

func SeedDatabase

func SeedDatabase(ctx context.Context, conn *pgx.Conn, fsys afero.Fs) error

func WaitForHealthyService

func WaitForHealthyService(ctx context.Context, container string, timeout time.Duration) bool

func WaitForServiceReady

func WaitForServiceReady(ctx context.Context, started []string) error