identity

Documentation

Index

• type Identity
  • func New(warehouse model.Warehouse, db *sqlmiddleware.DB, ...) *Identity
  • func (idr *Identity) Resolve(ctx context.Context) (err error)
  • func (idr *Identity) ResolveHistoricIdentities(ctx context.Context) (err error)
• type WarehouseManager

Types

type Identity

type Identity struct {
	// contains filtered or unexported fields
}

func New

func New(warehouse model.Warehouse, db *sqlmiddleware.DB, uploader warehouseutils.Uploader, uploadID int64, warehouseManager WarehouseManager, loadFileDownloader downloader.Downloader, encodingFactory *encoding.Factory) *Identity

func (*Identity) Resolve

func (idr *Identity) Resolve(ctx context.Context) (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 (*Identity) ResolveHistoricIdentities

func (idr *Identity) ResolveHistoricIdentities(ctx context.Context) (err error)

type WarehouseManager

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