network

Documentation

Index

• Variables
• func RequestHandler(pHandle IHandlerF) anonymity.IHandlerF
• type IHandlerF
• type IHiddenLakeNode
  • func NewHiddenLakeNode(pSettings ISettings, pPrivKey asymmetric.IPrivKey, ...) IHiddenLakeNode
  • func NewRawHiddenLakeNode(pOriginNode anonymity.INode, pConnsGetter func() []string, pHandlerF IHandlerF) IHiddenLakeNode
• type ISettings
  • func NewSettings(pSett *SSettings) ISettings
  • func NewSettingsByNetworkKey(pNetworkKey string, pSubSettings *SSubSettings) ISettings
• type ISubSettings
• type SHandlerError
  • func (err *SHandlerError) Error() string
• type SSettings
• type SSubSettings

Variables

var (
	ErrBadRequest          = &SHandlerError{"bad request"}
	ErrBuildRequest        = &SHandlerError{"build request"}
	ErrUndefinedService    = &SHandlerError{"undefined service"}
	ErrLoadRequest         = &SHandlerError{"load request"}
	ErrInvalidResponseMode = &SHandlerError{"invalid response mode"}
)

Functions

func RequestHandler

func RequestHandler(pHandle IHandlerF) anonymity.IHandlerF

Types

type IHandlerF

type IHandlerF func(
	context.Context,
	asymmetric.IPubKey,
	request.IRequest,
) (response.IResponse, error)

type IHiddenLakeNode

type IHiddenLakeNode interface {
	types.IRunner
	GetOrigNode() 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 IHandlerF,
) IHiddenLakeNode

func NewRawHiddenLakeNode

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

type ISettings

type ISettings interface {
	ISubSettings
	GetMessageSettings() gopeer_message.ISettings
	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 SHandlerError

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

func (*SHandlerError) Error

func (err *SHandlerError) Error() string

type SSettings

type SSettings sSettings

type SSubSettings

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