Versions in this module Expand all Collapse all v0 v0.2.3 Feb 27, 2015 v0.2.2 Feb 27, 2015 Changes in this version + var FIFO = func(a, b *peerRequestTask) bool + var V1 = func(a, b *peerRequestTask) bool + type Engine struct + func NewEngine(ctx context.Context, bs bstore.Blockstore) *Engine + func (e *Engine) MessageReceived(p peer.ID, m bsmsg.BitSwapMessage) error + func (e *Engine) MessageSent(p peer.ID, m bsmsg.BitSwapMessage) error + func (e *Engine) Outbox() <-chan (<-chan *Envelope) + func (e *Engine) PeerDisconnected(p peer.ID) + func (e *Engine) Peers() []peer.ID + type Envelope struct + Message bsmsg.BitSwapMessage + Peer peer.ID