testhelper

package
v1.9.0-rc.2 Latest Latest
Warning

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

Go to latest
Published: May 19, 2023 License: AGPL-3.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source
const (
	WaitFor2Minute         = 2 * time.Minute
	WaitFor10Minute        = 10 * time.Minute
	DefaultQueryFrequency  = 100 * time.Millisecond
	AsyncJOBQueryFrequency = 1000 * time.Millisecond
)

Variables

This section is empty.

Functions

func EnhanceWithDefaultEnvs added in v1.9.0

func EnhanceWithDefaultEnvs(t *testing.T)

func GetUserId

func GetUserId(provider string) string

func JobsDB added in v1.9.0

func JobsDB(t testing.TB, port int) *sql.DB

func RandSchema added in v1.9.0

func RandSchema(provider string) string

func VerifyConfigurationTest

func VerifyConfigurationTest(t testing.TB, destination backendconfig.DestinationT)

func WithConstantRetries added in v1.8.0

func WithConstantRetries(operation func() error) error

Types

type EventsCountMap

type EventsCountMap map[string]int

func SourcesLoadFilesEventsMap

func SourcesLoadFilesEventsMap() EventsCountMap

func SourcesStagingFilesEventsMap

func SourcesStagingFilesEventsMap() EventsCountMap

func SourcesTableUploadsEventsMap

func SourcesTableUploadsEventsMap() EventsCountMap

func SourcesWarehouseEventsMap

func SourcesWarehouseEventsMap() EventsCountMap

type TestConfig added in v1.9.0

type TestConfig struct {
	WriteKey                     string
	Schema                       string
	UserID                       string
	WorkspaceID                  string
	JobRunID                     string
	TaskRunID                    string
	SourceID                     string
	DestinationID                string
	DestinationType              string
	Tables                       []string
	Client                       *warehouseclient.Client
	TimestampBeforeSendingEvents time.Time
	Config                       map[string]interface{}
	StagingFilePath              string
	StagingFilesEventsMap        EventsCountMap
	LoadFilesEventsMap           EventsCountMap
	TableUploadsEventsMap        EventsCountMap
	WarehouseEventsMap           EventsCountMap
	JobsDB                       *sql.DB
	AsyncJob                     bool
	SkipWarehouse                bool
	HTTPPort                     int
}

func (*TestConfig) VerifyEvents added in v1.9.0

func (w *TestConfig) VerifyEvents(t testing.TB)

Jump to

Keyboard shortcuts

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