database

Documentation

Index

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

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(pPath string, pKey []byte) (IKVDatabase, error)

type IMessage

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

func LoadMessage

func LoadMessage(pMsgBytes []byte) IMessage

func NewMessage

func NewMessage(pIsIncoming bool, pMessage []byte, 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() IKVDatabase
	Set(IKVDatabase) IWrapperDB
}

func NewWrapperDB

func NewWrapperDB() IWrapperDB