identity

package
v1.9.0-rc.2 Latest Latest
Warning

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

Go to latest
Published: May 19, 2023 License: AGPL-3.0 Imports: 18 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          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
}

Jump to

Keyboard shortcuts

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