database

Documentation

Index

• type IKVDatabase
  • func NewKeyValueDB(pSett ISettings) (IKVDatabase, error)
  • func NewVoidKeyValueDB(pSett ISettings) IKVDatabase
• type ISettings
  • func NewSettings(pSett *SSettings) ISettings
• type IWrapperDB
  • func NewWrapperDB() IWrapperDB
• type SSettings

Types

type IKVDatabase

type IKVDatabase interface {
	types.ICloser

	Push(message.IMessage) error
	Load(string) (message.IMessage, error)
	Hashes() ([]string, error)

	Settings() ISettings
	GetOriginal() database.IKVDatabase
}

func NewKeyValueDB

func NewKeyValueDB(pSett ISettings) (IKVDatabase, error)

func NewVoidKeyValueDB

func NewVoidKeyValueDB(pSett ISettings) IKVDatabase

type ISettings

type ISettings interface {
	GetPath() string
	GetCapacity() uint64
	GetMessageSizeBytes() uint64
	GetWorkSizeBits() uint64
}

func NewSettings

func NewSettings(pSett *SSettings) ISettings

type IWrapperDB

type IWrapperDB interface {
	types.ICloser

	Get() IKVDatabase
	Set(IKVDatabase) IWrapperDB
}

func NewWrapperDB

func NewWrapperDB() IWrapperDB

type SSettings

type SSettings sSettings