common

Documentation

Index

• Variables
• func FastSum256(data []byte) [32]byte
• func FastSum64(data []byte) uint64
• type Config
• type Error
  • func NewError(code ErrorCode, e error) *Error
  • func NewErrorStr(code ErrorCode, e string) *Error
  • func NewSuccess() *Error
  • func (e *Error) Add(err string)
  • func (e *Error) AddError(err error)
  • func (e *Error) String() string
  • func (e *Error) ToError() error
• type ErrorCode
  • func (e ErrorCode) IsDAGConsensus() bool
  • func (e ErrorCode) IsStream() bool
  • func (e ErrorCode) IsSuccess() bool
  • func (e ErrorCode) String() string
• type QMultiaddr
  • func QMultiAddrFromString(address string) (*QMultiaddr, error)
  • func (qm *QMultiaddr) String() string

Variables

var (
	IngressConnectMeter = metrics.NewRegisteredMeter("p2p/serves/qng", nil)
	IngressTrafficMeter = metrics.NewRegisteredMeter(ingressMeterName, nil)
	EgressConnectMeter  = metrics.NewRegisteredMeter("p2p/dials/qng", nil)
	EgressTrafficMeter  = metrics.NewRegisteredMeter(egressMeterName, nil)
	ActivePeerGauge     = metrics.NewRegisteredGauge("p2p/peers/qng", nil)
)

Functions

func FastSum256

func FastSum256(data []byte) [32]byte

FastSum256 returns a hash sum of the input data using highwayhash. This method is not secure, but may be used as a quick identifier for objects where collisions are acceptable.

func FastSum64

func FastSum64(data []byte) uint64

FastSum64 returns a hash sum of the input data using highwayhash. This method is not secure, but may be used as a quick identifier for objects where collisions are acceptable.

Types

type Config

type Config struct {
	NoDiscovery          bool
	EnableUPnP           bool
	StaticPeers          []string
	BootstrapNodeAddr    []string
	Discv5BootStrapAddr  []string
	DataDir              string
	MaxPeers             uint
	MaxInbound           int
	MetaDataDir          string
	ReadWritePermissions os.FileMode
	AllowListCIDR        string
	DenyListCIDR         []string
	TCPPort              uint
	UDPPort              uint
	EnableNoise          bool
	RelayNodeAddr        string
	LocalIP              string
	HostAddress          string
	HostDNS              string
	PrivateKey           string
	Encoding             string
	// ProtocolVersion specifies the maximum protocol version to use and
	// advertise.
	ProtocolVersion uint32
	Services        protocol.ServiceFlag
	UserAgent       string
	// DisableRelayTx specifies if the remote peer should be informed to
	// not send inv messages for transactions.
	DisableRelayTx bool
	MaxOrphanTxs   int
	Params         *params.Params
	Banning        bool // Open or not ban module
	DisableListen  bool
	LANPeers       []string
	IsCircuit      bool
	Consistency    bool
}

Config for the p2p service. to initialize the p2p service.

type Error

type Error struct {
	Code  ErrorCode
	Error error
}

func NewError

func NewError(code ErrorCode, e error) *Error

func NewErrorStr

func NewErrorStr(code ErrorCode, e string) *Error

func NewSuccess

func NewSuccess() *Error

func (*Error) Add

func (e *Error) Add(err string)

func (*Error) AddError

func (e *Error) AddError(err error)

func (*Error) String

func (e *Error) String() string

func (*Error) ToError

func (e *Error) ToError() error

type ErrorCode

type ErrorCode int

ErrorCode identifies a kind of error.

const (
	// There are no errors by default
	ErrNone ErrorCode = iota

	// p2p stream write error
	ErrStreamWrite

	// p2p stream read error
	ErrStreamRead

	// p2p stream base error
	ErrStreamBase

	// p2p peer unknown error
	ErrPeerUnknown

	// p2p peer bad error
	ErrBadPeer

	// p2p DAG consensus error
	ErrDAGConsensus

	// p2p message error
	ErrMessage

	// Generic rule error
	ErrGeneric

	// peer connect frequent
	ErrConnectFrequent

	// Sequence error
	ErrSequence

	// revalidate error
	ErrRevalidate

	// libp2p connect
	ErrLibp2pConnect
)

func (ErrorCode) IsDAGConsensus

func (e ErrorCode) IsDAGConsensus() bool

func (ErrorCode) IsStream

func (e ErrorCode) IsStream() bool

func (ErrorCode) IsSuccess

func (e ErrorCode) IsSuccess() bool

func (ErrorCode) String

func (e ErrorCode) String() string

type QMultiaddr

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

func QMultiAddrFromString

func QMultiAddrFromString(address string) (*QMultiaddr, error)

func (*QMultiaddr) String

func (qm *QMultiaddr) String() string