repository

Documentation

Index

• func GetAirbyteUnprocessedRawRecords(ctx context.Context, db *gorm.DB, limit int, ...) (entity.AirbyteRaws, error)
• func GetOpenlineUnprocessedRawRecords(ctx context.Context, db *gorm.DB, limit int, ...) (entity.OpenlineRaws, error)
• func MarkAirbyteRawRecordProcessed(ctx context.Context, db *gorm.DB, ...) error
• func MarkOpenlineRawRecordProcessed(ctx context.Context, db *gorm.DB, syncedEntity, tableSuffix, rawId string, ...) error

Functions

func GetAirbyteUnprocessedRawRecords

func GetAirbyteUnprocessedRawRecords(ctx context.Context, db *gorm.DB, limit int, runId, syncedEntity, tableSuffix, tenant, sourceId string) (entity.AirbyteRaws, error)

func GetOpenlineUnprocessedRawRecords

func GetOpenlineUnprocessedRawRecords(ctx context.Context, db *gorm.DB, limit int, runId, syncedEntity, tableSuffix string) (entity.OpenlineRaws, error)

func MarkAirbyteRawRecordProcessed

func MarkAirbyteRawRecordProcessed(ctx context.Context, db *gorm.DB, tenant, syncedEntity, tableSuffix, airbyteRawId string, synced, skipped bool, runId, externalId, reason string) error

func MarkOpenlineRawRecordProcessed

func MarkOpenlineRawRecordProcessed(ctx context.Context, db *gorm.DB, syncedEntity, tableSuffix, rawId string, synced, skipped bool, runId, externalId, reason string) error