database

Documentation

Index

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

Types

type IKVDatabase

type IKVDatabase interface {
	types.ICloser
	PushRequestID([]byte) (bool, error)

	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
	GetPseudonym() string
	GetTimestamp() string
	GetMessage() []byte
	ToBytes() []byte
}

func LoadMessage

func LoadMessage(pMsgBytes []byte) IMessage

func NewMessage

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

type IRelation

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

func NewRelation

func NewRelation(pIAm, pFriend asymmetric.IPubKey) IRelation