warehouse_test

Documentation

Index

• func InitWHConfig()
• func SetWHBigQueryDestination() (cleanup func())
• func SetWHClickHouseClusterDestination(pool *dockertest.Pool) (cleanup func())
• func SetWHClickHouseDestination(pool *dockertest.Pool) (cleanup func())
• func SetWHMssqlDestination(pool *dockertest.Pool) (cleanup func())
• func SetWHPostgresDestination(pool *dockertest.Pool) (cleanup func())
• type BigQueryCredentials
• type BiqQueryTest
• type ClickHouseClusterResource
• type ClickHouseClusterResources
• type ClickHouseClusterTest
  • func (resources *ClickHouseClusterTest) GetResource() *ClickHouseClusterResource
• type ClickHouseTest
• type EventsCountMap
• type MSSQLTest
• type PostgresTest
• type WareHouseDestinationTest
• type WareHouseTest

Functions

func InitWHConfig

func InitWHConfig()

InitWHConfig Initialize warehouse config

func SetWHBigQueryDestination

func SetWHBigQueryDestination() (cleanup func())

SetWHBigQueryDestination setup warehouse Big query destination

func SetWHClickHouseClusterDestination

func SetWHClickHouseClusterDestination(pool *dockertest.Pool) (cleanup func())

SetWHClickHouseClusterDestination setup warehouse clickhouse cluster mode destination

func SetWHClickHouseDestination

func SetWHClickHouseDestination(pool *dockertest.Pool) (cleanup func())

SetWHClickHouseDestination setup warehouse clickhouse destination

func SetWHMssqlDestination

func SetWHMssqlDestination(pool *dockertest.Pool) (cleanup func())

SetWHMssqlDestination setup warehouse mssql destination

func SetWHPostgresDestination

func SetWHPostgresDestination(pool *dockertest.Pool) (cleanup func())

SetWHPostgresDestination setup warehouse postgres destination

Types

type BigQueryCredentials

type BigQueryCredentials struct {
	ProjectID          string            `json:"projectID"`
	Credentials        map[string]string `json:"credentials"`
	Location           string            `json:"location"`
	Bucket             string            `json:"bucketName"`
	CredentialsEscaped string
}

type BiqQueryTest

type BiqQueryTest struct {
	Credentials        *BigQueryCredentials
	DB                 *bq.Client
	Context            context.Context
	EventsMap          EventsCountMap
	WriteKey           string
	Tables             []string
	PrimaryKeys        []string
	TableTestQueryFreq time.Duration
}

type ClickHouseClusterResource

type ClickHouseClusterResource struct {
	Name        string
	HostName    string
	IPAddress   string
	Credentials *clickhouse.CredentialsT
	Port        string
	Resource    *dockertest.Resource
	DB          *sql.DB
}

type ClickHouseClusterResources

type ClickHouseClusterResources []*ClickHouseClusterResource

type ClickHouseClusterTest

type ClickHouseClusterTest struct {
	Network            *dc.Network
	Zookeeper          *dockertest.Resource
	Resources          ClickHouseClusterResources
	EventsMap          EventsCountMap
	WriteKey           string
	TableTestQueryFreq time.Duration
}

func (*ClickHouseClusterTest) GetResource

func (resources *ClickHouseClusterTest) GetResource() *ClickHouseClusterResource

type ClickHouseTest

type ClickHouseTest struct {
	Resource           *dockertest.Resource
	Credentials        *clickhouse.CredentialsT
	DB                 *sql.DB
	EventsMap          EventsCountMap
	WriteKey           string
	TableTestQueryFreq time.Duration
}

type EventsCountMap

type EventsCountMap map[string]int

type MSSQLTest

type MSSQLTest struct {
	Resource           *dockertest.Resource
	Credentials        *mssql.CredentialsT
	DB                 *sql.DB
	EventsMap          EventsCountMap
	WriteKey           string
	TableTestQueryFreq time.Duration
}

type PostgresTest

type PostgresTest struct {
	Resource           *dockertest.Resource
	Credentials        *postgres.CredentialsT
	DB                 *sql.DB
	EventsMap          EventsCountMap
	WriteKey           string
	TableTestQueryFreq time.Duration
}

type WareHouseDestinationTest

type WareHouseDestinationTest struct {
	Client             *client.Client
	EventsCountMap     EventsCountMap
	WriteKey           string
	UserId             string
	Schema             string
	BQContext          context.Context
	Tables             []string
	PrimaryKeys        []string
	MessageId          string
	TableTestQueryFreq time.Duration
}

type WareHouseTest

type WareHouseTest struct {
	PGTest                     *PostgresTest
	BQTest                     *BiqQueryTest
	CHTest                     *ClickHouseTest
	CHClusterTest              *ClickHouseClusterTest
	MSSQLTest                  *MSSQLTest
	GatewayJobsSqlFunction     string
	BatchRouterJobsSqlFunction string
}

var Test *WareHouseTest