peer_store

Documentation

Index

• type InMemory
  • func (me *InMemory) AddPeer(ih InfoHash, na krpc.NodeAddr)
  • func (me *InMemory) GetAll() (ret map[InfoHash][]NodeAndTime)
  • func (me *InMemory) GetPeers(ih InfoHash) (ret []krpc.NodeAddr)
  • func (me *InMemory) WriteDebug(w io.Writer)
• type InfoHash
• type Interface
• type NodeAndTime

Types

type InMemory

type InMemory struct {
	// This is used for sorting infohashes by distance in WriteDebug.
	RootId int160.T
	// contains filtered or unexported fields
}

func (*InMemory) AddPeer

func (me *InMemory) AddPeer(ih InfoHash, na krpc.NodeAddr)

func (*InMemory) GetAll

func (me *InMemory) GetAll() (ret map[InfoHash][]NodeAndTime)

func (*InMemory) GetPeers

func (me *InMemory) GetPeers(ih InfoHash) (ret []krpc.NodeAddr)

func (*InMemory) WriteDebug

func (me *InMemory) WriteDebug(w io.Writer)

type InfoHash

type InfoHash = metainfo.Hash

type Interface

type Interface interface {
	AddPeer(InfoHash, krpc.NodeAddr)
	GetPeers(InfoHash) []krpc.NodeAddr
}

type NodeAndTime

type NodeAndTime struct {
	krpc.NodeAddr
	time.Time
}