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

network

package

Go to main page

Versions in this module

v0

v0.24.3

Dec 2, 2024

Changes in this version

type BitSwapNetwork

+ Connect func(context.Context, peer.AddrInfo) error

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

+ var ProtocolBitswap = internal.ProtocolBitswap

+ var ProtocolBitswapNoVers = internal.ProtocolBitswapNoVers

+ var ProtocolBitswapOneOne = internal.ProtocolBitswapOneOne

+ var ProtocolBitswapOneZero = internal.ProtocolBitswapOneZero

+ type BitSwapNetwork interface

+ ConnectTo func(context.Context, peer.ID) error

+ ConnectionManager func() connmgr.ConnManager

+ DisconnectFrom func(context.Context, peer.ID) error

+ NewMessageSender func(context.Context, peer.ID, *MessageSenderOpts) (MessageSender, error)

+ Self func() peer.ID

+ SendMessage func(context.Context, peer.ID, bsmsg.BitSwapMessage) error

+ Start func(...Receiver)

+ Stats func() Stats

+ Stop func()

+ func NewFromIpfsHost(host host.Host, r routing.ContentRouting, opts ...NetOpt) BitSwapNetwork

+ type ConnectionListener interface

+ PeerConnected func(peer.ID)

+ PeerDisconnected func(peer.ID)

+ type MessageSender interface

+ Close func() error

+ Reset func() error

+ SendMsg func(context.Context, bsmsg.BitSwapMessage) error

+ SupportsHave func() bool

+ type MessageSenderOpts struct

+ MaxRetries int

+ SendErrorBackoff time.Duration

+ SendTimeout time.Duration

+ type NetOpt func(*Settings)

+ func Prefix(prefix protocol.ID) NetOpt

+ func SupportedProtocols(protos []protocol.ID) NetOpt

+ type Pinger interface

+ Latency func(peer.ID) time.Duration

+ Ping func(context.Context, peer.ID) ping.Result

+ type Receiver interface

+ PeerConnected func(peer.ID)

+ PeerDisconnected func(peer.ID)

+ ReceiveError func(error)

+ ReceiveMessage func(ctx context.Context, sender peer.ID, incoming bsmsg.BitSwapMessage)

+ type Routing interface

+ FindProvidersAsync func(context.Context, cid.Cid, int) <-chan peer.ID

+ Provide func(context.Context, cid.Cid) error

+ type Settings struct

+ ProtocolPrefix protocol.ID

+ SupportedProtocols []protocol.ID

+ type Stats struct

+ MessagesRecvd uint64

+ MessagesSent uint64