Documentation
¶
Index ¶
- func ClusterIDs(uniqueIDList map[int]string, clusterSize int, IDDataTypeString bool) map[int]string
- func Deduplicate(IDLists []map[int]string) map[int]string
- func EventToResourceIDs(ctx context.Context, db *sql.DB, fh *sql.DB, sourceTable string, ...) map[int]string
- func LsnMax(ctx context.Context, db *sql.DB) string
- func MsSQLInit(connectionName string, ConnMaxLifetimeHours int, MaxIdleConns int, ...) (*sql.DB, context.Context)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ClusterIDs ¶
ClusterIDs serialises ID's for 'IN' clause in SQL-statement, E.g. 1234','2345','3456','5678
func Deduplicate ¶
Deduplicate receives multiple maps of ID's and returns a single map containing unique values
func EventToResourceIDs ¶
func EventToResourceIDs(ctx context.Context, db *sql.DB, fh *sql.DB, sourceTable string, srcLsnMax string, srcQuery string) map[int]string
EventToResourceIDs load CDC rows and return a map
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.