| 42 | } |
| 43 | |
| 44 | type MemoryStorage struct { |
| 45 | parentStorage StorageInterface |
| 46 | |
| 47 | policy *serverconfigs.HTTPCachePolicy |
| 48 | list ListInterface |
| 49 | locker *sync.RWMutex |
| 50 | |
| 51 | valuesMap map[uint64]*MemoryItem // hash => item |
| 52 | |
| 53 | dirtyChan chan string // hash chan |
| 54 | dirtyQueueSize int |
| 55 | |
| 56 | purgeTicker *utils.Ticker |
| 57 | |
| 58 | usedSize int64 |
| 59 | totalDirtySize int64 |
| 60 | |
| 61 | writingKeyMap map[string]zero.Zero // key => bool |
| 62 | |
| 63 | ignoreKeys *setutils.FixedSet |
| 64 | } |
| 65 | |
| 66 | func NewMemoryStorage(policy *serverconfigs.HTTPCachePolicy, parentStorage StorageInterface) *MemoryStorage { |
| 67 | var dirtyChan chan string |
nothing calls this directly
no outgoing calls
no test coverage detected