testutil

Documentation

Index

• Constants
• func ChecksumReader(reader io.Reader) (uint64, error)
• func GetCosmosDBInstance() (string, func(), error)
• func GetDBInstance(pool *dockertest.Pool) (string, func())
• func GetDynamoDBInstance() (string, func(), error)
• func GetDynamoDBProd(ctx context.Context, tb testing.TB) kv.Store
• 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, ...) (*apigen.ClientWithResponses, error)
• func NewRandomReader(rand *rand.Rand, size int64) io.Reader
• 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.Client, error)
• func SetupTestingEnv(params *SetupTestingEnvParams) (logging.Logger, apigen.ClientWithResponsesInterface, *s3.Client, string)
• func UniqueKVTableName() string
• func UniqueName() string
• func WithEnvironmentVariable(t *testing.T, k, v string)
• type GetDBOption
• type GetDBOptions
• type SetupTestingEnvParams

Constants

const (
	DBName                    = "lakefs_db"
	DBContainerTimeoutSeconds = 60 * 30 // 30 minutes

	EnvKeyUseBlockAdapter = "USE_BLOCK_ADAPTER" // pragma: allowlist secret

)

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

	DynamoDBScanLimit = 10
)

const (
	CosmosDBLocalPort = "8081"
)

Functions

func ChecksumReader

func ChecksumReader(reader io.Reader) (uint64, error)

ChecksumReader returns the checksum (CRC-64) of the contents of reader.

func GetCosmosDBInstance

func GetCosmosDBInstance() (string, func(), error)

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 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) (*apigen.ClientWithResponses, error)

NewClientFromCreds creates a client using the credentials of a user

func NewRandomReader

func NewRandomReader(rand *rand.Rand, size int64) io.Reader

NewRandomReader returns a reader that will return size bytes from rand.

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.Client, error)

func SetupTestingEnv

func SetupTestingEnv(params *SetupTestingEnvParams) (logging.Logger, apigen.ClientWithResponsesInterface, *s3.Client, string)

func UniqueKVTableName

func UniqueKVTableName() string

func UniqueName

func UniqueName() string

func WithEnvironmentVariable

func WithEnvironmentVariable(t *testing.T, k, v string)

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
}

type SetupTestingEnvParams

type SetupTestingEnvParams struct {
	Name      string
	StorageNS string

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