dht

Apr 9, 2022

Changes in this version

type DHT

+ func (dht *DHT) Stop()

Apr 9, 2022

Changes in this version

+ func Log(a ...interface{})

type StunList

+ func (r StunList) SliceIndex(element string, data []string) int

Apr 9, 2022

Changes in this version

type DHT

+ func (dht *DHT) Join2addr(addr string)

type StunList

+ func (r StunList) GetSelfPublicIpPort1() (string, int)

Apr 7, 2022

Changes in this version

type Config

+ GetPeerLists []string

+ Log *log.Logger

type DHT

+ func (dht *DHT) DoAllGetPeers()

+ func (dht *DHT) Log(args ...interface{})

Apr 7, 2022

Changes in this version

type Config

+ AnnouncePeerLists []string

+ PublicIp string

+ QueryWorkLimit int

+ StunList StunList

type DHT

+ func (dht *DHT) RemoveAnnouncePeer(infoHash string) bool

+ type Fn func()

+ type MyTicker struct

+ MyTick *time.Ticker

+ Runner Fn

+ func NewMyTick(interval int, f Fn) *MyTicker

+ func (t *MyTicker) Start()

+ func (t *MyTicker) Stop()

Apr 6, 2022

Changes in this version

type StunList

+ func (r StunList) GetSelfPublicIpPort() string

+ func (r StunList) GetStunLists() []string

Apr 5, 2022

Changes in this version

+ func SliceIndex(element string, data []string) int

Apr 4, 2022

Changes in this version

+ type IStunList interface

+ GetDhtList func() []string

+ GetDhtMultiaddr func() []multiaddr.Multiaddr

+ GetStunList func() []string

+ type StunList struct

+ func (r StunList) GetDhtList() []string

+ func (r StunList) GetDhtListArr() [][]string

+ func (r StunList) GetDhtListRawA() []string

+ func (r StunList) GetDhtMma() []multiaddr.Multiaddr

+ func (r StunList) GetDhtUdpLists() []string

Apr 4, 2022

Changes in this version

+ var ErrOnAnnouncePeerNotSet = errors.New("OnAnnouncePeer is not set")

type DHT

+ func (dht *DHT) AnnouncePeer(infoHash string) error

Mar 28, 2022

Changes in this version

+ var LocalNodeId = hex.EncodeToString([]byte("https://ee.51pwn.com")[:20])

Mar 28, 2022

Changes in this version

+ const BLOCK

+ const CrawlMode

+ const DATA

+ const EXTENDED

+ const HANDSHAKE

+ const MaxMetadataSize

+ const REJECT

+ const REQUEST

+ const StandardMode

+ var ErrNotReady = errors.New("dht is not ready")

+ var ErrOnGetPeersResponseNotSet = errors.New("OnGetPeersResponse is not set")

+ func Decode(data []byte) (result interface{}, err error)

+ func DecodeDict(data []byte, start int) (result interface{}, index int, err error)

+ func DecodeInt(data []byte, start int) (result interface{}, index int, err error)

+ func DecodeList(data []byte, start int) (result interface{}, index int, err error)

+ func DecodeString(data []byte, start int) (result interface{}, index int, err error)

+ func Encode(data interface{}) string

+ func EncodeDict(data map[string]interface{}) string

+ func EncodeInt(data int) string

+ func EncodeList(data []interface{}) string

+ func EncodeString(data string) string

+ func ParseKey(data map[string]interface{}, key string, t string) error

+ func ParseKeys(data map[string]interface{}, pairs [][]string) error

+ type Config struct

+ Address string

+ BlackListMaxSize int

+ BlockedIPs []string

+ CheckKBucketPeriod time.Duration

+ K int

+ KBucketExpiredAfter time.Duration

+ KBucketSize int

+ LocalNodeId string

+ MaxNodes int

+ MaxTransactionCursor uint64

+ Mode int

+ Network string

+ NodeExpriedAfter time.Duration

+ OnAnnouncePeer func(string, string, int)

+ OnGetPeers func(string, string, int)

+ OnGetPeersResponse func(string, *Peer)

+ PacketJobLimit int

+ PacketWorkerLimit int

+ PrimeNodes []string

+ RefreshNodeNum int

+ TokenExpiredAfter time.Duration

+ Try int

+ func NewCrawlConfig() *Config

+ func NewStandardConfig() *Config

+ type DHT struct

+ Ready bool

+ func New(config *Config) *DHT

+ func (dht *DHT) GetPeers(infoHash string) error

+ func (dht *DHT) IsCrawlMode() bool

+ func (dht *DHT) IsStandardMode() bool

+ func (dht *DHT) Run()

+ type Peer struct

+ IP net.IP

+ Port int

+ func (p *Peer) CompactIPPortInfo() string

+ type Request struct

+ IP string

+ InfoHash []byte

+ Port int

+ type Response struct

+ MetadataInfo []byte

+ type Wire struct

+ func NewWire(blackListSize, requestQueueSize, workerQueueSize int) *Wire

+ func (wire *Wire) Request(infoHash []byte, ip string, port int)

+ func (wire *Wire) Response() <-chan Response

+ func (wire *Wire) Run()