dht

Oct 2, 2019

Changes in this version

+ const DefaultAnnounceRate

+ const DefaultPeerPort

+ const DefaultPort

+ const DefaultReannounceTime

+ const Network

+ func NodeFinderUseLogger(l *logrus.Logger)

+ func RoutingTableRefresh(n *Node, refreshInterval time.Duration, parentGrp *stop.Group)

+ func TestingCreateNetwork(t *testing.T, numNodes int, bootstrap, concurrent bool) (*BootstrapNode, []*DHT)

+ func UseLogger(l *logrus.Logger)

+ type BootstrapNode struct

+ func NewBootstrapNode(id bits.Bitmap, initialPingInterval, rePingInterval time.Duration) *BootstrapNode

+ func (b *BootstrapNode) Add(c Contact)

+ func (b *BootstrapNode) Connect(conn UDPConn) error

+ type Config struct

+ Address string

+ AnnounceNotificationCh chan announceNotification

+ AnnounceRate int

+ NodeID string

+ PeerProtocolPort int

+ PrintState time.Duration

+ RPCPort int

+ ReannounceTime time.Duration

+ SeedNodes []string

+ func NewStandardConfig() *Config

+ type Contact struct

+ ID bits.Bitmap

+ IP net.IP

+ PeerPort int

+ Port int

+ func FindContacts(node *Node, target bits.Bitmap, findValue bool, parentGrp *stop.Group) ([]Contact, bool, error)

+ func (c *Contact) UnmarshalBencode(b []byte) error

+ func (c *Contact) UnmarshalCompact(b []byte) error

+ func (c Contact) Addr() *net.UDPAddr

+ func (c Contact) Equals(other Contact, checkID bool) bool

+ func (c Contact) MarshalBencode() ([]byte, error)

+ func (c Contact) MarshalCompact() ([]byte, error)

+ func (c Contact) String() string

+ type DHT struct

+ func New(config *Config) *DHT

+ func (dht *DHT) Add(hash bits.Bitmap)

+ func (dht *DHT) Get(hash bits.Bitmap) ([]Contact, error)

+ func (dht *DHT) Ping(addr string) error

+ func (dht *DHT) PrintState()

+ func (dht *DHT) Remove(hash bits.Bitmap)

+ func (dht *DHT) Shutdown()

+ func (dht *DHT) Start() error

+ func (dht *DHT) WaitUntilJoined()

+ func (dht DHT) ID() bits.Bitmap

+ type Error struct

+ ExceptionType string

+ ID messageID

+ NodeID bits.Bitmap

+ Response []string

+ func (e *Error) UnmarshalBencode(b []byte) error

+ func (e Error) MarshalBencode() ([]byte, error)

+ type Message interface

+ type Node struct

+ func NewNode(id bits.Bitmap) *Node

+ func (n *Node) AddKnownNode(c Contact)

+ func (n *Node) Connect(conn UDPConn) error

+ func (n *Node) CountActiveTransactions() int

+ func (n *Node) Send(contact Contact, req Request, options ...SendOptions) *Response

+ func (n *Node) SendAsync(contact Contact, req Request, options ...SendOptions) <-chan *Response

+ func (n *Node) Shutdown()

+ func (n *Node) Store(hash bits.Bitmap, c Contact)

+ type Request struct

+ Arg *bits.Bitmap

+ ID messageID

+ Method string

+ NodeID bits.Bitmap

+ ProtocolVersion int

+ StoreArgs *storeArgs

+ func (r *Request) UnmarshalBencode(b []byte) error

+ func (r Request) MarshalBencode() ([]byte, error)

+ type RequestHandlerFunc func(addr *net.UDPAddr, request Request)

+ type Response struct

+ Contacts []Contact

+ Data string

+ FindValueKey string

+ ID messageID

+ NodeID bits.Bitmap

+ ProtocolVersion int

+ Token string

+ func (r *Response) UnmarshalBencode(b []byte) error

+ func (r Response) MarshalBencode() ([]byte, error)

+ type RpcBucketResponse struct

+ Contacts []Contact

+ End string

+ NumContacts int

+ Start string

+ type RpcFindArgs struct

+ IP string

+ Key string

+ NodeID string

+ Port int

+ type RpcFindValueResult struct

+ Contacts []Contact

+ Value string

+ type RpcIterativeFindValueArgs struct

+ Key string

+ type RpcIterativeFindValueResult struct

+ Contacts []Contact

+ FoundValue bool

+ type RpcPingArgs struct

+ Address string

+ type RpcRoutingTableResponse struct

+ Buckets []RpcBucketResponse

+ NodeID string

+ NumBuckets int

+ type SendOptions struct

+ type UDPConn interface

+ Close func() error

+ ReadFromUDP func([]byte) (int, *net.UDPAddr, error)

+ SetReadDeadline func(time.Time) error

+ SetWriteDeadline func(time.Time) error

+ WriteToUDP func([]byte, *net.UDPAddr) (int, error)