network

Documentation

Index

• Variables
• type IHiddenLakeNode
  • func NewHiddenLakeNode(pSettings ISettings, pPrivKey asymmetric.IPrivKey, ...) IHiddenLakeNode
  • func NewRawHiddenLakeNode(pAnonymityNode anonymity.INode) IHiddenLakeNode
• type ISettings
  • func NewSettings(pSett *SSettings) ISettings
  • func NewSettingsByNetworkKey(pNetworkKey string, pSubSettings *SSubSettings) ISettings
• type ISubSettings
• type SAppError
  • func (err *SAppError) Error() string
• type SSettings
• type SSubSettings

Variables

var (
	ErrSendRequest      = &SAppError{"send request"}
	ErrFetchRequest     = &SAppError{"fetch request"}
	ErrLoadResponse     = &SAppError{"load response"}
	ErrAdapterNotRunner = &SAppError{"adapter not runner"}
	ErrRunning          = &SAppError{"node running"}
)

Types

type IHiddenLakeNode

type IHiddenLakeNode interface {
	types.IRunner
	GetAnonymityNode() 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,
	pRunnerAdapter adapters.IRunnerAdapter,
	pHandlerF handler.IHandlerF,
) IHiddenLakeNode

func NewRawHiddenLakeNode

func NewRawHiddenLakeNode(pAnonymityNode anonymity.INode) IHiddenLakeNode

type ISettings

type ISettings interface {
	ISubSettings
	GetAdapterSettings() adapters.ISettings
	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
	GetServiceName() string
}

type SAppError

type SAppError struct {
	// contains filtered or unexported fields
}

func (*SAppError) Error

func (err *SAppError) Error() string

type SSettings

type SSettings sSettings

type SSubSettings

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