database

Documentation

Index

• Constants
• type CacheTimeProvider
  • func NewCacheTimeProvider(forceCacheTime time.Duration) *CacheTimeProvider
  • func (m *CacheTimeProvider) CacheTime(duration time.Duration) objectstorage.Option
• type DB
  • func NewDB(dirname string) (DB, error)
  • func NewMemDB() (DB, error)

Constants

const (
	// PrefixPeer defines the prefix of the peer db.
	PrefixPeer byte = iota

	// PrefixHealth defines the prefix of the health db.
	PrefixHealth

	// PrefixTangle defines the storage prefix for the tangle.
	PrefixTangle

	// PrefixMarkers defines the storage prefix for the markers used to optimize structural checks in the tangle.
	PrefixMarkers

	// PrefixLedgerState defines the storage prefix for the ledgerstate package.
	PrefixLedgerState

	// PrefixMana defines the storage prefix for the mana package.
	PrefixMana

	// PrefixFCOB defines the storage prefix for the fcob consensus package.
	PrefixFCOB

	// PrefixEpochs defines the storage prefix for the epochs package.
	PrefixEpochs
)

Types

type CacheTimeProvider

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

CacheTimeProvider should be always used to get the CacheTime option for storage It wraps around objectstorage.CacheTime() function and may override the input duration

func NewCacheTimeProvider

func NewCacheTimeProvider(forceCacheTime time.Duration) *CacheTimeProvider

NewCacheTimeProvider creates an instance that forces cache time to always be a certain value. If the given value is negative, hard coded defaults will be used

func (*CacheTimeProvider) CacheTime

func (m *CacheTimeProvider) CacheTime(duration time.Duration) objectstorage.Option

CacheTime returns a CacheTime option. Duration may be overridden if CacheTimeProvider parameter is a non-negative integer

type DB

type DB interface {
	// NewStore creates a new KVStore backed by the database.
	NewStore() kvstore.KVStore
	// Close closes a DB.
	Close() error

	// RequiresGC returns whether the database requires a call of GC() to clean deleted items.
	RequiresGC() bool
	// GC runs the garbage collection to clean deleted database items.
	GC() error
}

DB represents a database abstraction.

func NewDB

func NewDB(dirname string) (DB, error)

NewDB returns a new persisting DB object.

func NewMemDB

func NewMemDB() (DB, error)

NewMemDB returns a new in-memory (not persisted) DB object.