Function NewValkeyDataCache

lib/valkeycache/cache.go:39–68

NewValkeyDataCache creates a new ValkeyDataCache instance.

(
	keyPrefix string,
	host string,
	port string, // Will likely come from the environment variable as a string
	ttl time.Duration)

// NewValkeyDataCache creates a new ValkeyDataCache instance.
func NewValkeyDataCache[K comparable, V []byte](
	keyPrefix string,
	host string,
	port string, // Will likely come from the environment variable as a string
	ttl time.Duration) (*ValkeyDataCache[K, V], error) {

	addr := fmt.Sprintf("%s:%s", host, port)
	operation := func() (valkey.Client, error) {
		// nolint: exhaustruct // No need to use every option of 3rd party struct.
		return valkey.NewClient(valkey.ClientOption{
			InitAddress: []string{addr},
		})
	}

	c, err := backoff.Retry(context.TODO(), operation,
		backoff.WithBackOff(backoff.NewExponentialBackOff()),
		// Should be less than the total time in the startup probe for the backend container in
		// infra/backend/service.tf
		backoff.WithMaxElapsedTime(25*time.Second),
	)
	if err != nil {
		return nil, err
	}

	return &ValkeyDataCache[K, V]{
		keyPrefix: keyPrefix,
		client:    c,
		ttl:       ttl,
	}, nil
}

func (c *ValkeyDataCache[K, V]) cacheKey(key K) string {
	return fmt.Sprintf("%s-%v", c.keyPrefix, key)