Documentation ¶
Index ¶
- Variables
- func BatchWrite(e *Entry)
- func Delete(txn *rony.StoreLocalTxn, alloc *tools.Allocator, keyParts ...interface{}) error
- func Exists(txn *rony.StoreLocalTxn, alloc *tools.Allocator, keyParts ...interface{}) bool
- func Get(txn *rony.StoreLocalTxn, alloc *tools.Allocator, keyParts ...interface{}) ([]byte, error)
- func GetByKey(txn *rony.StoreLocalTxn, alloc *tools.Allocator, key []byte) ([]byte, error)
- func Init(config Config)
- func Marshal(txn *rony.StoreLocalTxn, alloc *tools.Allocator, m proto.Message, ...) error
- func Move(txn *rony.StoreLocalTxn, oldKey, newKey []byte) error
- func Set(txn *rony.StoreLocalTxn, alloc *tools.Allocator, val []byte, ...) error
- func Unmarshal(txn *rony.StoreLocalTxn, alloc *tools.Allocator, m proto.Message, ...) error
- func UnmarshalMerge(txn *rony.StoreLocalTxn, alloc *tools.Allocator, m proto.Message, ...) error
- func Update(fn func(txn *rony.StoreLocalTxn) error) (err error)
- func View(fn func(txn *rony.StoreLocalTxn) error) (err error)
- 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 LocalDB
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrKeyNotFound = badger.ErrKeyNotFound DefaultIteratorOptions = badger.DefaultIteratorOptions )
View Source
var ( ErrAlreadyExists = fmt.Errorf("already exists") ErrEmptyObject = fmt.Errorf("empty object") )
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 Delete ¶ added in v0.5.25
func Delete(txn *rony.StoreLocalTxn, alloc *tools.Allocator, keyParts ...interface{}) error
func Exists ¶ added in v0.5.25
func Exists(txn *rony.StoreLocalTxn, alloc *tools.Allocator, keyParts ...interface{}) bool
func UnmarshalMerge ¶ added in v0.5.25
Types ¶
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.