Method GetMultiWithError

cache/compression.go:105–123

GetMultiWithError implements Cache.

(ctx context.Context, keys []string, opts ...Option)

// GetMultiWithError implements Cache.
func (s *SnappyCache) GetMultiWithError(ctx context.Context, keys []string, opts ...Option) (map[string][]byte, error) {
	errs := []error{}

	found, err := s.next.GetMultiWithError(ctx, keys, opts...)
	errs = append(errs, err)
	decoded := make(map[string][]byte, len(found))

	for key, encodedValue := range found {
		decodedValue, decodeErr := snappy.Decode(nil, encodedValue)
		if decodeErr != nil {
			errs = append(errs, fmt.Errorf("failed to decode cache entry for key %s: %w", key, decodeErr))
			continue
		}

		decoded[key] = decodedValue
	}

	return decoded, errors.Join(errs...)
}

// Stop implements Cache.
func (s *SnappyCache) Stop() {