db

Documentation

Index

• Constants
• Variables
• type CacheMVCCDB
  • func NewCacheMVCCDB(path string, cacheType mvcc.CacheType) (*CacheMVCCDB, error)
  • func (m *CacheMVCCDB) Checkout(t string) bool
  • func (m *CacheMVCCDB) Close() error
  • func (m *CacheMVCCDB) Commit(t string)
  • func (m *CacheMVCCDB) CurrentTag() string
  • func (m *CacheMVCCDB) Del(table string, key string) error
  • func (m *CacheMVCCDB) Flush(t string) error
  • func (m *CacheMVCCDB) Fork() MVCCDB
  • func (m *CacheMVCCDB) Get(table string, key string) (string, error)
  • func (m *CacheMVCCDB) Has(table string, key string) (bool, error)
  • func (m *CacheMVCCDB) KeysByRange(table string, from string, to string, limit int) ([]string, error)
  • func (m *CacheMVCCDB) Put(table string, key string, value string) error
  • func (m *CacheMVCCDB) Size() (int64, error)
• type Commit
  • func NewCommit(cache mvcc.Cache, tag string) *Commit
  • func (c *Commit) ForkCache() mvcc.Cache
• type CommitManager
  • func NewCommitManager() *CommitManager
  • func (m *CommitManager) Add(c *Commit)
  • func (m *CommitManager) FreeBefore(c *Commit)
  • func (m *CommitManager) Get(t string) *Commit
  • func (m *CommitManager) Tags() []string
• type Item
• type MVCCDB
  • func NewMVCCDB(path string) (MVCCDB, error)

Constants

const (
	SEPARATOR = '/'
)

constant of mvccdb

Variables

var (
	ErrTableNotValid = fmt.Errorf("table name is not valid")
)

error of mvccdb

Types

type CacheMVCCDB

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

CacheMVCCDB is the mvcc db with cache

func NewCacheMVCCDB

func NewCacheMVCCDB(path string, cacheType mvcc.CacheType) (*CacheMVCCDB, error)

NewCacheMVCCDB returns new CacheMVCCDB

func (*CacheMVCCDB) Checkout

func (m *CacheMVCCDB) Checkout(t string) bool

Checkout will checkout the specify tag of mvccdb

func (*CacheMVCCDB) Close

func (m *CacheMVCCDB) Close() error

Close will close the mvccdb

func (*CacheMVCCDB) Commit

func (m *CacheMVCCDB) Commit(t string)

Commit will commit the stage and add tag to current state of mvccdb

func (*CacheMVCCDB) CurrentTag

func (m *CacheMVCCDB) CurrentTag() string

CurrentTag will return current tag of mvccdb

func (*CacheMVCCDB) Del

func (m *CacheMVCCDB) Del(table string, key string) error

Del will remove the specify key in the table

func (*CacheMVCCDB) Flush

func (m *CacheMVCCDB) Flush(t string) error

Flush will persist the current state of mvccdb

func (*CacheMVCCDB) Fork

func (m *CacheMVCCDB) Fork() MVCCDB

Fork will fork the mvcdb thread safe between all forks of the mvccdb

func (*CacheMVCCDB) Get

func (m *CacheMVCCDB) Get(table string, key string) (string, error)

Get returns the value of specify key and table

func (*CacheMVCCDB) Has

func (m *CacheMVCCDB) Has(table string, key string) (bool, error)

Has returns whether the specified key exists in the table

func (*CacheMVCCDB) KeysByRange

func (m *CacheMVCCDB) KeysByRange(table string, from string, to string, limit int) ([]string, error)

Keys returns the list of key prefixed with prefix in the table

func (*CacheMVCCDB) Put

func (m *CacheMVCCDB) Put(table string, key string, value string) error

Put will insert the key-value pair into the table

func (*CacheMVCCDB) Size

func (m *CacheMVCCDB) Size() (int64, error)

Size returns the size of mvccdb

type Commit

type Commit struct {
	mvcc.Cache
	Tag string
}

Commit is the cache of specify tag

func NewCommit

func NewCommit(cache mvcc.Cache, tag string) *Commit

NewCommit returns new commit

func (*Commit) ForkCache

func (c *Commit) ForkCache() mvcc.Cache

ForkCache will fork a cache from the commit

type CommitManager

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

CommitManager is the commit manager, support get, delete etc.

func NewCommitManager

func NewCommitManager() *CommitManager

NewCommitManager returns new commit manager

func (*CommitManager) Add

func (m *CommitManager) Add(c *Commit)

Add will add a commit with tag

func (*CommitManager) FreeBefore

func (m *CommitManager) FreeBefore(c *Commit)

FreeBefore will free the momery of commits before the commit

func (*CommitManager) Get

func (m *CommitManager) Get(t string) *Commit

Get will get a commit by tag

func (*CommitManager) Tags

func (m *CommitManager) Tags() []string

Tags will return last 10 tags

type Item

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

Item is the value of cache

type MVCCDB

type MVCCDB interface {
	Get(table string, key string) (string, error)
	Put(table string, key string, value string) error
	Del(table string, key string) error
	Has(table string, key string) (bool, error)
	KeysByRange(table string, from string, to string, limit int) ([]string, error)
	Checkout(t string) bool
	Commit(t string)
	CurrentTag() string
	Fork() MVCCDB
	Flush(t string) error
	Size() (int64, error)
	Close() error
}

MVCCDB is the interface of mvccdb

func NewMVCCDB

func NewMVCCDB(path string) (MVCCDB, error)

NewMVCCDB return new mvccdb