(txn *badger.Txn, opts badger.IteratorOptions, callback func(item *badger.Item) error)
| 247 | } |
| 248 | |
| 249 | func (b *Badger) iterator(txn *badger.Txn, opts badger.IteratorOptions, callback func(item *badger.Item) error) error { |
| 250 | iter := txn.NewIterator(opts) |
| 251 | defer iter.Close() |
| 252 | |
| 253 | for iter.Rewind(); iter.Valid(); iter.Next() { |
| 254 | item := iter.Item() |
| 255 | |
| 256 | if err := callback(item); err != nil { |
| 257 | return err |
| 258 | } |
| 259 | } |
| 260 | |
| 261 | return nil |
| 262 | } |
| 263 | |
| 264 | func (b *Badger) getKey(format string, a ...interface{}) []byte { |
| 265 | resourcePath := fmt.Sprintf(format, a...) |
no test coverage detected