dht_node

Documentation

Index

• type DhtNode
  • func New(nodeAddr *net.UDPAddr, torrentInfoHash [20]byte, startingNodes []dht.Addr, ...) (*DhtNode, error)
  • func (d *DhtNode) Close()
  • func (d *DhtNode) Port() *uint16
  • func (d *DhtNode) PrintStats()

Types

type DhtNode

type DhtNode struct {
	Node *dht.Server
	// contains filtered or unexported fields
}

func New

func New(
	nodeAddr *net.UDPAddr,
	torrentInfoHash [20]byte,
	startingNodes []dht.Addr,
	peerPort uint16,
	onNewPeerReceived func(peer peers.Peer)) (*DhtNode, error)

New creates a new DHT Node. peerPort, the port the controlling peer is listening to onNewPeerReceived, a function to be executed when a new Peer was found, used for adding the new peer to the controlling peers storage

func (*DhtNode) Close

func (d *DhtNode) Close()

func (*DhtNode) Port

func (d *DhtNode) Port() *uint16

func (*DhtNode) PrintStats

func (d *DhtNode) PrintStats()