Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

decision

package

Go to main page

Versions in this module

v0

v0.24.3

Dec 2, 2024

Changes in this version

+ type DefaultPeerLedger struct

+ func NewDefaultPeerLedger(maxEntriesPerPeer uint) *DefaultPeerLedger

+ func (l *DefaultPeerLedger) CancelWant(p peer.ID, k cid.Cid) bool

+ func (l *DefaultPeerLedger) CancelWantWithType(p peer.ID, k cid.Cid, typ pb.Message_Wantlist_WantType)

+ func (l *DefaultPeerLedger) ClearPeerWantlist(p peer.ID)

+ func (l *DefaultPeerLedger) CollectPeerIDs() []peer.ID

+ func (l *DefaultPeerLedger) PeerDisconnected(p peer.ID)

+ func (l *DefaultPeerLedger) Peers(k cid.Cid) []PeerEntry

+ func (l *DefaultPeerLedger) WantlistForPeer(p peer.ID) []wl.Entry

+ func (l *DefaultPeerLedger) WantlistSizeForPeer(p peer.ID) int

+ func (l *DefaultPeerLedger) Wants(p peer.ID, e wl.Entry) bool

type Engine

+ func (e *Engine) Close()

type Option

+ func WithPeerLedger(peerLedger PeerLedger) Option

+ func WithWantHaveReplaceSize(size int) Option

+ type PeerEntry struct

+ Peer peer.ID

+ Priority int32

+ WantType pb.Message_Wantlist_WantType

+ type PeerLedger interface

+ CancelWant func(p peer.ID, k cid.Cid) bool

+ CancelWantWithType func(p peer.ID, k cid.Cid, typ pb.Message_Wantlist_WantType)

+ ClearPeerWantlist func(p peer.ID)

+ CollectPeerIDs func() []peer.ID

+ PeerDisconnected func(p peer.ID)

+ Peers func(k cid.Cid) []PeerEntry

+ WantlistForPeer func(p peer.ID) []wl.Entry

+ WantlistSizeForPeer func(p peer.ID) int

+ Wants func(p peer.ID, e wl.Entry) bool

v0.10.7

Jul 17, 2023

v0.10.6

Jul 17, 2023

v0.10.5

Jul 15, 2023

v0.10.4

Jul 15, 2023

Changes in this version

+ type DefaultScoreLedger struct

+ func NewDefaultScoreLedger() *DefaultScoreLedger

+ func NewTestScoreLedger(peerSampleInterval time.Duration, sampleCh chan struct{}, clock clock.Clock) *DefaultScoreLedger

+ func (dsl *DefaultScoreLedger) AddToReceivedBytes(p peer.ID, n int)

+ func (dsl *DefaultScoreLedger) AddToSentBytes(p peer.ID, n int)

+ func (dsl *DefaultScoreLedger) GetReceipt(p peer.ID) *Receipt

+ func (dsl *DefaultScoreLedger) PeerConnected(p peer.ID)

+ func (dsl *DefaultScoreLedger) PeerDisconnected(p peer.ID)

+ func (dsl *DefaultScoreLedger) Start(scorePeer ScorePeerFunc)

+ func (dsl *DefaultScoreLedger) Stop()

+ type Engine struct

+ func NewEngine(ctx context.Context, bs bstore.Blockstore, peerTagger PeerTagger, self peer.ID, ...) *Engine

+ func (e *Engine) LedgerForPeer(p peer.ID) *Receipt

+ func (e *Engine) MessageReceived(ctx context.Context, p peer.ID, m bsmsg.BitSwapMessage) (mustKillConnection bool)

+ func (e *Engine) MessageSent(p peer.ID, m bsmsg.BitSwapMessage)

+ func (e *Engine) NotifyNewBlocks(blks []blocks.Block)

+ func (e *Engine) Outbox() <-chan (<-chan *Envelope)

+ func (e *Engine) PeerConnected(p peer.ID)

+ func (e *Engine) PeerDisconnected(p peer.ID)

+ func (e *Engine) Peers() []peer.ID

+ func (e *Engine) ReceivedBlocks(from peer.ID, blks []blocks.Block)

+ func (e *Engine) SetSendDontHaves(send bool)

+ func (e *Engine) StartWorkers(ctx context.Context, px process.Process)

+ func (e *Engine) WantlistForPeer(p peer.ID) []wl.Entry

+ type Envelope struct

+ Message bsmsg.BitSwapMessage

+ Peer peer.ID

+ Sent func()

+ type Option func(*Engine)

+ func WithBlockstoreWorkerCount(count int) Option

+ func WithMaxCidSize(n uint) Option

+ func WithMaxOutstandingBytesPerPeer(count int) Option

+ func WithMaxQueuedWantlistEntriesPerPeer(count uint) Option

+ func WithPeerBlockRequestFilter(pbrf PeerBlockRequestFilter) Option

+ func WithScoreLedger(scoreledger ScoreLedger) Option

+ func WithSetSendDontHave(send bool) Option

+ func WithTargetMessageSize(size int) Option

+ func WithTaskComparator(comparator TaskComparator) Option

+ func WithTaskWorkerCount(count int) Option

+ type PeerBlockRequestFilter func(p peer.ID, c cid.Cid) bool

+ type PeerTagger interface

+ TagPeer func(peer.ID, string, int)

+ UntagPeer func(p peer.ID, tag string)

+ type Receipt struct

+ Exchanged uint64

+ Peer string

+ Recv uint64

+ Sent uint64

+ Value float64

+ type ScoreLedger interface

+ AddToReceivedBytes func(p peer.ID, n int)

+ AddToSentBytes func(p peer.ID, n int)

+ GetReceipt func(p peer.ID) *Receipt

+ PeerConnected func(p peer.ID)

+ PeerDisconnected func(p peer.ID)

+ Start func(scorePeer ScorePeerFunc)

+ Stop func()

+ type ScorePeerFunc func(peer.ID, int)

+ type TaskComparator func(ta, tb *TaskInfo) bool

+ type TaskInfo struct

+ BlockSize int

+ Cid cid.Cid

+ HaveBlock bool

+ IsWantBlock bool

+ Peer peer.ID

+ SendDontHave bool