anonymity

Documentation

Index

• func NewPayload(pHead uint32, pBody []byte) payload.IPayload
• type IFormatType
• type IHandlerF
• type INode
  • func NewNode(pSett ISettings, pLogger logger.ILogger, pWrapperDB IWrapperDB, ...) INode
• type ISettings
  • func NewSettings(pSett *SSettings) ISettings
• type IWrapperDB
  • func NewWrapperDB() IWrapperDB
• type SSettings

Functions

func NewPayload

func NewPayload(pHead uint32, pBody []byte) payload.IPayload

Types

type IFormatType

type IFormatType byte

const (
	CIsRequest  IFormatType = '>'
	CIsResponse IFormatType = '<'
)

type IHandlerF

type IHandlerF func(INode, asymmetric.IPubKey, []byte, []byte) []byte

type INode

type INode interface {
	types.ICommand

	GetSettings() ISettings
	GetWrapperDB() IWrapperDB
	GetNetworkNode() network.INode
	GetMessageQueue() queue.IMessageQueue
	GetListPubKeys() asymmetric.IListPubKeys
	GetLogger() logger.ILogger

	HandleFunc(uint32, IHandlerF) INode
	HandleMessage(message.IMessage) // in runtime

	BroadcastPayload(IFormatType, asymmetric.IPubKey, payload.IPayload) error
	FetchPayload(asymmetric.IPubKey, payload.IPayload) ([]byte, error)
}

func NewNode

func NewNode(
	pSett ISettings,
	pLogger logger.ILogger,
	pWrapperDB IWrapperDB,
	pNetwork network.INode,
	pQueue queue.IMessageQueue,
	pFriends asymmetric.IListPubKeys,
) INode

type ISettings

type ISettings interface {
	GetServiceName() string
	GetTimeWait() time.Duration
	GetNetworkMask() uint64
	GetRetryEnqueue() uint64
}

func NewSettings

func NewSettings(pSett *SSettings) ISettings

type IWrapperDB

type IWrapperDB interface {
	types.ICloser

	Get() database.IKeyValueDB
	Set(database.IKeyValueDB) IWrapperDB
}

func NewWrapperDB

func NewWrapperDB() IWrapperDB

type SSettings

type SSettings sSettings