db

Documentation

Index

• func CloseStaleTasks(dbpool *pgxpool.Pool, timestamp time.Time) error
• func InsertCheckError(dbpool *pgxpool.Pool, ...) error
• func InsertSpecError(dbpool *pgxpool.Pool, packageName, packageVersion string, timestamp time.Time, ...) error
• func InsertTaskLog(dbpool *pgxpool.Pool, id, level, logger, message, syncId, taskId string, ...) error
• func UpdateRunningTaskDate(dbpool *pgxpool.Pool, taskId string) error
• func UpdateRunningTaskMetrics(dbpool *pgxpool.Pool, taskId string, metrics map[string]any) error
• func UpdateRunningTaskStatus(dbpool *pgxpool.Pool, taskId, status string) error
• func UpsertCatalogStatus(dbpool *pgxpool.Pool, packageName, packageVersion, storageKey string, ...) error
• func UpsertCatalogSuccess(dbpool *pgxpool.Pool, packageName, packageVersion, storageKey string, ...) error
• func UpsertCheck(dbpool *pgxpool.Pool, ...) error
• func UpsertRunningCatalogStatus(dbpool *pgxpool.Pool, packageName, packageVersion, storageKey string, ...) error
• func UpsertRunningTask(dbpool *pgxpool.Pool, syncId, taskId, packageName, packageVersion string, ...) error
• func UpsertSpec(dbpool *pgxpool.Pool, packageName, packageVersion, specs any, ...) error
• func UpsertState(dbpool *pgxpool.Pool, syncId, stream string, state any, timestamp time.Time) error
• func UpsertTaskDescriptionAndError(dbpool *pgxpool.Pool, syncId, taskId, packageName, packageVersion string, ...) error
• func UpsertTaskError(dbpool *pgxpool.Pool, syncId, taskId, packageName, packageVersion string, ...) error

Functions

func CloseStaleTasks

func CloseStaleTasks(dbpool *pgxpool.Pool, timestamp time.Time) error

func InsertCheckError

func InsertCheckError(dbpool *pgxpool.Pool, packageName, packageVersion, storageKey, status, description string, timestamp time.Time) error

func InsertSpecError

func InsertSpecError(dbpool *pgxpool.Pool, packageName, packageVersion string, timestamp time.Time, error string) error

func InsertTaskLog

func InsertTaskLog(dbpool *pgxpool.Pool, id, level, logger, message, syncId, taskId string, timestamp time.Time) error

func UpdateRunningTaskDate

func UpdateRunningTaskDate(dbpool *pgxpool.Pool, taskId string) error

func UpdateRunningTaskMetrics

func UpdateRunningTaskMetrics(dbpool *pgxpool.Pool, taskId string, metrics map[string]any) error

func UpdateRunningTaskStatus

func UpdateRunningTaskStatus(dbpool *pgxpool.Pool, taskId, status string) error

func UpsertCatalogStatus

func UpsertCatalogStatus(dbpool *pgxpool.Pool, packageName, packageVersion, storageKey string, timestamp time.Time, status, description string) error

func UpsertCatalogSuccess

func UpsertCatalogSuccess(dbpool *pgxpool.Pool, packageName, packageVersion, storageKey string, catalog any, timestamp time.Time, status, description string) error

func UpsertCheck

func UpsertCheck(dbpool *pgxpool.Pool, packageName, packageVersion, storageKey, status, description string, timestamp time.Time) error

func UpsertRunningCatalogStatus

func UpsertRunningCatalogStatus(dbpool *pgxpool.Pool, packageName, packageVersion, storageKey string, timestamp time.Time, status, description string) error

func UpsertRunningTask

func UpsertRunningTask(dbpool *pgxpool.Pool, syncId, taskId, packageName, packageVersion string, startedAt time.Time, status, error, startedBy string) error

func UpsertSpec

func UpsertSpec(dbpool *pgxpool.Pool, packageName, packageVersion, specs any, timestamp time.Time, error string) error

func UpsertState

func UpsertState(dbpool *pgxpool.Pool, syncId, stream string, state any, timestamp time.Time) error

func UpsertTaskDescriptionAndError

func UpsertTaskDescriptionAndError(dbpool *pgxpool.Pool, syncId, taskId, packageName, packageVersion string, startedAt time.Time, status, description, error string) error

func UpsertTaskError

func UpsertTaskError(dbpool *pgxpool.Pool, syncId, taskId, packageName, packageVersion string, startedAt time.Time, status, error string) error