setup

package

v1.0.1351 Latest Latest Go to latest Published: Jul 14, 2026 License: Apache-2.0 Imports: 33 Imported by: 0

Details

View Source

const (
	DUTY_DB_CREATE      = "DUTY_DB_CREATE"
	DUTY_DB_DISABLE_RLS = "DUTY_DB_DISABLE_RLS"
)

View Source

const (
	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

View Source

var DefaultContext context.Context

View Source

var PgUrl string

View Source

var WithExistingDatabase = "with_existing_database"

View Source

var WithoutDummyData = "without_dummy_data"

View Source

var WithoutRLS = "rls_disabled"

func AfterSuiteFn()

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

func CreateUserWithRole(ctx context.Context, name, email string, roles ...string) *models.Person

CreateUserWithRole creates a user and assigns the specified roles

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)

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() error

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

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

func SetupNode(data []byte, opts SetupOpts) context.Context

func SetupTemplate(opts SetupOpts) []byte

func SynchronizedAfterSuiteAllNodes()

func SynchronizedAfterSuiteNode1()

type SetupOpts struct {
	DummyData bool
}