Versions in this module Expand all Collapse all v0 v0.4.11 Apr 17, 2023 v0.4.1 Apr 3, 2023 Changes in this version + var HasBlockBufferSize = defaults.HasBlockBufferSize + type Bitswap struct + func New(ctx context.Context, net network.BitSwapNetwork, bstore blockstore.Blockstore, ...) *Bitswap + func (bs *Bitswap) Close() error + func (bs *Bitswap) NotifyNewBlocks(ctx context.Context, blks ...blocks.Block) error + 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 message.BitSwapMessage) + func (bs *Bitswap) Stat() (*Stat, error) + func (bs *Bitswap) WantlistForPeer(p peer.ID) []cid.Cid + type Option struct + func EngineBlockstoreWorkerCount(count int) Option + func EngineTaskWorkerCount(count int) Option + func MaxOutstandingBytesPerPeer(count int) Option + func ProvideEnabled(enabled bool) Option + func ProviderSearchDelay(newProvSearchDelay time.Duration) Option + func RebroadcastDelay(newRebroadcastDelay delay.D) Option + func SetSendDontHaves(send bool) Option + func SetSimulateDontHavesOnTimeout(send bool) Option + func TaskWorkerCount(count int) Option + func WithPeerBlockRequestFilter(pbrf server.PeerBlockRequestFilter) Option + func WithScoreLedger(scoreLedger server.ScoreLedger) Option + func WithTargetMessageSize(tms int) Option + func WithTaskComparator(comparator server.TaskComparator) Option + func WithTracer(tap tracer.Tracer) Option + type PeerBlockRequestFilter = server.PeerBlockRequestFilter + type Stat struct + BlocksReceived uint64 + BlocksSent uint64 + DataReceived uint64 + DataSent uint64 + DupBlksReceived uint64 + DupDataReceived uint64 + MessagesReceived uint64 + Peers []string + ProvideBufLen int + Wantlist []cid.Cid + type TaskComparator = server.TaskComparator + type TaskInfo = server.TaskInfo + type Tracer = tracer.Tracer
Go to main page