Versions in this module Expand all Collapse all v0 v0.4.1 Sep 5, 2022 v0.4.0 Aug 30, 2022 Changes in this version + type PBadgerReader struct + Badgers map[string]*badger.DB + func NewPBadgerReader(dirs []string) (*PBadgerReader, error) + func (pb *PBadgerReader) Close() + func (pb *PBadgerReader) Read(key string, dataCh chan []byte) + type PBadgerWriter struct + DB *badger.DB + SeqBandwidth int + func NewPBadgerWriter(dir string) (*PBadgerWriter, error) + func (pb *PBadgerWriter) Close() + func (pb *PBadgerWriter) Write(prefix string, dataCh chan []byte) error