Method GetMultiWithError

cache/lru.go:153–192

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

}

func (l *LRUCache) GetMultiWithError(ctx context.Context, keys []string, opts ...Option) (result map[string][]byte, err error) {
	l.requests.Add(float64(len(keys)))
	l.mtx.Lock()
	defer l.mtx.Unlock()
	var (
		found = make(map[string][]byte, len(keys))
		miss  = make([]string, 0, len(keys))
		now   = time.Now()
	)

	for _, k := range keys {
		item, ok := l.lru.Get(k)
		if !ok {
			miss = append(miss, k)
			continue
		}
		if item.ExpiresAt.After(now) {
			found[k] = item.Data
			continue
		}
		l.lru.Remove(k)
		miss = append(miss, k)

	}
	l.hits.Add(float64(len(found)))

	if len(miss) > 0 {
		result, err = l.c.GetMultiWithError(ctx, miss, opts...)
		for k, v := range result {
			// we don't know the ttl of the result, so we use the default one.
			l.lru.Add(k, &Item{
				Data:      v,
				ExpiresAt: now.Add(l.defaultTTL),
			})
			found[k] = v
		}
	}

	return found, err
}

func (l *LRUCache) Name() string {
	return "in-memory-" + l.name