identity

Documentation

Index

• type HandleT
  • func (idr *HandleT) Resolve() (err error)
  • func (idr *HandleT) ResolveHistoricIdentities() (err error)
• type WarehouseManager

Types

type HandleT

type HandleT struct {
	Warehouse          model.Warehouse
	DB                 *sql.DB
	Uploader           warehouseutils.Uploader
	UploadID           int64
	WarehouseManager   WarehouseManager
	LoadFileDownloader downloader.Downloader
}

func (*HandleT) Resolve

func (idr *HandleT) Resolve() (err error)

Resolve does the below things in a single pg txn 1. Fetch all new merge rules added in the upload 2. Append to local identity merge rules table 3. Apply each merge rule and update local identity mapping table 4. Upload the diff of each table to load files for both tables

func (*HandleT) ResolveHistoricIdentities

func (idr *HandleT) ResolveHistoricIdentities() (err error)

type WarehouseManager

type WarehouseManager interface {
	DownloadIdentityRules(*misc.GZipWriter) error
}