Documentation
¶
Index ¶
Constants ¶
View Source
const MinPeersForSyncStart = 3
Variables ¶
View Source
var ( // ErrorBlockAlreadyKnown returns when received a block already known ErrorBlockAlreadyKnown = errors.New("block already known") // ErrorBlockParentUnknown returns when received a block with an unknown parent ErrorBlockParentUnknown = errors.New("unknown block parent") )
Functions ¶
func NewDiscover ¶
NewDiscover creates a new discovery service.
func NewSyncronizer ¶
func NewSyncronizer(host HostNode, chain chain.Blockchain) (*synchronizer, error)
NewSyncronizerl constructs a new sync protocol with a given host and chain.
Types ¶
type HostNode ¶
type HostNode interface {
Syncing() bool
GetHost() host.Host
GetNetMagic() uint32
DisconnectPeer(p peer.ID) error
GetPeerInfos() []peer.AddrInfo
GetPeerDirection(id peer.ID) network.Direction
GetPeerInfo(id peer.ID) *peer.AddrInfo
GetPeersStats() []*peerInfo
RegisterHandler(message string, handler MessageHandler) error
RegisterTopicHandler(message string, handler MessageHandler) error
HandleStream(s network.Stream)
SendMessage(id peer.ID, msg p2p.Message) error
Broadcast(msg p2p.Message) error
}
HostNode is an interface for hostNode
func NewHostNode ¶
func NewHostNode(blockchain chain.Blockchain) (HostNode, error)
NewHostNode creates a host node
Source Files
Click to show internal directories.
Click to hide internal directories.