database

Documentation

Index

• Variables
• type IDBWrapper
  • func NewDBWrapper() IDBWrapper
• type IDatabase
  • func NewDatabase(pSett ISettings) (IDatabase, error)
  • func NewInMemoryDatabase(pSett ISettings) (IDatabase, error)
• type ISettings
  • func NewSettings(pSett *SSettings) ISettings
• type SSettings

Variables

var (
	ErrMessageIsExist    = errors.New("message is exist")
	ErrMessageIsNotExist = errors.New("message is not exist")
)

Types

type IDBWrapper

type IDBWrapper interface {
	types.ICloser

	Get() IDatabase
	Set(IDatabase) IDBWrapper
}

func NewDBWrapper

func NewDBWrapper() IDBWrapper

type IDatabase

type IDatabase interface {
	types.ICloser

	Push(net_message.IMessage) error
	Load([]byte) (net_message.IMessage, error)
	Hash(uint64) ([]byte, error)
	Pointer() uint64

	Settings() ISettings
}

func NewDatabase

func NewDatabase(pSett ISettings) (IDatabase, error)

func NewInMemoryDatabase

func NewInMemoryDatabase(pSett ISettings) (IDatabase, error)

type ISettings

type ISettings interface {
	net_message.ISettings

	GetPath() string
	GetMessagesCapacity() uint64
}

func NewSettings

func NewSettings(pSett *SSettings) ISettings

type SSettings

type SSettings sSettings