Method Get

pkg/cache/db.go:356–380

(ctx context.Context, key string)

}

func (c *PostgreSQLDependentCache) Get(ctx context.Context, key string) ([]byte, string, error) {
	log := logger.FromContext(ctx)

	cacheKey := c.keyProvider.CacheKey(ctx, key)
	var value []byte
	var contentType string

	err := c.pool.QueryRow(
		ctx,
		"SELECT value, http_content_type FROM dependent_values WHERE key=$1",
		cacheKey,
	).Scan(&value, &contentType)
	if err != nil {
		if err != pgx.ErrNoRows {
			// An actual error
			log.Warnw("Unhandled sql error", "error", err)
			return nil, "", err
		}

		// Cache entry didn't exist
		return nil, "", nil
	}

	return value, contentType, nil
}

func (c *PostgreSQLDependentCache) Insert(
	ctx context.Context, key string, parentKey string, value []byte, contentType string,