dht

Sep 23, 2021

Changes in this version

+ var TransactionTimeout = errors.New("transaction timed out")

+ func MakeDeterministicNodeID(public net.Addr) (id krpc.ID)

+ func NodeIdSecure(id [20]byte, ip net.IP) bool

+ func RandomNodeID() (id krpc.ID)

+ func ReadNodesFromFile(fileName string) (ns []krpc.NodeInfo, err error)

+ func SecureNodeId(id *krpc.ID, ip net.IP)

+ func WriteNodesToFile(ns []krpc.NodeInfo, fileName string) (err error)

+ type Addr interface

+ IA func() addr.IA

+ IP func() net.IP

+ KRPC func() krpc.NodeAddr

+ Port func() int

+ Raw func() snet.UDPAddr

+ String func() string

+ func GlobalBootstrapAddrs(network string) (addrs []Addr, err error)

+ func NewAddr(raw snet.UDPAddr) Addr

+ type Announce struct

+ Peers chan PeersValues

+ func (a *Announce) Close()

+ func (a *Announce) NumContacted() uint32

+ func (a *Announce) String() string

+ type AnnounceOpt *struct

+ func Scrape() AnnounceOpt

+ type Peer = krpc.NodeAddr

+ type PeersValues struct

+ Peers []Peer

+ type QueryInput struct

+ MsgArgs krpc.MsgArgs

+ NumTries int

+ RateLimiting QueryRateLimiting

+ type QueryRateLimiting struct

+ NotAny bool

+ NotFirst bool

+ WaitOnRetries bool

+ type QueryResult struct

+ Err error

+ Reply krpc.Msg

+ Writes numWrites

+ func (me QueryResult) TraversalQueryResult(addr krpc.NodeAddr) (ret traversal.QueryResult)

+ func (qr QueryResult) ToError() error

+ type Server struct

+ func NewServer(c *ServerConfig) (s *Server, err error)

+ func (s *Server) AddNode(ni krpc.NodeInfo) error

+ func (s *Server) AddNodesFromFile(fileName string) (added int, err error)

+ func (s *Server) Addr() net.Addr

+ func (s *Server) Announce(infoHash [20]byte, port int, impliedPort bool, opts ...AnnounceOpt) (_ *Announce, err error)

+ func (s *Server) Bootstrap() (_ TraversalStats, err error)

+ func (s *Server) Close()

+ func (s *Server) FindNode(addr Addr, targetID int160.T, rl QueryRateLimiting) (ret QueryResult)

+ func (s *Server) GetPeers(ctx context.Context, addr Addr, infoHash int160.T, scrape bool, ...) (ret QueryResult)

+ func (s *Server) ID() [20]byte

+ func (s *Server) IPBlocklist() iplist.Ranger

+ func (s *Server) IsGood(n *node) bool

+ func (s *Server) IsQuestionable(n *node) bool

+ func (s *Server) NodeRespondedToPing(addr Addr, id int160.T)

+ func (s *Server) Nodes() (nis []krpc.NodeInfo)

+ func (s *Server) NumNodes() int

+ func (s *Server) PeerStore() peer_store.Interface

+ func (s *Server) Ping(node *snet.UDPAddr) QueryResult

+ func (s *Server) Query(ctx context.Context, addr Addr, q string, input QueryInput) (ret QueryResult)

+ func (s *Server) SetIPBlockList(list iplist.Ranger)

+ func (s *Server) Stats() ServerStats

+ func (s *Server) String() string

+ func (s *Server) TableMaintainer()

+ func (s *Server) TraversalNodeFilter(node addrMaybeId) bool

+ func (s *Server) TraversalStartingNodes() (nodes []addrMaybeId, err error)

+ func (s *Server) WriteStatus(w io.Writer)

+ type ServerConfig struct

+ Conn *snet.Conn

+ DefaultWant []krpc.Want

+ IPBlocklist iplist.Ranger

+ Logger log.Logger

+ NoSecurity bool

+ NodeId krpc.ID

+ OnAnnouncePeer func(infoHash metainfo.Hash, ip net.IP, port int, portOk bool)

+ OnQuery func(query *krpc.Msg, source snet.UDPAddr) (propagate bool)

+ Passive bool

+ PeerStore peer_store.Interface

+ PublicIP net.IP

+ QueryResendDelay func() time.Duration

+ StartingNodes StartingNodesGetter

+ func NewDefaultServerConfig() *ServerConfig

+ func (c *ServerConfig) InitNodeId()

+ type ServerStats struct

+ BadNodes uint

+ GoodNodes int

+ Nodes int

+ OutboundQueriesAttempted int64

+ OutstandingTransactions int

+ SuccessfulOutboundAnnouncePeerQueries int64

+ type StartingNodesGetter func() ([]Addr, error)

+ type Transaction struct

+ type TraversalStats = traversal.Stats