kv

Documentation

Index

• Variables
• func DB() *badger.DB
• func Index() *buntdb.DB
• func Init(config Config) error
• func MustInit(config Config)
• func Update(fn func(txn *badger.Txn) error) (err error)
• func UpdateIndex(fn func(tx *buntdb.Tx) error) (err error)
• func View(fn func(txn *badger.Txn) error) (err error)
• func ViewIndex(fn func(tx *buntdb.Tx) error) error
• type Allocator
  • func NewAllocator() *Allocator
  • func (bk *Allocator) GenKey(v ...interface{}) []byte
  • func (bk *Allocator) GenValue(m proto.Message) []byte
  • func (bk *Allocator) ReleaseAll()
• type Config

Variables

var (
	DefaultConfig = Config{
		DirPath:             "./_hdd",
		ConflictRetries:     100,
		ConflictMaxInterval: time.Millisecond,
	}
)

Functions

func DB

func DB() *badger.DB

func Index

func Index() *buntdb.DB

func Init

func Init(config Config) error

func MustInit

func MustInit(config Config)

func Update

func Update(fn func(txn *badger.Txn) error) (err error)

func UpdateIndex

func UpdateIndex(fn func(tx *buntdb.Tx) error) (err error)

func View

func View(fn func(txn *badger.Txn) error) (err error)

func ViewIndex

func ViewIndex(fn func(tx *buntdb.Tx) error) error

Types

type Allocator

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

func NewAllocator

func NewAllocator() *Allocator

func (*Allocator) GenKey

func (bk *Allocator) GenKey(v ...interface{}) []byte

func (*Allocator) GenValue

func (bk *Allocator) GenValue(m proto.Message) []byte

func (*Allocator) ReleaseAll

func (bk *Allocator) ReleaseAll()

type Config

type Config struct {
	DirPath             string
	ConflictRetries     int
	ConflictMaxInterval time.Duration
}