testhelper

Documentation

Index

• Constants
• func EnhanceWithDefaultEnvs(t *testing.T)
• func GetUserId(provider string) string
• func JobsDB(t testing.TB, port int) *sql.DB
• func RandSchema(provider string) string
• func VerifyConfigurationTest(t testing.TB, destination backendconfig.DestinationT)
• func WithConstantRetries(operation func() error) error
• type EventsCountMap
  • func SourcesLoadFilesEventsMap() EventsCountMap
  • func SourcesStagingFilesEventsMap() EventsCountMap
  • func SourcesTableUploadsEventsMap() EventsCountMap
  • func SourcesWarehouseEventsMap() EventsCountMap
• type TestConfig
  • func (w *TestConfig) VerifyEvents(t testing.TB)

Constants

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

Functions

func EnhanceWithDefaultEnvs

func EnhanceWithDefaultEnvs(t *testing.T)

func GetUserId

func GetUserId(provider string) string

func JobsDB

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

func RandSchema

func RandSchema(provider string) string

func VerifyConfigurationTest

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

func WithConstantRetries

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

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

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