database

Documentation

Overview

Package database provides KV database for meta-information

Index

• Variables
• func RecoverDB(path string) error
• type Storage
  • func NewDB(path string) (Storage, error)
  • func NewOpenDB(path string) (Storage, error)
• type StorageProcessor

Variables

var (
	ErrNotFound = errors.New("key not found")
)

Errors for Storage

Functions

func RecoverDB

func RecoverDB(path string) error

RecoverDB recovers LevelDB database from corruption

Types

type Storage

type Storage interface {
	CreateTemporary() (Storage, error)
	Get(key []byte) ([]byte, error)
	Put(key []byte, value []byte) error
	Delete(key []byte) error
	HasPrefix(prefix []byte) bool
	ProcessByPrefix(prefix []byte, proc StorageProcessor) error
	KeysByPrefix(prefix []byte) [][]byte
	FetchByPrefix(prefix []byte) [][]byte
	Open() error
	Close() error
	StartBatch()
	FinishBatch() error
	CompactDB() error
	Drop() error
}

Storage is an interface to KV storage

func NewDB

func NewDB(path string) (Storage, error)

NewDB creates new instance of DB, but doesn't open it (yet)

func NewOpenDB

func NewOpenDB(path string) (Storage, error)

NewOpenDB creates new instance of DB and opens it

type StorageProcessor

type StorageProcessor func(key []byte, value []byte) error

StorageProcessor is a function to process one single storage entry