sessionmanager

package

v0.1.10 Latest Latest Go to latest Published: Dec 16, 2019 License: MIT Imports: 9 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

Repository

github.com/SJTU-OpenNetwork/go-bitswap

Links

Open Source Insights

Documentation ¶

Index ¶

type PeerManagerFactory
type RequestSplitterFactory
type Session
type SessionFactory
type SessionManager
- func New(ctx context.Context, sessionFactory SessionFactory, ...) *SessionManager

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type PeerManagerFactory ¶

type PeerManagerFactory func(ctx context.Context, id uint64) bssession.PeerManager

PeerManagerFactory generates a new peer manager for a session.

type RequestSplitterFactory ¶

type RequestSplitterFactory func(ctx context.Context) bssession.RequestSplitter

RequestSplitterFactory generates a new request splitter for a session.

type Session ¶

type Session interface {
	exchange.Fetcher
	ReceiveFrom(peer.ID, []cid.Cid)
	IsWanted(cid.Cid) bool
}

Session is a session that is managed by the session manager

type SessionFactory ¶

type SessionFactory func(ctx context.Context, id uint64, pm bssession.PeerManager, srs bssession.RequestSplitter, notif notifications.PubSub, provSearchDelay time.Duration, rebroadcastDelay delay.D) Session

SessionFactory generates a new session for the SessionManager to track.

type SessionManager ¶

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

SessionManager is responsible for creating, managing, and dispatching to sessions.

func New ¶

func New(ctx context.Context, sessionFactory SessionFactory, peerManagerFactory PeerManagerFactory,
	requestSplitterFactory RequestSplitterFactory, notif notifications.PubSub) *SessionManager

New creates a new SessionManager.

func (*SessionManager) GetNextSessionID ¶

func (sm *SessionManager) GetNextSessionID() uint64

GetNextSessionID returns the next sequentional identifier for a session.

func (*SessionManager) IsWanted ¶

func (sm *SessionManager) IsWanted(cid cid.Cid) bool

IsWanted indicates whether any of the sessions are waiting to receive the block with the given CID.

func (*SessionManager) NewSession ¶

func (sm *SessionManager) NewSession(ctx context.Context,
	provSearchDelay time.Duration,
	rebroadcastDelay delay.D) exchange.Fetcher

NewSession initializes a session with the given context, and adds to the session manager.

func (*SessionManager) ReceiveFrom ¶

func (sm *SessionManager) ReceiveFrom(from peer.ID, ks []cid.Cid)

ReceiveFrom receives block CIDs from a peer and dispatches to sessions.

Source Files ¶

View all Source files

sessionmanager.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL