pbadger

package
v0.4.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 5, 2022 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL