kv

Documentation

Index

• Variables
• func DB() *badger.DB
• func Init(config Config) error
• func MustInit(config Config)
• func New(config Config) (*badger.DB, error)
• func Update(fn func(txn *badger.Txn) error) (err error)
• func View(fn func(txn *badger.Txn) error) (err 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 Init

func Init(config Config) error

func MustInit

func MustInit(config Config)

func New

func New(config Config) (*badger.DB, error)

func Update

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

func View

func View(fn func(txn *badger.Txn) error) (err 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
}