Documentation ¶
Index ¶
- func BatchWrite(e *badger.Entry)
- func DB() *badger.DB
- func Init(config Config) error
- func MustInit(config Config)
- func Shutdown()
- func Update(fn func(txn *badger.Txn) error) (err error)
- func View(fn func(txn *badger.Txn) error) (err error)
- type Allocator
- type Config
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BatchWrite ¶
func BatchWrite(e *badger.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
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
Click to show internal directories.
Click to hide internal directories.