anonymity

Documentation

Index

• 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

Types

type IHandlerF

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

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(asymmetric.IPubKey, adapters.IPayload) error
	FetchPayload(asymmetric.IPubKey, adapters.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
	GetNetworkMask() uint64
	GetRetryEnqueue() uint64
	GetFetchTimeWait() time.Duration
}

func NewSettings

func NewSettings(pSett *SSettings) ISettings

type IWrapperDB

type IWrapperDB interface {
	types.ICloser

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

func NewWrapperDB

func NewWrapperDB() IWrapperDB

type SSettings

type SSettings sSettings