testutil

Documentation

Index

• Constants
• func GetDB(t testing.TB, uri string, opts ...GetDBOption) (db.Database, string)
• func GetDBInstance(pool *dockertest.Pool) (string, func())
• 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 SetupTestingEnv(params *SetupTestingEnvParams) (logging.Logger, api.ClientWithResponsesInterface, *s3.S3)
• 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 (
	DBContainerTimeoutSeconds = 60 * 30 // 30 minutes

	EnvKeyUseBlockAdapter = "USE_BLOCK_ADAPTER"
)

Functions

func GetDB

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

func GetDBInstance

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

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 SetupTestingEnv

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

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