testingx

Documentation

Index

• Variables
• func BackoffWithTimeout(tctx context.Context, timeout *time.Duration) backoff.BackOffContext
• func CheckErrFatal(err error)
• func Context() context.Context
• func NewPostgresDB(ctx context.Context, manager *container.Manager, params NewPostgresDBParams) (dsn *url.URL, err error)
• func NewWorkspaceFileStore(ctx context.Context) (store *config.FileStore, err error)
• func SetupPostgresDatabaseConnection(ctx context.Context, params SetupPostgresDatabaseConnectionParams) (dsn *url.URL, err error)
• func SetupTestMainWithDB(m *testing.M, params SetupTestMainWithDBParams)
• func WaitForPostgres(ctx context.Context, db *sql.DB, timeout *time.Duration) container.StartOption
• type Connection
  • func GetDB() (Connection, error)
• type MigrationProvider
• type NewPostgresDBParams
• type SetupPostgresDatabaseConnectionParams
• type SetupTestMainWithDBParams

Variables

var LocalFileStoreSet = wire.NewSet(
	NewWorkspaceFileStore,
	wire.Bind(new(config.Store), new(*config.FileStore)),
)

var PostgresUserinfo = url.UserPassword("postgres", "password")

var ReadWriteUserinfo = url.UserPassword("read_write", "password")

Functions

func BackoffWithTimeout

func BackoffWithTimeout(
	tctx context.Context,
	timeout *time.Duration,
) backoff.BackOffContext

func CheckErrFatal

func CheckErrFatal(err error)

func Context

func Context() context.Context

func NewPostgresDB

func NewPostgresDB(
	ctx context.Context,
	manager *container.Manager,
	params NewPostgresDBParams,
) (dsn *url.URL, err error)

func NewWorkspaceFileStore

func NewWorkspaceFileStore(ctx context.Context) (store *config.FileStore, err error)

func SetupPostgresDatabaseConnection

func SetupPostgresDatabaseConnection(
	ctx context.Context,
	params SetupPostgresDatabaseConnectionParams,
) (dsn *url.URL, err error)

func SetupTestMainWithDB

func SetupTestMainWithDB(
	m *testing.M,
	params SetupTestMainWithDBParams,
)

func WaitForPostgres

func WaitForPostgres(ctx context.Context, db *sql.DB, timeout *time.Duration) container.StartOption

Types

type Connection

type Connection struct {
	DB  *sqlx.DB
	URL *url.URL
}

func GetDB

func GetDB() (Connection, error)

type MigrationProvider

type MigrationProvider func(dsn string) (*migrate.Migrate, error)

type NewPostgresDBParams

type NewPostgresDBParams struct {
	Database      string
	ImageURL      string
	ContainerName string
	Timeout       *time.Duration
}

type SetupPostgresDatabaseConnectionParams

type SetupPostgresDatabaseConnectionParams struct {
	Manager        *container.Manager
	LoadMigrations MigrationProvider
	ContainerName  string
	DatabaseName   string
}

type SetupTestMainWithDBParams

type SetupTestMainWithDBParams struct {
	LoadMigrations MigrationProvider
	ContainerName  string
	DatabaseName   string
}