manager

Documentation

Index

• type Manager
  • func New(destType string, conf *config.Config, logger logger.Logger, stats stats.Stats) (Manager, error)
• type WarehouseDelete
• type WarehouseOperations
  • func NewWarehouseOperations(destType string, conf *config.Config, logger logger.Logger, stats stats.Stats) (WarehouseOperations, error)

Types

type Manager

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

func New

func New(destType string, conf *config.Config, logger logger.Logger, stats stats.Stats) (Manager, error)

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

type WarehouseDelete

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

type WarehouseOperations

type WarehouseOperations interface {
	Manager
	WarehouseDelete
}

func NewWarehouseOperations

func NewWarehouseOperations(destType string, conf *config.Config, logger logger.Logger, stats stats.Stats) (WarehouseOperations, error)

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