testutil

package
v1.24.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 19, 2024 License: Apache-2.0 Imports: 42 Imported by: 0

Documentation

Index

Constants

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

	EnvKeyUseBlockAdapter = "USE_BLOCK_ADAPTER" // pragma: allowlist secret

)
View Source
const (
	DynamodbLocalPort = "6432"
	DynamodbLocalURI  = "http://localhost:6432"

	DynamoDBScanLimit = 10
)
View Source
const (
	CosmosDBLocalPort = "8081"
)

Variables

This section is empty.

Functions

func ChecksumReader added in v1.11.1

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

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

func GetCosmosDBInstance added in v0.103.0

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

func GetDBInstance

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

func GetDynamoDBInstance added in v0.68.0

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

func GetDynamoDBProd added in v0.68.0

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 added in v0.43.0

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 added in v1.11.1

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

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

func ParseEndpointURL added in v0.43.0

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

ParseEndpointURL parses the given endpoint string

func PingPG added in v0.84.0

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

func RandomRune added in v0.51.0

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 added in v0.51.0

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 added in v0.82.0

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

func UniqueKVTableName added in v0.68.0

func UniqueKVTableName() string

func UniqueName added in v0.109.0

func UniqueName() string

func WithEnvironmentVariable added in v0.87.0

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
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL