Documentation
¶
Index ¶
- Variables
- func BatchWrite(e *Entry)
- func DB() *badger.DB
- func Init(config Config) (err error)
- func MustInit(config Config)
- func Shutdown()
- func Update(fn func(txn *Txn) error) (err error)
- func View(fn func(txn *Txn) error) (err error)
- type Allocator
- type Config
- type Entry
- type IterOption
- func (o *IterOption) Backward() bool
- func (o *IterOption) OffsetKey() []byte
- func (o *IterOption) OnClose(key []byte)
- func (o *IterOption) SetBackward() *IterOption
- func (o *IterOption) SetForward() *IterOption
- func (o *IterOption) SetOffsetKey(offset []byte) *IterOption
- func (o *IterOption) SetOnClose(f func(key []byte)) *IterOption
- type ListOption
- func (o *ListOption) Backward() bool
- func (o *ListOption) Limit() int32
- func (o *ListOption) SetBackward() *ListOption
- func (o *ListOption) SetForward() *ListOption
- func (o *ListOption) SetLimit(limit int32) *ListOption
- func (o *ListOption) SetSkip(skip int32) *ListOption
- func (o *ListOption) Skip() int32
- type Store
- type Txn
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrKeyNotFound = badger.ErrKeyNotFound DefaultIteratorOptions = badger.DefaultIteratorOptions )
Functions ¶
func BatchWrite ¶
func BatchWrite(e *Entry)
BatchWrite is the helper function to set the entry backed by an internal flusher. Which makes writes faster but there is no guarantee that write has been done successfully, since we bypass the errors. TODO:: Maybe improve the flusher structure to return error in the case
func Shutdown ¶
func Shutdown()
Shutdown stops all the background go-routines and closed the underlying database
Types ¶
type Allocator ¶
type Allocator struct {
// contains filtered or unexported fields
}
func NewAllocator ¶
func NewAllocator() *Allocator
func (*Allocator) ReleaseAll ¶
func (bk *Allocator) ReleaseAll()
type Config ¶
type Config struct { DirPath string ConflictRetries int ConflictMaxInterval time.Duration BatchWorkers int BatchSize int }
func DefaultConfig ¶
type IterOption ¶
type IterOption struct {
// contains filtered or unexported fields
}
func NewIterOption ¶
func NewIterOption() *IterOption
func (*IterOption) Backward ¶
func (o *IterOption) Backward() bool
func (*IterOption) OffsetKey ¶
func (o *IterOption) OffsetKey() []byte
func (*IterOption) OnClose ¶
func (o *IterOption) OnClose(key []byte)
func (*IterOption) SetBackward ¶
func (o *IterOption) SetBackward() *IterOption
func (*IterOption) SetForward ¶
func (o *IterOption) SetForward() *IterOption
func (*IterOption) SetOffsetKey ¶
func (o *IterOption) SetOffsetKey(offset []byte) *IterOption
func (*IterOption) SetOnClose ¶
func (o *IterOption) SetOnClose(f func(key []byte)) *IterOption
type ListOption ¶
type ListOption struct {
// contains filtered or unexported fields
}
func NewListOption ¶
func NewListOption() *ListOption
func (*ListOption) Backward ¶
func (o *ListOption) Backward() bool
func (*ListOption) Limit ¶
func (o *ListOption) Limit() int32
func (*ListOption) SetBackward ¶
func (o *ListOption) SetBackward() *ListOption
func (*ListOption) SetForward ¶
func (o *ListOption) SetForward() *ListOption
func (*ListOption) SetLimit ¶
func (o *ListOption) SetLimit(limit int32) *ListOption
func (*ListOption) SetSkip ¶
func (o *ListOption) SetSkip(skip int32) *ListOption
func (*ListOption) Skip ¶
func (o *ListOption) Skip() int32
Source Files
¶
Click to show internal directories.
Click to hide internal directories.