database

Documentation

Index

• Variables
• type IDatabase
  • func NewDatabase(pSett ISettings) (IDatabase, error)
  • func NewInMemoryDatabase(pSett ISettings) (IDatabase, error)
• type ISettings
  • func NewSettings(pSett *SSettings) ISettings
• type SDatabaseError
  • func (err *SDatabaseError) Error() string
• type SSettings

Variables

var (
	ErrMessageIsExist     = &SDatabaseError{"message is exist"}
	ErrMessageIsNotExist  = &SDatabaseError{"message is not exist"}
	ErrGtMessagesCapacity = &SDatabaseError{"gt message capacity"}
	ErrInvalidKeySize     = &SDatabaseError{"invalid key size"}
	ErrLoadMessage        = &SDatabaseError{"load message"}
	ErrCloseDB            = &SDatabaseError{"close db"}
	ErrSetPointer         = &SDatabaseError{"set pointer"}
	ErrIncrementPointer   = &SDatabaseError{"increment pointer"}
	ErrWriteMessage       = &SDatabaseError{"write message"}
	ErrRewriteKeyHash     = &SDatabaseError{"rewrite key hash"}
	ErrDeleteOldKey       = &SDatabaseError{"delete old key"}
	ErrCreateDB           = &SDatabaseError{"create db"}
)

Types

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 SDatabaseError

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

func (*SDatabaseError) Error

func (err *SDatabaseError) Error() string

type SSettings

type SSettings sSettings