localdb

Documentation

Index

• type Config
  • func DefaultConfig(dataPath string) Config
• type Store
  • func New(cfg Config) (*Store, error)
  • func (s *Store) DB() *store.LocalDB
  • func (s *Store) Shutdown()
  • func (s *Store) Update(fn func(txn rony.StoreTxn) error) error
  • func (s *Store) UpdateLocal(fn func(txn *rony.StoreLocalTxn) error) error
  • func (s *Store) View(fn func(rony.StoreTxn) error) error
  • func (s *Store) ViewLocal(fn func(txn *rony.StoreLocalTxn) error) error

Types

type Config

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

func DefaultConfig

func DefaultConfig(dataPath string) Config

type Store

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

func New

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

func (*Store) DB

func (s *Store) DB() *store.LocalDB

func (*Store) Shutdown

func (s *Store) Shutdown()

func (*Store) Update

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

func (*Store) UpdateLocal

func (s *Store) UpdateLocal(fn func(txn *rony.StoreLocalTxn) error) error

func (*Store) View

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

func (*Store) ViewLocal

func (s *Store) ViewLocal(fn func(txn *rony.StoreLocalTxn) error) error