database

Documentation

Index

• Variables
• type IKVDatabase
  • func NewKeyValueDB(pSettings database.ISettings) (IKVDatabase, error)
• type IMessage
  • func LoadMessage(pMsgBytes []byte) IMessage
  • func NewMessage(pIsIncoming bool, pMessage []byte) IMessage
• type IRelation
  • func NewRelation(pIAm, pFriend asymmetric.IPubKey) IRelation
• type SDatabaseError
  • func (err *SDatabaseError) Error() string

Variables

var (
	ErrLoadMessage    = &SDatabaseError{"load message"}
	ErrGetMessage     = &SDatabaseError{"get message"}
	ErrSetMessage     = &SDatabaseError{"set message"}
	ErrSetSizeMessage = &SDatabaseError{"set size message"}
	ErrCloseDB        = &SDatabaseError{"close db"}
	ErrEndGtSize      = &SDatabaseError{"end > size"}
	ErrStartGtEnd     = &SDatabaseError{"start > end"}
	ErrCreateDB       = &SDatabaseError{"create db"}
)

Types

type IKVDatabase

type IKVDatabase interface {
	types.ICloser

	Size(IRelation) uint64
	Push(IRelation, IMessage) error
	Load(IRelation, uint64, uint64) ([]IMessage, error)
}

func NewKeyValueDB

func NewKeyValueDB(pSettings database.ISettings) (IKVDatabase, error)

type IMessage

type IMessage interface {
	IsIncoming() bool
	GetTimestamp() string
	GetMessage() []byte
	ToBytes() []byte
}

func LoadMessage

func LoadMessage(pMsgBytes []byte) IMessage

func NewMessage

func NewMessage(pIsIncoming bool, pMessage []byte) IMessage

type IRelation

type IRelation interface {
	IAm() asymmetric.IPubKey
	Friend() asymmetric.IPubKey
}

func NewRelation

func NewRelation(pIAm, pFriend asymmetric.IPubKey) IRelation

type SDatabaseError

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

func (*SDatabaseError) Error

func (err *SDatabaseError) Error() string