Documentation ¶
Index ¶
- Variables
- func NewBoltDriver(path string) (engine.Driver, error)
- type BoltBatch
- type BoltDriver
- func (bs *BoltDriver) Close() error
- func (bs *BoltDriver) Delete(key []byte) error
- func (bs *BoltDriver) Get(key []byte) (value []byte, err error)
- func (bs *BoltDriver) GetSnapshot() (engine.Snapshot, error)
- func (bs *BoltDriver) NewBatch() engine.Batch
- func (bs *BoltDriver) NewIterator(startKey, endKey []byte) engine.Iterator
- func (bs *BoltDriver) Put(key []byte, value []byte) error
- type BoltIterator
- type BoltSnapshot
- type KvPair
- type SnapIterTx
- type Tx
Constants ¶
This section is empty.
Variables ¶
View Source
var DB_BUCKET []byte = []byte("DbBucket")
Functions ¶
Types ¶
type BoltBatch ¶
type BoltBatch struct {
// contains filtered or unexported fields
}
WriteBatch write batch
type BoltDriver ¶
type BoltDriver struct {
// contains filtered or unexported fields
}
Store store
func (*BoltDriver) Close ¶
func (bs *BoltDriver) Close() error
func (*BoltDriver) Delete ¶
func (bs *BoltDriver) Delete(key []byte) error
func (*BoltDriver) GetSnapshot ¶
func (bs *BoltDriver) GetSnapshot() (engine.Snapshot, error)
func (*BoltDriver) NewBatch ¶
func (bs *BoltDriver) NewBatch() engine.Batch
批量写入,提交时保证batch里的修改同时对外可见
func (*BoltDriver) NewIterator ¶
func (bs *BoltDriver) NewIterator(startKey, endKey []byte) engine.Iterator
type BoltIterator ¶
type BoltIterator struct {
// contains filtered or unexported fields
}
Iterator iterator
func NewBoltIterator ¶
func NewBoltIterator(db *bolt.DB, startKey, endKey []byte) (*BoltIterator, error)
func (*BoltIterator) Error ¶
func (iter *BoltIterator) Error() error
func (*BoltIterator) Key ¶
func (iter *BoltIterator) Key() []byte
func (*BoltIterator) Value ¶
func (iter *BoltIterator) Value() []byte
type BoltSnapshot ¶
type BoltSnapshot struct {
// contains filtered or unexported fields
}
Snapshot snapshot
func NewBoltSnapshot ¶
func NewBoltSnapshot(db *bolt.DB) (*BoltSnapshot, error)
func (*BoltSnapshot) NewIterator ¶
func (bs *BoltSnapshot) NewIterator(startKey, endKey []byte) engine.Iterator
type SnapIterTx ¶
type SnapIterTx struct {
// contains filtered or unexported fields
}
func (*SnapIterTx) Rollback ¶
func (st *SnapIterTx) Rollback() error
Click to show internal directories.
Click to hide internal directories.