database

Documentation

Index

• Constants
• type Badger
  • func NewBadger(path string, inMemory bool) (*Badger, error)
  • func NewBadgerWithLogger(path string, inMemory bool, logger *logrus.Entry) (*Badger, error)
  • func (b *Badger) Close() error
  • func (b *Badger) Delete(key string) error
  • func (b *Badger) Get(key string) ([]byte, error)
  • func (b *Badger) Has(key string) (bool, error)
  • func (b *Badger) Persist(key string, value []byte) error
  • func (b *Badger) Read(prefix string) (map[string][]byte, error)
• type Database
• type Error
  • func (e Error) Error() string
• type Memory
  • func NewMemory() *Memory
  • func (m *Memory) Close() error
  • func (m *Memory) Delete(key string) error
  • func (m *Memory) Get(key string) ([]byte, error)
  • func (m *Memory) Has(key string) (bool, error)
  • func (m *Memory) Persist(key string, value []byte) error
  • func (m *Memory) Read(prefix string) (map[string][]byte, error)
• type PrefixDB
  • func NewPrefixDB(prefix string, db Database) *PrefixDB
  • func (p *PrefixDB) Close() error
  • func (p *PrefixDB) Delete(key string) error
  • func (p *PrefixDB) Get(key string) ([]byte, error)
  • func (p *PrefixDB) Has(key string) (bool, error)
  • func (p *PrefixDB) Persist(key string, value []byte) error
  • func (p *PrefixDB) Read(prefix string) (map[string][]byte, error)

Constants

const (
	ErrNotFound = Error("not found")
)

Types

type Badger

type Badger struct {
	// contains filtered or unexported fields
}

Badger implements Database

func NewBadger

func NewBadger(path string, inMemory bool) (*Badger, error)

func NewBadgerWithLogger

func NewBadgerWithLogger(path string, inMemory bool, logger *logrus.Entry) (*Badger, error)

func (*Badger) Close

func (b *Badger) Close() error

func (*Badger) Delete

func (b *Badger) Delete(key string) error

func (*Badger) Get

func (b *Badger) Get(key string) ([]byte, error)

func (*Badger) Has

func (b *Badger) Has(key string) (bool, error)

func (*Badger) Persist

func (b *Badger) Persist(key string, value []byte) error

func (*Badger) Read

func (b *Badger) Read(prefix string) (map[string][]byte, error)

type Database

type Database interface {
	// Persist update or insert the key
	Persist(key string, value []byte) error
	Get(key string) ([]byte, error)
	Has(key string) (bool, error)
	Read(prefix string) (map[string][]byte, error)
	Delete(key string) error
	Close() error
}

type Error

type Error string

func (Error) Error

func (e Error) Error() string

type Memory

type Memory struct {
	// contains filtered or unexported fields
}

Memory implements Database

func NewMemory

func NewMemory() *Memory

func (*Memory) Close

func (m *Memory) Close() error

func (*Memory) Delete

func (m *Memory) Delete(key string) error

func (*Memory) Get

func (m *Memory) Get(key string) ([]byte, error)

func (*Memory) Has

func (m *Memory) Has(key string) (bool, error)

func (*Memory) Persist

func (m *Memory) Persist(key string, value []byte) error

func (*Memory) Read

func (m *Memory) Read(prefix string) (map[string][]byte, error)

type PrefixDB

type PrefixDB struct {
	// contains filtered or unexported fields
}

func NewPrefixDB

func NewPrefixDB(prefix string, db Database) *PrefixDB

func (*PrefixDB) Close

func (p *PrefixDB) Close() error

func (*PrefixDB) Delete

func (p *PrefixDB) Delete(key string) error

func (*PrefixDB) Get

func (p *PrefixDB) Get(key string) ([]byte, error)

func (*PrefixDB) Has

func (p *PrefixDB) Has(key string) (bool, error)

func (*PrefixDB) Persist

func (p *PrefixDB) Persist(key string, value []byte) error

func (*PrefixDB) Read

func (p *PrefixDB) Read(prefix string) (map[string][]byte, error)