Method Insert

pkg/cache/db.go:382–403

(
	ctx context.Context, key string, parentKey string, value []byte, contentType string,
)

}

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

	cacheKey := c.keyProvider.CacheKey(ctx, key)
	if _, err := c.pool.Exec(
		ctx,
		"INSERT INTO dependent_values (key, parent_key, value, http_content_type, "+
			"expiration_timestamp) VALUES ($1, $2, $3, $4, $5)",
		cacheKey, parentKey, value, contentType, time.Now().Add(dependentExpirationDuration),
	); err != nil {
		log.Errorw("Error inserting dependent value",
			"cacheKey", cacheKey,
			"parentKey", parentKey,
			"error", err,
		)
		return err
	}

	return nil
}

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