Documentation ¶
Index ¶
- Variables
- type LDBDatabase
- func (self *LDBDatabase) Close()
- func (self *LDBDatabase) Delete(key []byte) error
- func (self *LDBDatabase) Flush() error
- func (self *LDBDatabase) Get(key []byte) ([]byte, error)
- func (self *LDBDatabase) LDB() *leveldb.DB
- func (self *LDBDatabase) Meter(prefix string)
- func (self *LDBDatabase) NewIterator() iterator.Iterator
- func (self *LDBDatabase) Put(key []byte, value []byte) error
- type MemDatabase
- func (db *MemDatabase) Close()
- func (db *MemDatabase) Delete(key []byte) error
- func (db *MemDatabase) Flush() error
- func (db *MemDatabase) Get(key []byte) ([]byte, error)
- func (db *MemDatabase) LastKnownTD() []byte
- func (db *MemDatabase) Print()
- func (db *MemDatabase) Put(key []byte, value []byte) error
- func (db *MemDatabase) Set(key []byte, value []byte)
Constants ¶
This section is empty.
Variables ¶
View Source
var OpenFileLimit = 64
Functions ¶
This section is empty.
Types ¶
type LDBDatabase ¶
type LDBDatabase struct {
// contains filtered or unexported fields
}
func NewLDBDatabase ¶
func NewLDBDatabase(file string) (*LDBDatabase, error)
NewLDBDatabase returns a LevelDB wrapped object. LDBDatabase does not persist data by it self but requires a background poller which syncs every X. `Flush` should be called when data needs to be stored and written to disk.
func (*LDBDatabase) Close ¶
func (self *LDBDatabase) Close()
func (*LDBDatabase) Delete ¶
func (self *LDBDatabase) Delete(key []byte) error
Delete deletes the key from the queue and database
func (*LDBDatabase) Flush ¶
func (self *LDBDatabase) Flush() error
Flush flushes out the queue to leveldb
func (*LDBDatabase) Get ¶
func (self *LDBDatabase) Get(key []byte) ([]byte, error)
Get returns the given key if it's present.
func (*LDBDatabase) LDB ¶
func (self *LDBDatabase) LDB() *leveldb.DB
func (*LDBDatabase) Meter ¶
func (self *LDBDatabase) Meter(prefix string)
Meter configures the database metrics collectors and
func (*LDBDatabase) NewIterator ¶
func (self *LDBDatabase) NewIterator() iterator.Iterator
type MemDatabase ¶
type MemDatabase struct {
// contains filtered or unexported fields
}
* This is a test memory database. Do not use for any production it does not get persisted
func NewMemDatabase ¶
func NewMemDatabase() (*MemDatabase, error)
func (*MemDatabase) Close ¶
func (db *MemDatabase) Close()
func (*MemDatabase) Delete ¶
func (db *MemDatabase) Delete(key []byte) error
func (*MemDatabase) Flush ¶
func (db *MemDatabase) Flush() error
func (*MemDatabase) LastKnownTD ¶
func (db *MemDatabase) LastKnownTD() []byte
func (*MemDatabase) Print ¶
func (db *MemDatabase) Print()
func (*MemDatabase) Set ¶
func (db *MemDatabase) Set(key []byte, value []byte)
Click to show internal directories.
Click to hide internal directories.