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        warehouseutils.WarehouseT
	DbHandle         *sql.DB
	Uploader         warehouseutils.UploaderI
	UploadID         int64
	WarehouseManager WarehouseManager
}

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
}