table

Documentation

Index

• func MigrateCaches(c interface{}, get func() interface{})
• func MigrateTables(s interface{}, db kvdb.Store)
• type IteratedReader
  • func (t *IteratedReader) Get(key []byte) ([]byte, error)
  • func (t *IteratedReader) Has(key []byte) (bool, error)
  • func (t *IteratedReader) NewIterator(itPrefix []byte, start []byte) kvdb.Iterator
• type Readonly
  • func NewReadonly(db kvdb.ReadonlyStore, prefix []byte) *Readonly
  • func (t *Readonly) GetSnapshot() (kvdb.Snapshot, error)
  • func (t *Readonly) NewReadonlyTable(prefix []byte) *Readonly
  • func (t *Readonly) Stat(property string) (string, error)
• type Table
  • func New(db kvdb.Store, prefix []byte) *Table
  • func (t *Table) Close() error
  • func (t *Table) Compact(start []byte, limit []byte) error
  • func (t *Table) Delete(key []byte) error
  • func (t *Table) Drop()
  • func (t *Table) NewBatch() kvdb.Batch
  • func (t *Table) NewTable(prefix []byte) *Table
  • func (t *Table) Put(key []byte, value []byte) error

Functions

func MigrateCaches

func MigrateCaches(c interface{}, get func() interface{})

MigrateCaches sets target fields to get() result.

func MigrateTables

func MigrateTables(s interface{}, db kvdb.Store)

MigrateTables sets target fields to database tables.

Types

type IteratedReader

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

func (*IteratedReader) Get

func (t *IteratedReader) Get(key []byte) ([]byte, error)

func (*IteratedReader) Has

func (t *IteratedReader) Has(key []byte) (bool, error)

func (*IteratedReader) NewIterator

func (t *IteratedReader) NewIterator(itPrefix []byte, start []byte) kvdb.Iterator

type Readonly

type Readonly struct {
	IteratedReader
	// contains filtered or unexported fields
}

Readonly table wraper of the underling DB, so all the table's data is stored with a prefix in underling DB.

func NewReadonly

func NewReadonly(db kvdb.ReadonlyStore, prefix []byte) *Readonly

func (*Readonly) GetSnapshot

func (t *Readonly) GetSnapshot() (kvdb.Snapshot, error)

func (*Readonly) NewReadonlyTable

func (t *Readonly) NewReadonlyTable(prefix []byte) *Readonly

func (*Readonly) Stat

func (t *Readonly) Stat(property string) (string, error)

type Table

type Table struct {
	Readonly
	// contains filtered or unexported fields
}

Table wraper the underling DB, so all the table's data is stored with a prefix in underling DB

func New

func New(db kvdb.Store, prefix []byte) *Table

func (*Table) Close

func (t *Table) Close() error

func (*Table) Compact

func (t *Table) Compact(start []byte, limit []byte) error

func (*Table) Delete

func (t *Table) Delete(key []byte) error

func (*Table) Drop

func (t *Table) Drop()

Drop the whole database.

func (*Table) NewBatch

func (t *Table) NewBatch() kvdb.Batch

func (*Table) NewTable

func (t *Table) NewTable(prefix []byte) *Table

func (*Table) Put

func (t *Table) Put(key []byte, value []byte) error