testutil

Documentation

Index

• Constants
• func GetDB(t testing.TB, uri string, opts ...GetDBOption) (db.Database, string)
• func GetDBInstance(pool *dockertest.Pool) (string, func())
• func Must(t testing.TB, err error)
• func MustDo(t testing.TB, what string, err error)
• func NewBlockAdapterByType(t testing.TB, translator block.UploadIDTranslator, blockstoreType string) block.Adapter
• func SetupTestingEnv(params *SetupTestingEnvParams) (logging.Logger, *genclient.Lakefs, *s3.S3)
• type GetDBOption
  • func WithGetDBApplyDDL(apply bool) GetDBOption
• type GetDBOptions
• type SetupTestingEnvParams
• type UploadIDTranslator
  • func (d *UploadIDTranslator) RemoveUploadID(inputUploadID string)
  • func (d *UploadIDTranslator) SetUploadID(uploadID string) string
  • func (d *UploadIDTranslator) TranslateUploadID(simulationID string) string

Constants

const (
	DBContainerTimeoutSeconds = 60 * 30 // 30 minutes

	EnvKeyUseBlockAdapter = "USE_BLOCK_ADAPTER"
)

Functions

func GetDB

func GetDB(t testing.TB, uri string, opts ...GetDBOption) (db.Database, string)

func GetDBInstance

func GetDBInstance(pool *dockertest.Pool) (string, func())

func Must

func Must(t testing.TB, err error)

func MustDo

func MustDo(t testing.TB, what string, err error)

func NewBlockAdapterByType

func NewBlockAdapterByType(t testing.TB, translator block.UploadIDTranslator, blockstoreType string) block.Adapter

func SetupTestingEnv

func SetupTestingEnv(params *SetupTestingEnvParams) (logging.Logger, *genclient.Lakefs, *s3.S3)

Types

type GetDBOption

type GetDBOption func(options *GetDBOptions)

func WithGetDBApplyDDL

func WithGetDBApplyDDL(apply bool) GetDBOption

type GetDBOptions

type GetDBOptions struct {
	ApplyDDL bool
}

type SetupTestingEnvParams

type SetupTestingEnvParams struct {
	Name      string
	StorageNS string

	// Only if non-empty
	AdminAccessKeyID     string
	AdminSecretAccessKey string
}

type UploadIDTranslator

type UploadIDTranslator struct {
	T          *testing.T
	TransMap   map[string]string
	ExpectedID string
	// contains filtered or unexported fields
}

func (*UploadIDTranslator) RemoveUploadID

func (d *UploadIDTranslator) RemoveUploadID(inputUploadID string)

func (*UploadIDTranslator) SetUploadID

func (d *UploadIDTranslator) SetUploadID(uploadID string) string

func (*UploadIDTranslator) TranslateUploadID

func (d *UploadIDTranslator) TranslateUploadID(simulationID string) string