p2p

Jul 21, 2025

Changes in this version

+ type Logger interface

+ Debugf func(format string, args ...interface{})

+ Errorf func(format string, args ...interface{})

+ Fatalf func(format string, args ...interface{})

+ Infof func(format string, args ...interface{})

+ Warnf func(format string, args ...interface{})

Jul 21, 2025

Changes in this version

type Node

+ func NewNode(ctx context.Context, logger logrus.FieldLogger, config Config) (*Node, error)

Jul 21, 2025

Changes in this version

+ type BestBlockRequestMessage struct

+ PeerID string

+ type BlockMessage struct

+ DataHubURL string

+ Hash string

+ Height uint32

+ PeerID string

+ type Config struct

+ Advertise bool

+ AdvertiseAddresses []string

+ BootstrapAddresses []string

+ DHTProtocolID string

+ ListenAddresses []string

+ OptimiseRetries bool

+ Port int

+ PrivateKey string

+ ProcessName string

+ SharedKey string

+ StaticPeers []string

+ UsePrivateDHT bool

+ type Handler func(ctx context.Context, msg []byte, from string)

+ type HandshakeMessage struct

+ BestHash string

+ BestHeight uint32

+ DataHubURL string

+ PeerID string

+ Services uint64

+ Type MessageType

+ UserAgent string

+ type MessageType string

+ const Verack

+ const Version

+ type MiningOnMessage struct

+ DataHubURL string

+ Hash string

+ Height uint32

+ Miner string

+ PeerID string

+ PreviousHash string

+ SizeInBytes uint64

+ TxCount uint64

+ type Node struct

+ func NewP2PNode(ctx context.Context, logger *logrus.Logger, config Config) (*Node, error)

+ func (s *Node) BytesReceived() uint64

+ func (s *Node) BytesSent() uint64

+ func (s *Node) ConnectedPeers() []PeerInfo

+ func (s *Node) CurrentlyConnectedPeers() []PeerInfo

+ func (s *Node) DisconnectPeer(_ context.Context, peerID peer.ID) error

+ func (s *Node) GetPeerIPs(peerID peer.ID) []string

+ func (s *Node) GetProcessName() string

+ func (s *Node) GetTopic(topicName string) *pubsub.Topic

+ func (s *Node) HostID() peer.ID

+ func (s *Node) LastRecv() time.Time

+ func (s *Node) LastSend() time.Time

+ func (s *Node) Publish(ctx context.Context, topicName string, msgBytes []byte) error

+ func (s *Node) SendToPeer(ctx context.Context, peerID peer.ID, msg []byte) (err error)

+ func (s *Node) SetPeerConnectedCallback(callback func(context.Context, peer.ID))

+ func (s *Node) SetTopicHandler(ctx context.Context, topicName string, handler Handler) error

+ func (s *Node) Start(ctx context.Context, streamHandler func(network.Stream), topicNames ...string) error

+ func (s *Node) Stop(_ context.Context) error

+ func (s *Node) UpdateBytesReceived(bytesCount uint64)

+ func (s *Node) UpdateLastReceived()

+ func (s *Node) UpdatePeerHeight(peerID peer.ID, height int32)

+ type NodeI interface

+ BytesReceived func() uint64

+ BytesSent func() uint64

+ ConnectedPeers func() []PeerInfo

+ CurrentlyConnectedPeers func() []PeerInfo

+ DisconnectPeer func(ctx context.Context, peerID peer.ID) error

+ GetPeerIPs func(peerID peer.ID) []string

+ GetProcessName func() string

+ GetTopic func(topicName string) *pubsub.Topic

+ HostID func() peer.ID

+ LastRecv func() time.Time

+ LastSend func() time.Time

+ Publish func(ctx context.Context, topicName string, msgBytes []byte) error

+ SendToPeer func(ctx context.Context, pid peer.ID, msg []byte) error

+ SetPeerConnectedCallback func(callback func(context.Context, peer.ID))

+ SetTopicHandler func(ctx context.Context, topicName string, handler Handler) error

+ Start func(ctx context.Context, streamHandler func(network.Stream), topicNames ...string) error

+ Stop func(ctx context.Context) error

+ UpdateBytesReceived func(bytesCount uint64)

+ UpdateLastReceived func()

+ UpdatePeerHeight func(peerID peer.ID, height int32)

+ type PeerInfo struct

+ Addrs []multiaddr.Multiaddr

+ ConnTime *time.Time

+ CurrentHeight int32

+ ID peer.ID

+ type RejectedTxMessage struct

+ PeerID string

+ Reason string

+ TxID string

+ type SubtreeMessage struct

+ DataHubURL string

+ Hash string

+ PeerID string