Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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
- API
  
  Reference documentation for the pkg.go.dev API
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

net

package module

Go to main page

Versions in this module

v0

v0.1.0

May 24, 2019

v0.0.2

Apr 10, 2019

Changes in this version

+ var ErrNoConn = errors.New("no usable connection to peer")

+ func GetNoDial(ctx context.Context) (nodial bool, reason string)

+ func WithNoDial(ctx context.Context, reason string) context.Context

v0.0.1

Mar 1, 2019

Changes in this version

+ const MessageSizeMax

+ var DialPeerTimeout = 60 * time.Second

+ var EOFTimeout = time.Second * 60

+ var ErrExpectedEOF = errors.New("read data when expecting EOF")

+ var ErrNoRemoteAddrs = errors.New("no remote addresses")

+ func AwaitEOF(s Stream) error

+ func FullClose(s Stream) error

+ func GetDialPeerTimeout(ctx context.Context) time.Duration

+ func WithDialPeerTimeout(ctx context.Context, timeout time.Duration) context.Context

+ type Conn interface

+ GetStreams func() []Stream

+ NewStream func() (Stream, error)

+ Stat func() Stat

+ type ConnHandler func(Conn)

+ type ConnMultiaddrs interface

+ LocalMultiaddr func() ma.Multiaddr

+ RemoteMultiaddr func() ma.Multiaddr

+ type ConnSecurity interface

+ LocalPeer func() peer.ID

+ LocalPrivateKey func() ic.PrivKey

+ RemotePeer func() peer.ID

+ RemotePublicKey func() ic.PubKey

+ type Connectedness int

+ const CanConnect

+ const CannotConnect

+ const Connected

+ const NotConnected

+ type Dialer interface

+ ClosePeer func(peer.ID) error

+ Connectedness func(peer.ID) Connectedness

+ Conns func() []Conn

+ ConnsToPeer func(p peer.ID) []Conn

+ DialPeer func(context.Context, peer.ID) (Conn, error)

+ LocalPeer func() peer.ID

+ Notify func(Notifiee)

+ Peers func() []peer.ID

+ Peerstore func() pstore.Peerstore

+ StopNotify func(Notifiee)

+ type Direction int

+ const DirInbound

+ const DirOutbound

+ const DirUnknown

+ type Network interface

+ InterfaceListenAddresses func() ([]ma.Multiaddr, error)

+ Listen func(...ma.Multiaddr) error

+ ListenAddresses func() []ma.Multiaddr

+ NewStream func(context.Context, peer.ID) (Stream, error)

+ Process func() goprocess.Process

+ SetConnHandler func(ConnHandler)

+ SetStreamHandler func(StreamHandler)

+ type Notifiee interface

+ ClosedStream func(Network, Stream)

+ Connected func(Network, Conn)

+ Disconnected func(Network, Conn)

+ Listen func(Network, ma.Multiaddr)

+ ListenClose func(Network, ma.Multiaddr)

+ OpenedStream func(Network, Stream)

+ type NotifyBundle struct

+ ClosedStreamF func(Network, Stream)

+ ConnectedF func(Network, Conn)

+ DisconnectedF func(Network, Conn)

+ ListenCloseF func(Network, ma.Multiaddr)

+ ListenF func(Network, ma.Multiaddr)

+ OpenedStreamF func(Network, Stream)

+ func (nb *NotifyBundle) ClosedStream(n Network, s Stream)

+ func (nb *NotifyBundle) Connected(n Network, c Conn)

+ func (nb *NotifyBundle) Disconnected(n Network, c Conn)

+ func (nb *NotifyBundle) Listen(n Network, a ma.Multiaddr)

+ func (nb *NotifyBundle) ListenClose(n Network, a ma.Multiaddr)

+ func (nb *NotifyBundle) OpenedStream(n Network, s Stream)

+ type Stat struct

+ Direction Direction

+ Extra map[interface{}]interface{}

+ type Stream interface

+ Conn func() Conn

+ Protocol func() protocol.ID

+ SetProtocol func(protocol.ID)

+ Stat func() Stat

+ type StreamHandler func(Stream)