providertracker

Documentation

Index

• Variables
• type ProviderTracker
  • func New() *ProviderTracker
  • func (m *ProviderTracker) Ban(peer peer.ID, dur time.Duration)
  • func (m *ProviderTracker) BanCache() *cache.Cache
  • func (m *ProviderTracker) DidPeerSendNope(id peer.ID, key []byte) bool
  • func (m *ProviderTracker) Get(id peer.ID, cb func(*dht2.ProviderInfo)) *dht2.ProviderInfo
  • func (m *ProviderTracker) IsGood(id peer.ID) bool
  • func (m *ProviderTracker) MarkFailure(id peer.ID)
  • func (m *ProviderTracker) MarkSeen(id peer.ID)
  • func (m *ProviderTracker) NumProviders() int
  • func (m *ProviderTracker) PeerSentNope(id peer.ID, key []byte)
  • func (m *ProviderTracker) Register(addrs ...peer.AddrInfo)

Variables

var (
	// MaxFailureBeforeBan is the number of failures before a provider is banned
	MaxFailureBeforeBan = 30

	// BanDueToFailureDur is the duration of a ban due to failure
	BanDueToFailureDur = 15 * time.Minute

	// BackOffDurAfterFailure is the backoff time before a failed provider can be tried again.
	BackOffDurAfterFailure = 1 * time.Minute
)

Types

type ProviderTracker

type ProviderTracker struct {
	// contains filtered or unexported fields
}

ProviderTracker is used to track status and behaviour of providers.

func New

func New() *ProviderTracker

New creates an instance of dht.ProviderTracker.

func (*ProviderTracker) Ban

func (m *ProviderTracker) Ban(peer peer.ID, dur time.Duration)

Ban implements ProviderTracker

func (*ProviderTracker) BanCache

func (m *ProviderTracker) BanCache() *cache.Cache

BanCache returns the cache containing banned peers

func (*ProviderTracker) DidPeerSendNope

func (m *ProviderTracker) DidPeerSendNope(id peer.ID, key []byte) bool

DidPeerSendNope implements ProviderTracker

func (*ProviderTracker) Get

func (m *ProviderTracker) Get(id peer.ID, cb func(*dht2.ProviderInfo)) *dht2.ProviderInfo

Get implements ProviderTracker

func (*ProviderTracker) IsGood

func (m *ProviderTracker) IsGood(id peer.ID) bool

IsGood implements ProviderTracker

func (*ProviderTracker) MarkFailure

func (m *ProviderTracker) MarkFailure(id peer.ID)

MarkFailure implements ProviderTracker

func (*ProviderTracker) MarkSeen

func (m *ProviderTracker) MarkSeen(id peer.ID)

MarkSeen implements ProviderTracker

func (*ProviderTracker) NumProviders

func (m *ProviderTracker) NumProviders() int

NumProviders implements ProviderTracker

func (*ProviderTracker) PeerSentNope

func (m *ProviderTracker) PeerSentNope(id peer.ID, key []byte)

PeerSentNope implements ProviderTracker

func (*ProviderTracker) Register

func (m *ProviderTracker) Register(addrs ...peer.AddrInfo)

Register implements ProviderTracker