pbadger

Documentation

Index

• type PBadgerReader
  • func NewPBadgerReader(dirs []string) (*PBadgerReader, error)
  • func (pb *PBadgerReader) Close()
  • func (pb *PBadgerReader) Read(key string, dataCh chan []byte)
• type PBadgerWriter
  • func NewPBadgerWriter(dir string) (*PBadgerWriter, error)
  • func (pb *PBadgerWriter) Close()
  • func (pb *PBadgerWriter) Write(prefix string, dataCh chan []byte) error

Types

type PBadgerReader

type PBadgerReader struct {
	Badgers map[string]*badger.DB
}

func NewPBadgerReader

func NewPBadgerReader(dirs []string) (*PBadgerReader, error)

func (*PBadgerReader) Close

func (pb *PBadgerReader) Close()

func (*PBadgerReader) Read

func (pb *PBadgerReader) Read(key string, dataCh chan []byte)

type PBadgerWriter

type PBadgerWriter struct {
	DB           *badger.DB
	SeqBandwidth int
}

func NewPBadgerWriter

func NewPBadgerWriter(dir string) (*PBadgerWriter, error)

func (*PBadgerWriter) Close

func (pb *PBadgerWriter) Close()

func (*PBadgerWriter) Write

func (pb *PBadgerWriter) Write(prefix string, dataCh chan []byte) error