MCPcopy
hub / github.com/mxpv/podsync / iterator

Method iterator

pkg/db/badger.go:249–262  ·  view source on GitHub ↗
(txn *badger.Txn, opts badger.IteratorOptions, callback func(item *badger.Item) error)

Source from the content-addressed store, hash-verified

247}
248
249func (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
264func (b *Badger) getKey(format string, a ...interface{}) []byte {
265 resourcePath := fmt.Sprintf(format, a...)

Callers 3

WalkFeedsMethod · 0.95
DeleteFeedMethod · 0.95
walkEpisodesMethod · 0.95

Calls 1

CloseMethod · 0.65

Tested by

no test coverage detected