Versions in this module Expand all Collapse all v0 v0.5.0 Mar 23, 2021 Changes in this version + var ErrEmptyPrivKey = errors.New("empty private key hex string") + var ErrHandshakeTimeout = errors.New("handshake timeout") + var ErrInvalidPrivKey = errors.New("invalid private key hex string") + var ErrInvalidPubKeyLength = errors.New("invalid public key format: Length") + var ErrListenerClosed = errors.New("listener closed") + var ErrUint32Overflow = errors.New("invalid uint32 from hex conversion. Number overflows uint32") + func NewNodeAddr(address string) (interfaces.NodeAddr, error) + func NewP2PTransport(logger *logrus.Logger, cid types.ChainIdentifier, privateKeyHex string, ...) (interfaces.P2PTransport, error) + func NewTransportPrivateKey() (string, error) + func RandomNodeAddr() (interfaces.NodeAddr, error) + type ErrInvalidNetworkAddress struct + func (eina *ErrInvalidNetworkAddress) Error() string + type NodeAddr struct + func (pad *NodeAddr) ChainID() types.ChainIdentifier + func (pad *NodeAddr) ChainIdentifier() types.ChainIdentifier + func (pad *NodeAddr) Host() string + func (pad *NodeAddr) Identity() string + func (pad *NodeAddr) Network() string + func (pad *NodeAddr) P2PAddr() string + func (pad *NodeAddr) Port() int + func (pad *NodeAddr) String() string + func (pad *NodeAddr) Unmarshal(address string) (interfaces.NodeAddr, error) + type P2PConn struct + func (pc *P2PConn) ChainID() types.ChainIdentifier + func (pc *P2PConn) Close() error + func (pc *P2PConn) CloseChan() <-chan struct{} + func (pc *P2PConn) Identity() string + func (pc *P2PConn) Initiator() types.P2PInitiator + func (pc *P2PConn) NodeAddr() interfaces.NodeAddr + func (pc *P2PConn) ProtoVersion() types.ProtoVersion + func (pc *P2PConn) Protocol() types.Protocol + func (pc *P2PConn) RemoteAddr() net.Addr + func (pc *P2PConn) RemoteP2PAddr() interfaces.NodeAddr + type P2PMux struct + func (pmx *P2PMux) HandleConnection(ctx context.Context, conn interfaces.P2PConn) (interfaces.P2PMuxConn, error) + type P2PMuxConn struct + func (pmc *P2PMuxConn) ClientConn() interfaces.P2PConn + func (pmc *P2PMuxConn) Close() error + func (pmc *P2PMuxConn) CloseChan() <-chan struct{} + func (pmc *P2PMuxConn) Initiator() types.P2PInitiator + func (pmc *P2PMuxConn) NodeAddr() interfaces.NodeAddr + func (pmc *P2PMuxConn) ServerConn() interfaces.P2PConn + type P2PTransport struct + func (pt *P2PTransport) Accept() (interfaces.P2PConn, error) + func (pt *P2PTransport) Close() error + func (pt *P2PTransport) Dial(addr interfaces.NodeAddr, protocol types.Protocol) (interfaces.P2PConn, error) + func (pt *P2PTransport) NodeAddr() interfaces.NodeAddr