database

Documentation

Index

• type IKeyValueDB
  • func NewKeyValueDB(pPath string, pKey []byte) IKeyValueDB
• type IMessage
  • func LoadMessage(pMsgBytes []byte) IMessage
  • func NewMessage(pIsIncoming bool, pMessage string, pHashUID []byte) IMessage
• type IRelation
  • func NewRelation(pIAm, pFriend asymmetric.IPubKey) IRelation
• type IWrapperDB
  • func NewWrapperDB() IWrapperDB

Types

type IKeyValueDB

type IKeyValueDB interface {
	types.ICloser

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

func NewKeyValueDB

func NewKeyValueDB(pPath string, pKey []byte) IKeyValueDB

type IMessage

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

func LoadMessage

func LoadMessage(pMsgBytes []byte) IMessage

func NewMessage

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

type IRelation

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

func NewRelation

func NewRelation(pIAm, pFriend asymmetric.IPubKey) IRelation

type IWrapperDB

type IWrapperDB interface {
	types.ICloser

	Get() IKeyValueDB
	Set(IKeyValueDB) IWrapperDB
}

func NewWrapperDB

func NewWrapperDB() IWrapperDB