Method
SetMultiAsync
cache/mock.go:38–46
· cache/mock.go::MockCache.SetMultiAsync
(data map[string][]byte, ttl time.Duration)
Source from the content-addressed store, hash-verified
| 36 | } |
| 37 | |
| 38 | func (m *MockCache) SetMultiAsync(data map[string][]byte, ttl time.Duration) { |
| 39 | m.mu.Lock() |
| 40 | defer m.mu.Unlock() |
| 41 | |
| 42 | exp := m.now.Add(ttl) |
| 43 | for key, val := range data { |
| 44 | m.cache[key] = Item{Data: val, ExpiresAt: exp} |
| 45 | } |
| 46 | } |
| 47 | |
| 48 | func (m *MockCache) Set(_ context.Context, key string, value []byte, ttl time.Duration) error { |
| 49 | m.mu.Lock() |