manager

Documentation

Index

• type Manager
  • func New(destType string) (Manager, error)
• type WarehouseDelete
• type WarehouseOperations
  • func NewWarehouseOperations(destType string) (WarehouseOperations, error)

Types

type Manager

type Manager interface {
	Setup(warehouse model.Warehouse, uploader warehouseutils.Uploader) error
	CrashRecover()
	FetchSchema(warehouse model.Warehouse) (model.Schema, model.Schema, error)
	CreateSchema() (err error)
	CreateTable(tableName string, columnMap model.TableSchema) (err error)
	AddColumns(tableName string, columnsInfo []warehouseutils.ColumnInfo) (err error)
	AlterColumn(tableName, columnName, columnType string) (model.AlterTableResponse, error)
	LoadTable(ctx context.Context, tableName string) error
	LoadUserTables(ctx context.Context) map[string]error
	LoadIdentityMergeRulesTable() error
	LoadIdentityMappingsTable() error
	Cleanup()
	IsEmpty(warehouse model.Warehouse) (bool, error)
	TestConnection(ctx context.Context, warehouse model.Warehouse) error
	DownloadIdentityRules(*misc.GZipWriter) error
	GetTotalCountInTable(ctx context.Context, tableName string) (int64, error)
	Connect(warehouse model.Warehouse) (client.Client, error)
	LoadTestTable(location, stagingTableName string, payloadMap map[string]interface{}, loadFileFormat string) error
	SetConnectionTimeout(timeout time.Duration)
	ErrorMappings() []model.JobError
}

func New

func New(destType string) (Manager, error)

New is a Factory function that returns a Manager of a given destination-type TODO: Remove flag for useLegacy once the postgres new implementation is stable

type WarehouseDelete

type WarehouseDelete interface {
	DropTable(tableName string) (err error)
	DeleteBy(tableName []string, params warehouseutils.DeleteByParams) error
}

type WarehouseOperations

type WarehouseOperations interface {
	Manager
	WarehouseDelete
}

func NewWarehouseOperations

func NewWarehouseOperations(destType string) (WarehouseOperations, error)

NewWarehouseOperations is a Factory function that returns a WarehouseOperations of a given destination-type TODO: Remove flag for useLegacy once the postgres new implementation is stable