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)
- func WithEnvironmentVariable(t *testing.T, k, v string)
- type GetDBOption
- type GetDBOptions
- type SetupTestingEnvParams
Constants ¶
View Source
const ( DBName = "lakefs_db" DBContainerTimeoutSeconds = 60 * 30 // 30 minutes EnvKeyUseBlockAdapter = "USE_BLOCK_ADAPTER" )
View Source
const ( DynamodbLocalPort = "6432" DynamodbLocalURI = "http://localhost:6432" DynamoDBReadCapacity = 1000 DynamoDBWriteCapacity = 1000 DynamoDBScanLimit = 10 )
Variables ¶
This section is empty.
Functions ¶
func GetDBInstance ¶
func GetDBInstance(pool *dockertest.Pool) (string, func())
func GetDynamoDBInstance ¶ added in v0.68.0
func GetDynamoDBProd ¶ added in v0.68.0
func MigrateBadEntry ¶ added in v0.66.0
func MigrateBadEntry(_ context.Context, _ *pgxpool.Pool, _ blockparams.AdapterConfig, writer io.Writer) error
func MigrateBasic ¶ added in v0.66.0
func MigrateBasic(_ context.Context, _ *pgxpool.Pool, _ blockparams.AdapterConfig, writer io.Writer) error
func MigrateEmpty ¶ added in v0.66.0
func MigrateEmpty(_ context.Context, _ *pgxpool.Pool, _ blockparams.AdapterConfig, _ io.Writer) error
func MigrateNoHeader ¶ added in v0.66.0
func MigrateNoHeader(_ context.Context, _ *pgxpool.Pool, _ blockparams.AdapterConfig, writer io.Writer) error
func MigrateParallel ¶ added in v0.66.0
func MigrateParallel(_ context.Context, _ *pgxpool.Pool, _ blockparams.AdapterConfig, writer io.Writer) error
func NewBlockAdapterByType ¶
func NewClientFromCreds ¶ added in v0.43.0
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 ¶ added in v0.43.0
ParseEndpointURL parses the given endpoint string
func RandomRune ¶ added in v0.51.0
RandomRune returns a random Unicode rune from rand, weighting at least num out of den runes to be ASCII.
func RandomString ¶ added in v0.51.0
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 ¶ added in v0.82.0
func SetupTestingEnv ¶
func SetupTestingEnv(params *SetupTestingEnvParams) (logging.Logger, api.ClientWithResponsesInterface, *s3.S3)
func UniqueKVTableName ¶ added in v0.68.0
func UniqueKVTableName() string
func ValidateKV ¶ added in v0.66.0
func WithEnvironmentVariable ¶ added in v0.87.0
WithEnvironmentVariable Sets an environment variable for the duration of the test,
restoring it to a previous value, if any, at teardown.
Warning: Environment variables affect other goroutines that might be running at the same time -
so this function is *not* thread safe.
Types ¶
type GetDBOption ¶
type GetDBOption func(options *GetDBOptions)
type GetDBOptions ¶
type GetDBOptions struct {
ApplyDDL bool
}
Click to show internal directories.
Click to hide internal directories.