You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
41 lines
1.1 KiB
41 lines
1.1 KiB
package p2p
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"io"
|
|
"net"
|
|
|
|
"github.com/harmony-one/bls/ffi/go/bls"
|
|
libp2p_peer "github.com/libp2p/go-libp2p-peer"
|
|
ma "github.com/multiformats/go-multiaddr"
|
|
)
|
|
|
|
// StreamHandler handles incoming p2p message.
|
|
type StreamHandler func(Stream)
|
|
|
|
// Peer is the object for a p2p peer (node)
|
|
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
|
|
}
|
|
|
|
func (p Peer) String() string {
|
|
BLSPubKey := "nil"
|
|
if p.ConsensusPubKey != nil {
|
|
BLSPubKey = p.ConsensusPubKey.SerializeToHexStr()
|
|
}
|
|
return fmt.Sprintf("BLSPubKey:%s-%s/%s[%d]", BLSPubKey, net.JoinHostPort(p.IP, p.Port), p.PeerID, len(p.Addrs))
|
|
}
|
|
|
|
// GroupReceiver is a multicast group message receiver interface.
|
|
type GroupReceiver interface {
|
|
// Close closes this receiver.
|
|
io.Closer
|
|
|
|
// Receive a message.
|
|
Receive(ctx context.Context) (msg []byte, sender libp2p_peer.ID, err error)
|
|
}
|
|
|