reset

Documentation

Index

• Constants
• func DisconnectClients(ctx context.Context, conn *pgx.Conn) error
• func InitialiseDatabase(ctx context.Context, conn *pgx.Conn, fsys afero.Fs) error
• func RecreateDatabase(ctx context.Context, options ...func(*pgx.ConnConfig)) error
• func RestartDatabase(ctx context.Context, w io.Writer)
• func RetryEverySecond(ctx context.Context, callback func() bool, timeout time.Duration) bool
• func Run(ctx context.Context, fsys afero.Fs, options ...func(*pgx.ConnConfig)) error
• func SeedDatabase(ctx context.Context, conn *pgx.Conn, fsys afero.Fs) error
• func WaitForHealthyService(ctx context.Context, container string, timeout time.Duration) bool

Constants

const SET_POSTGRES_ROLE = "SET ROLE postgres;"

Functions

func DisconnectClients

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

func InitialiseDatabase

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

func RecreateDatabase

func RecreateDatabase(ctx context.Context, options ...func(*pgx.ConnConfig)) error

Recreate postgres database by connecting to template1

func RestartDatabase

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

func RetryEverySecond

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

func Run

func Run(ctx context.Context, 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