identity

package
v0.0.0-...-0ade494 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 26, 2022 License: AGPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL