Method commit

pkg/cache/db.go:405–422

(ctx context.Context, parentKey string)

}

func (c *PostgreSQLDependentCache) commit(ctx context.Context, parentKey string) error {
	log := logger.FromContext(ctx)

	_, err := c.pool.Exec(
		ctx,
		"UPDATE dependent_values SET committed = TRUE WHERE parent_key = $1 AND NOT committed",
		parentKey,
	)
	if err != nil {
		log.Errorw("Error committing dependent values",
			"parentKey", parentKey,
			"err", err,
		)
		return err
	}

	return nil
}

func (c *PostgreSQLDependentCache) rollback(ctx context.Context, parentKey string) error {
	log := logger.FromContext(ctx)