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.1.0

Dec 19, 2023

v0.0.8

Mar 29, 2024

v0.0.7

Mar 29, 2024

v0.0.6

Mar 25, 2024

v0.0.5

Mar 21, 2024

v0.0.4

Mar 20, 2024

v0.0.3

Mar 20, 2024

v0.0.2

Mar 20, 2024

Changes in this version

+ const MessageSizeMax

+ const ReservationPriorityAlways

+ const ReservationPriorityHigh

+ const ReservationPriorityLow

+ const ReservationPriorityMedium

+ var DialPeerTimeout = 60 * time.Second

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

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

+ var ErrReset = errors.New("stream reset")

+ var ErrResourceLimitExceeded = temporaryError("resource limit exceeded")

+ var ErrResourceScopeClosed = errors.New("resource scope closed")

+ var ErrTransientConn = errors.New("transient connection to peer")

+ var GlobalNoopNotifiee = &NoopNotifiee

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

+ func GetForceDirectDial(ctx context.Context) (forceDirect bool, reason string)

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

+ func GetSimultaneousConnect(ctx context.Context) (simconnect bool, isClient bool, reason string)

+ func GetUseTransient(ctx context.Context) (usetransient bool, reason string)

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

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

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

+ func WithSimultaneousConnect(ctx context.Context, isClient bool, reason string) context.Context

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

+ type AddrDelay struct

+ Addr ma.Multiaddr

+ Delay time.Duration

+ type Conn interface

+ GetStreams func() []Stream

+ ID func() string

+ IsClosed func() bool

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

+ type ConnManagementScope interface

+ PeerScope func() PeerScope

+ SetPeer func(peer.ID) error

+ type ConnMultiaddrs interface

+ LocalMultiaddr func() ma.Multiaddr

+ RemoteMultiaddr func() ma.Multiaddr

+ type ConnScope interface

+ type ConnScoper interface

+ Scope func() ConnScope

+ type ConnSecurity interface

+ ConnState func() ConnectionState

+ LocalPeer func() peer.ID

+ RemotePeer func() peer.ID

+ RemotePublicKey func() ic.PubKey

+ type ConnStat interface

+ Stat func() ConnStats

+ type ConnStats struct

+ NumStreams int

+ type Connectedness int

+ const CanConnect

+ const CannotConnect

+ const Connected

+ const NotConnected

+ func (c Connectedness) String() string

+ type ConnectionState struct

+ Security protocol.ID

+ StreamMultiplexer protocol.ID

+ Transport string

+ UsedEarlyMuxerNegotiation bool

+ type DialRanker func([]ma.Multiaddr) []AddrDelay

+ 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() peerstore.Peerstore

+ StopNotify func(Notifiee)

+ type Direction int

+ const DirInbound

+ const DirOutbound

+ const DirUnknown

+ func (d Direction) String() string

+ type Multiplexer interface

+ NewConn func(c net.Conn, isServer bool, scope PeerScope) (MuxedConn, error)

+ type MuxedConn interface

+ AcceptStream func() (MuxedStream, error)

+ IsClosed func() bool

+ OpenStream func(context.Context) (MuxedStream, error)

+ type MuxedStream interface

+ CloseRead func() error

+ CloseWrite func() error

+ Reset func() error

+ SetDeadline func(time.Time) error

+ SetReadDeadline func(time.Time) error

+ SetWriteDeadline func(time.Time) error

+ type NATDeviceType int

+ const NATDeviceTypeCone

+ const NATDeviceTypeSymmetric

+ const NATDeviceTypeUnknown

+ func (r NATDeviceType) String() string

+ type NATTransportProtocol int

+ const NATTransportTCP

+ const NATTransportUDP

+ func (n NATTransportProtocol) String() string

+ 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)

+ ResourceManager func() ResourceManager

+ SetStreamHandler func(StreamHandler)

+ type NoopNotifiee struct

+ func (nn *NoopNotifiee) Connected(n Network, c Conn)

+ func (nn *NoopNotifiee) Disconnected(n Network, c Conn)

+ func (nn *NoopNotifiee) Listen(n Network, addr ma.Multiaddr)

+ func (nn *NoopNotifiee) ListenClose(n Network, addr ma.Multiaddr)

+ type Notifiee interface

+ Connected func(Network, Conn)

