manager

Documentation

Index

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

Types

type ManagerI

type ManagerI interface {
	Setup(warehouse warehouseutils.Warehouse, uploader warehouseutils.UploaderI) error
	CrashRecover(warehouse warehouseutils.Warehouse) (err error)
	FetchSchema(warehouse warehouseutils.Warehouse) (warehouseutils.SchemaT, warehouseutils.SchemaT, error)
	CreateSchema() (err error)
	CreateTable(tableName string, columnMap map[string]string) (err error)
	AddColumns(tableName string, columnsInfo []warehouseutils.ColumnInfo) (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)
}

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)
	DeleteBy(tableName []string, params warehouseutils.DeleteByParams) 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