sessionpeermanager

package

v0.1.10 Latest Latest Go to latest Published: Dec 16, 2019 License: MIT Imports: 8 Imported by: 0

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() []bssd.OptimizedPeer

GetOptimizedPeers returns the best peers available for a session, along with a rating for how good they are, in comparison to the best peer.

func (spm *SessionPeerManager) RecordCancels(ks []cid.Cid)

RecordCancels records the fact that cancellations were sent to peers, so if blocks don't arrive, don't let it affect the peer's timeout

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, ks []cid.Cid)

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

func (spm *SessionPeerManager) SetTimeoutDuration(timeoutDuration time.Duration)

SetTimeoutDuration changes the length of time used to timeout recording of requests