store

Documentation

Index

• Variables
• func Delete(txn *rony.StoreTxn, alloc *tools.Allocator, keyParts ...interface{}) error
• func Exists(txn *rony.StoreTxn, alloc *tools.Allocator, keyParts ...interface{}) bool
• func ExistsByKey(txn *rony.StoreTxn, alloc *tools.Allocator, key []byte) bool
• func Get(txn *rony.StoreTxn, alloc *tools.Allocator, keyParts ...interface{}) ([]byte, error)
• func GetByKey(txn *rony.StoreTxn, alloc *tools.Allocator, key []byte) ([]byte, error)
• func Marshal(txn *rony.StoreTxn, alloc *tools.Allocator, m proto.Message, ...) error
• func Move(txn *rony.StoreTxn, oldKey, newKey []byte) error
• func ProvideDI(cfg Config)
• func Set(txn *rony.StoreTxn, alloc *tools.Allocator, val []byte, ...) error
• func SetByKey(txn *rony.StoreTxn, val, key []byte) error
• func Unmarshal(txn *rony.StoreTxn, alloc *tools.Allocator, m proto.Message, ...) error
• func UnmarshalMerge(txn *rony.StoreTxn, alloc *tools.Allocator, m proto.Message, ...) error
• type Config
  • func DefaultConfig(dataPath string) Config
• type Entry
  • func NewEntry(key, value []byte) *Entry
• type Item
• type IterOption
  • func NewIterOption() *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 NewListOption() *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
• type Store
  • func New(cfg Config) (*Store, error)
  • func (s *Store) LocalDB() *LocalDB
  • func (s *Store) Shutdown()
  • func (s *Store) Update(fn func(txn *rony.StoreTxn) error) error
  • func (s *Store) View(fn func(txn *rony.StoreTxn) error) error

Variables

var (
	ErrKeyNotFound         = badger.ErrKeyNotFound
	DefaultIteratorOptions = badger.DefaultIteratorOptions
)

var (
	ErrAlreadyExists = fmt.Errorf("already exists")
	ErrEmptyObject   = fmt.Errorf("empty object")
)

Functions

func Delete

func Delete(txn *rony.StoreTxn, alloc *tools.Allocator, keyParts ...interface{}) error

func Exists

func Exists(txn *rony.StoreTxn, alloc *tools.Allocator, keyParts ...interface{}) bool

func ExistsByKey

func ExistsByKey(txn *rony.StoreTxn, alloc *tools.Allocator, key []byte) bool

func Get

func Get(txn *rony.StoreTxn, alloc *tools.Allocator, keyParts ...interface{}) ([]byte, error)

func GetByKey

func GetByKey(txn *rony.StoreTxn, alloc *tools.Allocator, key []byte) ([]byte, error)

func Marshal

func Marshal(txn *rony.StoreTxn, alloc *tools.Allocator, m proto.Message, keyParts ...interface{}) error

func Move

func Move(txn *rony.StoreTxn, oldKey, newKey []byte) error

func ProvideDI

func ProvideDI(cfg Config)

func Set

func Set(txn *rony.StoreTxn, alloc *tools.Allocator, val []byte, keyParts ...interface{}) error

func SetByKey

func SetByKey(txn *rony.StoreTxn, val, key []byte) error

func Unmarshal

func Unmarshal(txn *rony.StoreTxn, alloc *tools.Allocator, m proto.Message, keyParts ...interface{}) error

func UnmarshalMerge

func UnmarshalMerge(txn *rony.StoreTxn, alloc *tools.Allocator, m proto.Message, keyParts ...interface{}) error

Types

type Config

type Config struct {
	DirPath             string
	ConflictRetries     int
	ConflictMaxInterval time.Duration
	BatchWorkers        int
	BatchSize           int
	InMemory            bool
}

func DefaultConfig

func DefaultConfig(dataPath string) Config

type Entry

type Entry = badger.Entry

func NewEntry

func NewEntry(key, value []byte) *Entry

type Item

type Item = badger.Item

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

type LocalDB

type LocalDB = badger.DB

type Store

type Store struct {
	// contains filtered or unexported fields
}

func New

func New(cfg Config) (*Store, error)

func (*Store) LocalDB

func (s *Store) LocalDB() *LocalDB

func (*Store) Shutdown

func (s *Store) Shutdown()

func (*Store) Update

func (s *Store) Update(fn func(txn *rony.StoreTxn) error) error

func (*Store) View

func (s *Store) View(fn func(txn *rony.StoreTxn) error) error