manager

type ManagerI interface {
	Setup(warehouse warehouseutils.Warehouse, uploader warehouseutils.UploaderI) error
	CrashRecover(warehouse warehouseutils.Warehouse) (err error)
	FetchSchema(warehouse warehouseutils.Warehouse) (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.Warehouse) (bool, error)
	TestConnection(warehouse warehouseutils.Warehouse) error
	DownloadIdentityRules(*misc.GZipWriter) error
	GetTotalCountInTable(ctx context.Context, tableName string) (int64, error)
	Connect(warehouse warehouseutils.Warehouse) (client.Client, error)
	LoadTestTable(location, stagingTableName string, payloadMap map[string]interface{}, loadFileFormat string) error
	SetConnectionTimeout(timeout time.Duration)
}

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

type WarehouseOperations interface {
	ManagerI
	WarehouseDelete
}