manager

package
v1.0.2 Latest Latest
Warning

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

Go to latest
Published: Aug 25, 2022 License: AGPL-3.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ManagerI

type ManagerI interface {
	Setup(warehouse warehouseutils.WarehouseT, uploader warehouseutils.UploaderI) error
	CrashRecover(warehouse warehouseutils.WarehouseT) (err error)
	FetchSchema(warehouse warehouseutils.WarehouseT) (warehouseutils.SchemaT, error)
	CreateSchema() (err error)
	CreateTable(tableName string, columnMap map[string]string) (err error)
	AddColumn(tableName, columnName, columnType string) (err error)
	AlterColumn(tableName, columnName, columnType string) (err error)
	LoadTable(tableName string) error
	LoadUserTables() map[string]error
	LoadIdentityMergeRulesTable() error
	LoadIdentityMappingsTable() error
	Cleanup()
	IsEmpty(warehouse warehouseutils.WarehouseT) (bool, error)
	TestConnection(warehouse warehouseutils.WarehouseT) error
	DownloadIdentityRules(*misc.GZipWriter) error
	GetTotalCountInTable(tableName string) (int64, error)
	Connect(warehouse warehouseutils.WarehouseT) (client.Client, error)
	LoadTestTable(location, stagingTableName string, payloadMap map[string]interface{}, loadFileFormat string) error
	SetConnectionTimeout(timeout time.Duration)
}

func New

func New(destType string) (ManagerI, error)

New is a Factory function that returns a ManagerI of a given destination-type

type WarehouseDelete

type WarehouseDelete interface {
	DropTable(tableName string) (err error)
}

type WarehouseOperations

type WarehouseOperations interface {
	ManagerI
	WarehouseDelete
}

func NewWarehouseOperations

func NewWarehouseOperations(destType string) (WarehouseOperations, error)

NewWarehouseOperations is a Factory function that returns a WarehouseOperations of a given destination-type

Jump to

Keyboard shortcuts

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