+ Disconnected func(Network, Conn)

+ Listen func(Network, ma.Multiaddr)

+ ListenClose func(Network, ma.Multiaddr)

+ type NotifyBundle struct

+ ConnectedF func(Network, Conn)

+ DisconnectedF func(Network, Conn)

+ ListenCloseF func(Network, ma.Multiaddr)

+ ListenF func(Network, ma.Multiaddr)

+ 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)

+ type NullResourceManager struct

+ func (n *NullResourceManager) Close() error

+ func (n *NullResourceManager) OpenConnection(dir Direction, usefd bool, endpoint multiaddr.Multiaddr) (ConnManagementScope, error)

+ func (n *NullResourceManager) OpenStream(p peer.ID, dir Direction) (StreamManagementScope, error)

+ func (n *NullResourceManager) ViewPeer(p peer.ID, f func(PeerScope) error) error

+ func (n *NullResourceManager) ViewProtocol(p protocol.ID, f func(ProtocolScope) error) error

+ func (n *NullResourceManager) ViewService(svc string, f func(ServiceScope) error) error

+ func (n *NullResourceManager) ViewSystem(f func(ResourceScope) error) error

+ func (n *NullResourceManager) ViewTransient(f func(ResourceScope) error) error

+ type NullScope struct

+ func (n *NullScope) BeginSpan() (ResourceScopeSpan, error)

+ func (n *NullScope) Done()

+ func (n *NullScope) Name() string

+ func (n *NullScope) Peer() peer.ID

+ func (n *NullScope) PeerScope() PeerScope

+ func (n *NullScope) Protocol() protocol.ID

+ func (n *NullScope) ProtocolScope() ProtocolScope

+ func (n *NullScope) ReleaseMemory(size int)

+ func (n *NullScope) ReserveMemory(size int, prio uint8) error

+ func (n *NullScope) ServiceScope() ServiceScope

+ func (n *NullScope) SetPeer(peer.ID) error

+ func (n *NullScope) SetProtocol(proto protocol.ID) error

+ func (n *NullScope) SetService(srv string) error

+ func (n *NullScope) Stat() ScopeStat

+ type PeerScope interface

+ Peer func() peer.ID

+ type ProtocolScope interface

+ Protocol func() protocol.ID

+ type Reachability int

+ const ReachabilityPrivate

+ const ReachabilityPublic

+ const ReachabilityUnknown

+ func (r Reachability) String() string

+ type ResourceManager interface

+ Close func() error

+ OpenConnection func(dir Direction, usefd bool, endpoint multiaddr.Multiaddr) (ConnManagementScope, error)

+ OpenStream func(p peer.ID, dir Direction) (StreamManagementScope, error)

+ type ResourceScope interface

+ BeginSpan func() (ResourceScopeSpan, error)

+ ReleaseMemory func(size int)

+ ReserveMemory func(size int, prio uint8) error

+ Stat func() ScopeStat

+ type ResourceScopeSpan interface

+ Done func()

+ type ResourceScopeViewer interface

+ ViewPeer func(peer.ID, func(PeerScope) error) error

+ ViewProtocol func(protocol.ID, func(ProtocolScope) error) error

+ ViewService func(string, func(ServiceScope) error) error

+ ViewSystem func(func(ResourceScope) error) error

+ ViewTransient func(func(ResourceScope) error) error

+ type ScopeStat struct

+ Memory int64

+ NumConnsInbound int

+ NumConnsOutbound int

+ NumFD int

+ NumStreamsInbound int

+ NumStreamsOutbound int

+ type ServiceScope interface

+ Name func() string

+ type Stats struct

+ Direction Direction

+ Extra map[interface{}]interface{}

+ Opened time.Time

+ Transient bool

+ type Stream interface

+ Conn func() Conn

+ ID func() string

+ Protocol func() protocol.ID

+ Scope func() StreamScope

+ SetProtocol func(id protocol.ID) error

+ Stat func() Stats

+ type StreamHandler func(Stream)

+ type StreamManagementScope interface

+ PeerScope func() PeerScope

+ ProtocolScope func() ProtocolScope

+ ServiceScope func() ServiceScope

+ SetProtocol func(proto protocol.ID) error

+ SetService func(srv string) error

+ type StreamScope interface

+ SetService func(srv string) error