testutil

Documentation

Index

• Constants
• func CleanupKV(ctx context.Context, t *testing.T, store kv.Store)
• 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, _ blockparams.AdapterConfig, ...) error
• func MigrateBasic(_ context.Context, _ *pgxpool.Pool, _ blockparams.AdapterConfig, ...) error
• func MigrateEmpty(_ context.Context, _ *pgxpool.Pool, _ blockparams.AdapterConfig, _ io.Writer) error
• func MigrateNoHeader(_ context.Context, _ *pgxpool.Pool, _ blockparams.AdapterConfig, ...) error
• func MigrateParallel(_ context.Context, _ *pgxpool.Pool, _ blockparams.AdapterConfig, ...) error
• func Must(t testing.TB, err error)
• func MustDo(t testing.TB, what string, err error)
• func NewBlockAdapterByType(t testing.TB, 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 PingPG(ctx context.Context, pool *pgxpool.Pool) error
• func RandomRune(rand *rand.Rand, num, den int) rune
• func RandomString(rand *rand.Rand, size int) string
• func SetupTestS3Client(endpoint, key, secret string) *s3.S3
• 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
• type GetDBOptions
• type SetupTestingEnvParams

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 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, _ blockparams.AdapterConfig, writer io.Writer) error

func MigrateBasic

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

func MigrateEmpty

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

func MigrateNoHeader

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

func MigrateParallel

func MigrateParallel(_ context.Context, _ *pgxpool.Pool, _ blockparams.AdapterConfig, 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, blockstoreType string) block.Adapter

func NewClientFromCreds

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

NewClientFromCreds creates a client using the credentials of a user

func ParseEndpointURL

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

ParseEndpointURL parses the given endpoint string

func PingPG

func PingPG(ctx context.Context, pool *pgxpool.Pool) error

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 SetupTestS3Client

func SetupTestS3Client(endpoint, key, secret string) *s3.S3

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)

type GetDBOptions

type GetDBOptions struct {
	ApplyDDL bool
}

type SetupTestingEnvParams

type SetupTestingEnvParams struct {
	Name      string
	StorageNS string

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