()
| 101 | } |
| 102 | |
| 103 | func (it *EntryInfoIterator) setCurrentEntry() bool { |
| 104 | var entryNotFound = false |
| 105 | entry, err := it.cache.shards[it.currentShard].getEntry(it.elements[it.currentIndex]) |
| 106 | |
| 107 | if err == ErrEntryNotFound { |
| 108 | it.currentEntryInfo = emptyEntryInfo |
| 109 | entryNotFound = true |
| 110 | } else if err != nil { |
| 111 | it.currentEntryInfo = EntryInfo{ |
| 112 | err: err, |
| 113 | } |
| 114 | } else { |
| 115 | it.currentEntryInfo = EntryInfo{ |
| 116 | timestamp: readTimestampFromEntry(entry), |
| 117 | hash: readHashFromEntry(entry), |
| 118 | key: readKeyFromEntry(entry), |
| 119 | value: readEntry(entry), |
| 120 | err: err, |
| 121 | } |
| 122 | } |
| 123 | |
| 124 | return entryNotFound |
| 125 | } |
| 126 | |
| 127 | func newIterator(cache *BigCache) *EntryInfoIterator { |
| 128 | elements, count := cache.shards[0].copyHashedKeys() |
no test coverage detected