| 83 | } |
| 84 | |
| 85 | type eventuallyConsistentStorage struct { |
| 86 | mu sync.Mutex |
| 87 | |
| 88 | recentlyDeleted sync.Map |
| 89 | listSettleTime time.Duration |
| 90 | |
| 91 | // +checklocks:mu |
| 92 | caches []*ecFrontendCache |
| 93 | realStorage blob.Storage |
| 94 | timeNow func() time.Time |
| 95 | } |
| 96 | |
| 97 | func (s *eventuallyConsistentStorage) randomFrontendCache() *ecFrontendCache { |
| 98 | s.mu.Lock() |
nothing calls this directly
no outgoing calls
no test coverage detected