setup

Documentation

Index

• Constants
• Variables
• func AfterSuiteFn()
• func BeforeSuiteFn(args ...interface{}) context.Context
• func DumpEventQueue(ctx context.Context)
• func ExpectJobToPass(j *job.Job)
• func GetEmbeddedPGConfig(database string, port int) (embeddedPG.Config, string)
• func MustDB() *sql.DB
• func NewDB(ctx context.Context, name string) (*context.Context, func(), error)
• func RestartEmbeddedPG() error
• func RunEcho(e *echo.Echo) (int, func())
• func SetupDB(dbName string, args ...interface{}) (context.Context, error)

Constants

const (
	DUTY_DB_CREATE   = "DUTY_DB_CREATE"
	DUTY_DB_DATA_DIR = "DUTY_DB_DATA_DIR"
	DUTY_DB_URL      = "DUTY_DB_URL"
	TEST_DB_PORT     = "TEST_DB_PORT"
)

Env vars for embedded db

Variables

var DefaultContext context.Context

var PgUrl string

var WithExistingDatabase = "with_existing_database"

var WithoutDummyData = "without_dummy_data"

var WithoutRLS = "rls_disabled"

Functions

func AfterSuiteFn

func AfterSuiteFn()

func BeforeSuiteFn

func BeforeSuiteFn(args ...interface{}) context.Context

func DumpEventQueue

func DumpEventQueue(ctx context.Context)

func ExpectJobToPass

func ExpectJobToPass(j *job.Job)

func GetEmbeddedPGConfig

func GetEmbeddedPGConfig(database string, port int) (embeddedPG.Config, string)

func MustDB

func MustDB() *sql.DB

func NewDB

func NewDB(ctx context.Context, name string) (*context.Context, func(), error)

NewDB creates a new database from an existing context, and returns the new context and a function that be called to drop it

func RestartEmbeddedPG

func RestartEmbeddedPG() error

func RunEcho

func RunEcho(e *echo.Echo) (int, func())

func SetupDB

func SetupDB(dbName string, args ...interface{}) (context.Context, error)