Versions in this module Expand all Collapse all v0 v0.1.10 Dec 16, 2019 Changes in this version + var HasBlockBufferSize = 256 + var TaskWorkerCount = 8 + var TicketWorkerCount = 4 + func New(parent context.Context, network bsnet.BitSwapNetwork, ...) exchange.Interface + type Bitswap struct + func (bs *Bitswap) Close() error + func (bs *Bitswap) GetBlock(parent context.Context, k cid.Cid) (blocks.Block, error) + func (bs *Bitswap) GetBlocks(ctx context.Context, keys []cid.Cid) (<-chan blocks.Block, error) + func (bs *Bitswap) GetWantlist() []cid.Cid + func (bs *Bitswap) HasBlock(blk blocks.Block) error + func (bs *Bitswap) IsOnline() bool + func (bs *Bitswap) LedgerForPeer(p peer.ID) *decision.Receipt + func (bs *Bitswap) NewSession(ctx context.Context) exchange.Fetcher + func (bs *Bitswap) PeerConnected(p peer.ID) + func (bs *Bitswap) PeerDisconnected(p peer.ID) + func (bs *Bitswap) ReceiveError(err error) + func (bs *Bitswap) ReceiveMessage(ctx context.Context, p peer.ID, incoming bsmsg.BitSwapMessage) + func (bs *Bitswap) Stat() (*Stat, error) + func (bs *Bitswap) WantlistForPeer(p peer.ID) []cid.Cid + type Option func(*Bitswap) + func ProvideEnabled(enabled bool) Option + func ProviderSearchDelay(newProvSearchDelay time.Duration) Option + func RebroadcastDelay(newRebroadcastDelay delay.D) Option + type Stat struct + BlocksReceived uint64 + BlocksSent uint64 + DataReceived uint64 + DataSent uint64 + DupBlksReceived uint64 + DupDataReceived uint64 + MessagesReceived uint64 + Peers []string + ProvideBufLen int + Wantlist []cid.Cid v0.1.10-1 Dec 16, 2019