sessionpeermanager

package

v0.0.0-...-8b9b725 Latest Latest Go to latest Published: Apr 7, 2019 License: MIT, MIT Imports: 6 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type PeerProviderFinder interface {
	FindProvidersAsync(context.Context, cid.Cid) <-chan peer.ID
}

PeerProviderFinder is an interface for finding providers

type PeerTagger interface {
	TagPeer(peer.ID, string, int)
	UntagPeer(p peer.ID, tag string)
}

PeerTagger is an interface for tagging peers with metadata

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

SessionPeerManager tracks and manages peers for a session, and provides the best ones to the session

func New(ctx context.Context, id uint64, tagger PeerTagger, providerFinder PeerProviderFinder) *SessionPeerManager

New creates a new SessionPeerManager

func (spm *SessionPeerManager) FindMorePeers(ctx context.Context, c cid.Cid)

FindMorePeers attempts to find more peers for a session by searching for providers for the given Cid

func (spm *SessionPeerManager) GetOptimizedPeers() []peer.ID

GetOptimizedPeers returns the best peers available for a session

func (spm *SessionPeerManager) RecordPeerRequests(p []peer.ID, ks []cid.Cid)

RecordPeerRequests records that a given set of peers requested the given cids

func (spm *SessionPeerManager) RecordPeerResponse(p peer.ID, k cid.Cid)

RecordPeerResponse records that a peer received a block, and adds to it the list of peers if it wasn't already added