indexKVStore implements IndexKVStore interface.
| 46 | |
| 47 | // indexKVStore implements IndexKVStore interface. |
| 48 | type indexKVStore struct { |
| 49 | family kv.Family |
| 50 | snapshot version.Snapshot |
| 51 | |
| 52 | // memory store |
| 53 | mutable *imap.IntMap[map[string]uint32] |
| 54 | immutable *imap.IntMap[map[string]uint32] |
| 55 | // cache |
| 56 | bucketCache *expirable.LRU[uint32, *model.TrieBucket] |
| 57 | |
| 58 | lock sync.RWMutex |
| 59 | } |
| 60 | |
| 61 | // NewIndexKVStore creates an IndexKVStore instance. |
| 62 | func NewIndexKVStore(family kv.Family, cacheSize int, cacheTTL time.Duration) IndexKVStore { |
nothing calls this directly
no outgoing calls
no test coverage detected