network

Documentation

Index

• type IHiddenLakeNode
  • func NewHiddenLakeNode(pSettings ISettings, pPrivKey asymmetric.IPrivKey, ...) IHiddenLakeNode
  • func NewRawHiddenLakeNode(pOriginNode anonymity.INode, pConnsGetter func() []string, ...) IHiddenLakeNode
• type ISettings
  • func NewSettings(pSett *SSettings) ISettings
  • func NewSettingsByNetworkKey(pNetworkKey string, pSubSettings *SSubSettings) ISettings
• type ISubSettings
• type SSettings
• type SSubSettings

Types

type IHiddenLakeNode

type IHiddenLakeNode interface {
	types.IRunner
	GetOriginNode() anonymity.INode

	SendRequest(context.Context, asymmetric.IPubKey, request.IRequest) error
	FetchRequest(context.Context, asymmetric.IPubKey, request.IRequest) (response.IResponse, error)
}

func NewHiddenLakeNode

func NewHiddenLakeNode(
	pSettings ISettings,
	pPrivKey asymmetric.IPrivKey,
	pKVDatabase database.IKVDatabase,
	pConnsGetter func() []string,
	pHandlerF handler.IHandlerF,
) IHiddenLakeNode

func NewRawHiddenLakeNode

func NewRawHiddenLakeNode(
	pOriginNode anonymity.INode,
	pConnsGetter func() []string,
	pHandlerF handler.IHandlerF,
) IHiddenLakeNode

type ISettings

type ISettings interface {
	ISubSettings
	GetNetworkKey() string
	GetWorkSizeBits() uint64
	GetMessageSizeBytes() uint64
	GetQueuePeriod() time.Duration
	GetFetchTimeout() time.Duration
}

func NewSettings

func NewSettings(pSett *SSettings) ISettings

func NewSettingsByNetworkKey

func NewSettingsByNetworkKey(pNetworkKey string, pSubSettings *SSubSettings) ISettings

type ISubSettings

type ISubSettings interface {
	GetLogger() gopeer_logger.ILogger
	GetParallel() uint64
	GetTCPAddress() string
	GetServiceName() string
}

type SSettings

type SSettings sSettings

type SSubSettings

type SSubSettings struct {
	FLogger      gopeer_logger.ILogger
	FParallel    uint64
	FTCPAddress  string
	FServiceName string
}