db

Documentation

Index

• func NewNullDB() *nullDB
• func NewProxyDB() *proxyDB
• type BackendType
• type BadgerDB
  • func NewBadgerDB(name string, dir string) (*BadgerDB, error)
  • func (db *BadgerDB) Close() error
  • func (db *BadgerDB) GetBatch() (Batch, error)
  • func (db *BadgerDB) GetBucket(id BucketID) (Bucket, error)
  • func (db *BadgerDB) GetIterator() (Iterator, error)
  • func (db *BadgerDB) GetSnapshot() (Snapshot, error)
• type Batch
• type BoltDB
  • func NewBoltDB(name string, dir string) (*BoltDB, error)
  • func (db *BoltDB) Close() error
  • func (db *BoltDB) DB() *bolt.DB
  • func (db *BoltDB) GetBatch() (Batch, error)
  • func (db *BoltDB) GetBucket(id BucketID) (Bucket, error)
  • func (db *BoltDB) GetIterator() (Iterator, error)
  • func (db *BoltDB) GetSnapshot() (Snapshot, error)
• type Bucket
• type BucketID
• type Database
  • func NewMapDB() Database
  • func Open(dir, dbtype, name string) Database
• type GoLevelDB
  • func NewGoLevelDB(name string, dir string) (*GoLevelDB, error)
  • func NewGoLevelDBWithOpts(name string, dir string, o *opt.Options) (*GoLevelDB, error)
  • func (db *GoLevelDB) Close() error
  • func (db *GoLevelDB) GetBatch() (Batch, error)
  • func (db *GoLevelDB) GetBucket(id BucketID) (Bucket, error)
  • func (db *GoLevelDB) GetIterator() (Iterator, error)
  • func (db *GoLevelDB) GetSnapshot() (Snapshot, error)
• type Iterator
• type LayerDB
  • func NewLayerDB(dbase Database) LayerDB
• type Snapshot

Functions

func NewNullDB

func NewNullDB() *nullDB

func NewProxyDB

func NewProxyDB() *proxyDB

Types

type BackendType

type BackendType string

const (
	BadgerDBBackend  BackendType = "badgerdb"
	GoLevelDBBackend BackendType = "goleveldb"
	BoltDBBackend    BackendType = "boltdb"
	MapDBBackend     BackendType = "mapdb"
)

type BadgerDB

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

func NewBadgerDB

func NewBadgerDB(name string, dir string) (*BadgerDB, error)

func (*BadgerDB) Close

func (db *BadgerDB) Close() error

func (*BadgerDB) GetBatch

func (db *BadgerDB) GetBatch() (Batch, error)

func (*BadgerDB) GetBucket

func (db *BadgerDB) GetBucket(id BucketID) (Bucket, error)

func (*BadgerDB) GetIterator

func (db *BadgerDB) GetIterator() (Iterator, error)

func (*BadgerDB) GetSnapshot

func (db *BadgerDB) GetSnapshot() (Snapshot, error)

type Batch

type Batch interface {
	New()
	Len() int
	Set(key, value []byte)
	Delete(key []byte)
	Write() error
	Reset()
}

DBIterator

type BoltDB

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

func NewBoltDB

func NewBoltDB(name string, dir string) (*BoltDB, error)

func (*BoltDB) Close

func (db *BoltDB) Close() error

func (*BoltDB) DB

func (db *BoltDB) DB() *bolt.DB

func (*BoltDB) GetBatch

func (db *BoltDB) GetBatch() (Batch, error)

func (*BoltDB) GetBucket

func (db *BoltDB) GetBucket(id BucketID) (Bucket, error)

func (*BoltDB) GetIterator

func (db *BoltDB) GetIterator() (Iterator, error)

func (*BoltDB) GetSnapshot

func (db *BoltDB) GetSnapshot() (Snapshot, error)

type Bucket

type Bucket interface {
	Get(key []byte) ([]byte, error)
	Has(key []byte) bool
	Set(key []byte, value []byte) error
	Delete(key []byte) error
}

Bucket

type BucketID

type BucketID string

const (
	// For query and calculation DB
	// I-Score
	PrefixIScore BucketID = ""

	// For calculation result DB
	PrefixCalcResult BucketID = ""

	// For claim DB
	PrefixClaim BucketID = ""

	// Information for management
	PrefixManagement BucketID = "MI"

	// Governance variable
	PrefixGovernanceVariable BucketID = "GV"

	// P-Rep candidate list
	PrefixPRepCandidate BucketID = "PC"

	// Main/Sub P-Rep list
	PrefixPRep BucketID = "PR"

	// FOR IISS data DB
	// Header
	PrefixIISSHeader BucketID = "HD"

	// IISS Governance variable
	PrefixIISSGV BucketID = "GV"

	// Block Producer Info.
	PrefixIISSBPInfo BucketID = "BP"

	// Main/Sub P-Rep list
	PrefixIISSPRep BucketID = "PR"

	// TX
	PrefixIISSTX BucketID = "TX"
)

Bucket ID

type Database

type Database interface {
	GetBucket(id BucketID) (Bucket, error)
	GetIterator() (Iterator, error)
	GetBatch() (Batch, error)
	GetSnapshot() (Snapshot, error)
	Close() error
}

func NewMapDB

func NewMapDB() Database

func Open

func Open(dir, dbtype, name string) Database

type GoLevelDB

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

func NewGoLevelDB

func NewGoLevelDB(name string, dir string) (*GoLevelDB, error)

func NewGoLevelDBWithOpts

func NewGoLevelDBWithOpts(name string, dir string, o *opt.Options) (*GoLevelDB, error)

func (*GoLevelDB) Close

func (db *GoLevelDB) Close() error

func (*GoLevelDB) GetBatch

func (db *GoLevelDB) GetBatch() (Batch, error)

func (*GoLevelDB) GetBucket

func (db *GoLevelDB) GetBucket(id BucketID) (Bucket, error)

func (*GoLevelDB) GetIterator

func (db *GoLevelDB) GetIterator() (Iterator, error)

func (*GoLevelDB) GetSnapshot

func (db *GoLevelDB) GetSnapshot() (Snapshot, error)

type Iterator

type Iterator interface {
	New([]byte, []byte)
	Next() bool
	Key() []byte
	Value() []byte
	Release()
	Error() error
}

DBIterator

type LayerDB

type LayerDB interface {
	Database
	Flush(write bool) error
}

func NewLayerDB

func NewLayerDB(dbase Database) LayerDB

type Snapshot

type Snapshot interface {
	New() error
	Get(key []byte) ([]byte, error)
	NewIterator([]byte, []byte)
	IterNext() bool
	IterKey() []byte
	IterValue() []byte
	ReleaseIterator()
	Release()
}

DB Snapshot