testutil

Documentation

Index

• Constants
• func CleanupKV(ctx context.Context, t *testing.T, store kv.Store)
• func GetDB(t testing.TB, uri string, opts ...GetDBOption) (db.Database, string)
• func GetDBInstance(pool *dockertest.Pool) (string, func())
• func GetDynamoDBInstance() (string, func(), error)
• func GetDynamoDBProd(ctx context.Context, tb testing.TB) kv.Store
• func MigrateBadEntry(_ context.Context, _ *pgxpool.Pool, writer io.Writer) error
• func MigrateBasic(_ context.Context, _ *pgxpool.Pool, writer io.Writer) error
• func MigrateEmpty(_ context.Context, _ *pgxpool.Pool, _ io.Writer) error
• func MigrateNoHeader(_ context.Context, _ *pgxpool.Pool, writer io.Writer) error
• func MigrateParallel(_ context.Context, _ *pgxpool.Pool, writer io.Writer) error
• 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 NewClientFromCreds(logger logging.Logger, accessKeyID string, secretAccessKey string, ...) (*api.ClientWithResponses, error)
• func ParseEndpointURL(logger logging.Logger, endpointURL string) string
• func RandomRune(rand *rand.Rand, num, den int) rune
• func RandomString(rand *rand.Rand, size int) string
• func SetupTestingEnv(params *SetupTestingEnvParams) (logging.Logger, api.ClientWithResponsesInterface, *s3.S3)
• func UniqueKVTableName() string
• func ValidateKV(ctx context.Context, t *testing.T, store kv.Store, entries int)
• 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 (
	DBName                    = "lakefs_db"
	DBContainerTimeoutSeconds = 60 * 30 // 30 minutes

	EnvKeyUseBlockAdapter = "USE_BLOCK_ADAPTER"
)

const (
	DynamodbLocalPort = "6432"
	DynamodbLocalURI  = "http://localhost:6432"

	DynamoDBReadCapacity  = 1000
	DynamoDBWriteCapacity = 1000
	DynamoDBScanLimit     = 10
)

Functions

func CleanupKV

func CleanupKV(ctx context.Context, t *testing.T, store kv.Store)

func GetDB

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

func GetDBInstance

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

func GetDynamoDBInstance

func GetDynamoDBInstance() (string, func(), error)

func GetDynamoDBProd

func GetDynamoDBProd(ctx context.Context, tb testing.TB) kv.Store

func MigrateBadEntry

func MigrateBadEntry(_ context.Context, _ *pgxpool.Pool, writer io.Writer) error

func MigrateBasic

func MigrateBasic(_ context.Context, _ *pgxpool.Pool, writer io.Writer) error

func MigrateEmpty

func MigrateEmpty(_ context.Context, _ *pgxpool.Pool, _ io.Writer) error

func MigrateNoHeader

func MigrateNoHeader(_ context.Context, _ *pgxpool.Pool, writer io.Writer) error

func MigrateParallel

func MigrateParallel(_ context.Context, _ *pgxpool.Pool, writer io.Writer) error

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 NewClientFromCreds

func NewClientFromCreds(logger logging.Logger, accessKeyID string, secretAccessKey string, endpointURL string) (*api.ClientWithResponses, error)

Creates a client using the credentials of a user

func ParseEndpointURL

func ParseEndpointURL(logger logging.Logger, endpointURL string) string

Parses the given endpoint string

func RandomRune

func RandomRune(rand *rand.Rand, num, den int) rune

RandomRune returns a random Unicode rune from rand, weighting at least num out of den runes to be ASCII.

func RandomString

func RandomString(rand *rand.Rand, size int) string

RandomString returns a random UTF-8 string of size or almost size bytes from rand. It is weighted towards using many ASCII characters.

func SetupTestingEnv

func SetupTestingEnv(params *SetupTestingEnvParams) (logging.Logger, api.ClientWithResponsesInterface, *s3.S3)

func UniqueKVTableName

func UniqueKVTableName() string

func ValidateKV

func ValidateKV(ctx context.Context, t *testing.T, store kv.Store, entries int)

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