p2p

Documentation

Index

• Variables
• func ConstructMessage(content []byte) []byte
• func StringsToAddrs(addrStrings []string) (maddrs []ma.Multiaddr, err error)
• type AddrList
  • func (al *AddrList) Set(value string) error
  • func (al *AddrList) String() string
• type Host
  • func NewHost(self *Peer, key libp2p_crypto.PrivKey) (Host, error)
• type HostV2
  • func (host *HostV2) AddPeer(p *Peer) error
  • func (host *HostV2) AllTopics() []*libp2p_pubsub.Topic
  • func (host *HostV2) ConnectHostPeer(peer Peer) error
  • func (host *HostV2) GetID() libp2p_peer.ID
  • func (host *HostV2) GetP2PHost() libp2p_host.Host
  • func (host *HostV2) GetPeerCount() int
  • func (host *HostV2) GetSelfPeer() Peer
  • func (host *HostV2) Peerstore() libp2p_peerstore.Peerstore
  • func (host *HostV2) SendMessageToGroups(groups []nodeconfig.GroupID, msg []byte) (err error)
• type Peer
  • func (p Peer) String() string

Variables

var DefaultBootNodeAddrStrings = []string{
	"/ip4/127.0.0.1/tcp/19876/p2p/Qmc1V6W7BwX8Ugb42Ti8RnXF1rY5PF7nnZ6bKBryCgi6cv",
}

DefaultBootNodeAddrStrings is a list of Harmony bootnodes address. Used to find other peers in the network.

Functions

func ConstructMessage

func ConstructMessage(content []byte) []byte

ConstructMessage constructs the p2p message as [messageType, contentSize, content]

func StringsToAddrs

func StringsToAddrs(addrStrings []string) (maddrs []ma.Multiaddr, err error)

StringsToAddrs convert a list of strings to a list of multiaddresses

Types

type AddrList

type AddrList []ma.Multiaddr

AddrList is a list of multiaddress

var BootNodes AddrList

BootNodes is a list of boot nodes. It is populated either from default or from user CLI input.

func (*AddrList) Set

func (al *AddrList) Set(value string) error

Set is a function to set the value of AddrList based on a string

func (*AddrList) String

func (al *AddrList) String() string

String is a function to print a string representation of the AddrList

type Host

type Host interface {
	GetSelfPeer() Peer
	AddPeer(*Peer) error
	GetID() libp2p_peer.ID
	GetP2PHost() libp2p_host.Host
	GetPeerCount() int
	ConnectHostPeer(Peer) error
	// SendMessageToGroups sends a message to one or more multicast groups.
	SendMessageToGroups(groups []nodeconfig.GroupID, msg []byte) error
	AllTopics() []*libp2p_pubsub.Topic
}

Host is the client + server in p2p network.

func NewHost

func NewHost(self *Peer, key libp2p_crypto.PrivKey) (Host, error)

NewHost ..

type HostV2

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

HostV2 is the version 2 p2p host

func (*HostV2) AddPeer

func (host *HostV2) AddPeer(p *Peer) error

AddPeer add p2p.Peer into Peerstore

func (*HostV2) AllTopics

func (host *HostV2) AllTopics() []*libp2p_pubsub.Topic

AllTopics ..

func (*HostV2) ConnectHostPeer

func (host *HostV2) ConnectHostPeer(peer Peer) error

ConnectHostPeer connects to peer host

func (*HostV2) GetID

func (host *HostV2) GetID() libp2p_peer.ID

GetID returns ID.Pretty

func (*HostV2) GetP2PHost

func (host *HostV2) GetP2PHost() libp2p_host.Host

GetP2PHost returns the p2p.Host

func (*HostV2) GetPeerCount

func (host *HostV2) GetPeerCount() int

GetPeerCount ...

func (*HostV2) GetSelfPeer

func (host *HostV2) GetSelfPeer() Peer

GetSelfPeer gets self peer

func (*HostV2) Peerstore

func (host *HostV2) Peerstore() libp2p_peerstore.Peerstore

Peerstore returns the peer store

func (*HostV2) SendMessageToGroups

func (host *HostV2) SendMessageToGroups(groups []nodeconfig.GroupID, msg []byte) (err error)

SendMessageToGroups sends a message to one or more multicast groups. It returns a nil error if and only if it has succeeded to schedule the given message for sending.

type Peer

type Peer struct {
	IP              string         // IP address of the peer
	Port            string         // Port number of the peer
	ConsensusPubKey *bls.PublicKey // Public key of the peer, used for consensus signing
	Addrs           []ma.Multiaddr // MultiAddress of the peer
	PeerID          libp2p_peer.ID // PeerID, the pubkey for communication
}

Peer is the object for a p2p peer (node)

func (Peer) String

func (p Peer) String() string