Documentation
¶
Index ¶
- func IsKeyInDomain(key, start, end []byte) bool
- func NewDebugBatch(label string, bch Batch) debugBatch
- func NewDebugDB(label string, db DB) debugDB
- func NewDebugIterator(label string, itr Iterator) debugIterator
- func NewPrefixDB(db DB, prefix []byte) *prefixDB
- type Batch
- type DB
- type DBBackendType
- type FSDB
- func (db *FSDB) Close()
- func (db *FSDB) Delete(key []byte)
- func (db *FSDB) DeleteNoLock(key []byte)
- func (db *FSDB) DeleteSync(key []byte)
- func (db *FSDB) Get(key []byte) []byte
- func (db *FSDB) Has(key []byte) bool
- func (db *FSDB) Iterator(start, end []byte) Iterator
- func (db *FSDB) MakeIterator(start, end []byte, isReversed bool) Iterator
- func (db *FSDB) Mutex() *sync.Mutex
- func (db *FSDB) NewBatch() Batch
- func (db *FSDB) Print()
- func (db *FSDB) ReverseIterator(start, end []byte) Iterator
- func (db *FSDB) Set(key []byte, value []byte)
- func (db *FSDB) SetNoLock(key []byte, value []byte)
- func (db *FSDB) SetSync(key []byte, value []byte)
- func (db *FSDB) Stats() map[string]string
- type GoLevelDB
- func (db *GoLevelDB) Close()
- func (db *GoLevelDB) DB() *leveldb.DB
- func (db *GoLevelDB) Delete(key []byte)
- func (db *GoLevelDB) DeleteSync(key []byte)
- func (db *GoLevelDB) Get(key []byte) []byte
- func (db *GoLevelDB) Has(key []byte) bool
- func (db *GoLevelDB) Iterator(start, end []byte) Iterator
- func (db *GoLevelDB) NewBatch() Batch
- func (db *GoLevelDB) Print()
- func (db *GoLevelDB) ReverseIterator(start, end []byte) Iterator
- func (db *GoLevelDB) Set(key []byte, value []byte)
- func (db *GoLevelDB) SetSync(key []byte, value []byte)
- func (db *GoLevelDB) Stats() map[string]string
- type Iterator
- type MemDB
- func (db *MemDB) Close()
- func (db *MemDB) Delete(key []byte)
- func (db *MemDB) DeleteNoLock(key []byte)
- func (db *MemDB) DeleteNoLockSync(key []byte)
- func (db *MemDB) DeleteSync(key []byte)
- func (db *MemDB) Get(key []byte) []byte
- func (db *MemDB) Has(key []byte) bool
- func (db *MemDB) Iterator(start, end []byte) Iterator
- func (db *MemDB) Mutex() *sync.Mutex
- func (db *MemDB) NewBatch() Batch
- func (db *MemDB) Print()
- func (db *MemDB) ReverseIterator(start, end []byte) Iterator
- func (db *MemDB) Set(key []byte, value []byte)
- func (db *MemDB) SetNoLock(key []byte, value []byte)
- func (db *MemDB) SetNoLockSync(key []byte, value []byte)
- func (db *MemDB) SetSync(key []byte, value []byte)
- func (db *MemDB) Stats() map[string]string
- type SetDeleter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsKeyInDomain ¶
See DB interface documentation for more information.
func NewDebugBatch ¶
For printing all operationgs to the console for debugging.
func NewDebugDB ¶
For printing all operationgs to the console for debugging.
func NewDebugIterator ¶
For printing all operationgs to the console for debugging.
Types ¶
type Batch ¶
type Batch interface {
SetDeleter
Write()
WriteSync()
Close()
}
Batch Close must be called when the program no longer needs the object.
type DB ¶
type DB interface {
// Get returns nil iff key doesn't exist.
// A nil key is interpreted as an empty byteslice.
// CONTRACT: key, value readonly []byte
Get([]byte) []byte
// Has checks if a key exists.
// A nil key is interpreted as an empty byteslice.
// CONTRACT: key, value readonly []byte
Has(key []byte) bool
// Set sets the key.
// A nil key is interpreted as an empty byteslice.
// CONTRACT: key, value readonly []byte
Set([]byte, []byte)
SetSync([]byte, []byte)
// Delete deletes the key.
// A nil key is interpreted as an empty byteslice.
// CONTRACT: key readonly []byte
Delete([]byte)
DeleteSync([]byte)
// Iterate over a domain of keys in ascending order. End is exclusive.
// Start must be less than end, or the Iterator is invalid.
// A nil start is interpreted as an empty byteslice.
// If end is nil, iterates up to the last item (inclusive).
// CONTRACT: No writes may happen within a domain while an iterator exists over it.
// CONTRACT: start, end readonly []byte
Iterator(start, end []byte) Iterator
// Iterate over a domain of keys in descending order. End is exclusive.
// Start must be less than end, or the Iterator is invalid.
// If start is nil, iterates up to the first/least item (inclusive).
// If end is nil, iterates from the last/greatest item (inclusive).
// CONTRACT: No writes may happen within a domain while an iterator exists over it.
// CONTRACT: start, end readonly []byte
ReverseIterator(start, end []byte) Iterator
// Closes the connection.
Close()
// Creates a batch for atomic updates.
NewBatch() Batch
// For debugging
Print()
// Stats returns a map of property values for all keys and the size of the cache.
Stats() map[string]string
}
DBs are goroutine safe.
func NewDB ¶
func NewDB(name string, backend DBBackendType, dir string) DB
NewDB creates a new database of type backend with the given name. NOTE: function panics if:
- backend is unknown (not registered)
- creator function, provided during registration, returns error
type DBBackendType ¶
type DBBackendType string
const ( LevelDBBackend DBBackendType = "leveldb" // legacy, defaults to goleveldb unless +gcc CLevelDBBackend DBBackendType = "cleveldb" GoLevelDBBackend DBBackendType = "goleveldb" MemDBBackend DBBackendType = "memdb" FSDBBackend DBBackendType = "fsdb" // using the filesystem naively )
type FSDB ¶
type FSDB struct {
// contains filtered or unexported fields
}
It's slow.
func (*FSDB) DeleteNoLock ¶
NOTE: Implements atomicSetDeleter.
func (*FSDB) MakeIterator ¶
func (*FSDB) SetNoLock ¶
NOTE: Implements atomicSetDeleter.
type GoLevelDB ¶
type GoLevelDB struct {
// contains filtered or unexported fields
}
func NewGoLevelDBWithOpts ¶
func (*GoLevelDB) Iterator ¶
Implements DB.
func (*GoLevelDB) ReverseIterator ¶
Implements DB.
type Iterator ¶
type Iterator interface {
// The start & end (exclusive) limits to iterate over.
// If end < start, then the Iterator goes in reverse order.
//
// A domain of ([]byte{12, 13}, []byte{12, 14}) will iterate
// over anything with the prefix []byte{12, 13}.
//
// The smallest key is the empty byte array []byte{} - see BeginningKey().
// The largest key is the nil byte array []byte(nil) - see EndingKey().
// CONTRACT: start, end readonly []byte
Domain() (start []byte, end []byte)
// Valid returns whether the current position is valid.
// Once invalid, an Iterator is forever invalid.
Valid() bool
// Next moves the iterator to the next sequential key in the database, as
// defined by order of iteration.
//
// If Valid returns false, this method will panic.
Next()
// Key returns the key of the cursor.
// If Valid returns false, this method will panic.
// CONTRACT: key readonly []byte
Key() (key []byte)
// Value returns the value of the cursor.
// If Valid returns false, this method will panic.
// CONTRACT: value readonly []byte
Value() (value []byte)
// Close releases the Iterator.
Close()
}
Usage:
var itr Iterator = ... defer itr.Close()
for ; itr.Valid(); itr.Next() {
k, v := itr.Key(); itr.Value()
// ...
}
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
remotedb is a package for connecting to distributed Tendermint db.DB instances.
|
remotedb is a package for connecting to distributed Tendermint db.DB instances. |
|
grpcdb
grpcdb is the distribution of Tendermint's db.DB instances using the gRPC transport to decouple local db.DB usages from applications, to using them over a network in a highly performant manner.
|
grpcdb is the distribution of Tendermint's db.DB instances using the gRPC transport to decouple local db.DB usages from applications, to using them over a network in a highly performant manner. |
|
proto
Package protodb is a generated protocol buffer package.
|
Package protodb is a generated protocol buffer package. |
Click to show internal directories.
Click to hide internal directories.