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

p2p

package

Go to main page

Versions in this module

v1

v1.4.1

Mar 1, 2023

Changes in this version

+ const DefaultBlocklistTime

+ const HeaderNameTracingSpanContext

+ const ReachabilityStatusPrivate

+ const ReachabilityStatusPublic

+ const ReachabilityStatusUnknown

+ var ErrAlreadyConnected = errors.New("already connected")

+ var ErrDialLightNode = errors.New("target peer is a light node")

+ var ErrNetworkUnavailable = errors.New("network unavailable")

+ var ErrPeerBlocklisted = errors.New("peer blocklisted")

+ var ErrPeerNotFound = errors.New("peer not found")

+ var ErrStreamClosed = errors.New("stream closed")

+ var ErrUnexpected = errors.New("unexpected request while in light mode")

+ func Discover(ctx context.Context, addr ma.Multiaddr, f func(ma.Multiaddr) (bool, error)) (bool, error)

+ func NewBlockPeerError(duration time.Duration, err error) error

+ func NewConnectionBackoffError(err error, tryAfter time.Time) error

+ func NewDisconnectError(err error) error

+ func NewProtocolStreamName(protocol, version, stream string) string

+ func WithBlocklistStreams(dur time.Duration, spec ProtocolSpec)

+ func WithDisconnectStreams(spec ProtocolSpec)

+ type BlockPeerError struct

+ func (e *BlockPeerError) Duration() time.Duration

+ func (e *BlockPeerError) Error() string

+ func (e *BlockPeerError) Unwrap() error

+ type BlockPeers struct

+ Address boson.Address

+ Duration float64

+ Timestamp string

+ type Blocklister interface

+ Blocklist func(overlay boson.Address, duration time.Duration, reason string) error

+ type Connect interface

+ Connect func(ctx context.Context, addr ma.Multiaddr) (peer *Peer, err error)

+ type ConnectionBackoffError struct

+ func (e *ConnectionBackoffError) Error() string

+ func (e *ConnectionBackoffError) TryAfter() time.Time

+ func (e *ConnectionBackoffError) Unwrap() error

+ type DebugService interface

+ GetWelcomeMessage func() string

+ SetWelcomeMessage func(val string) error

+ type DisconnectError struct

+ func (e *DisconnectError) Error() string

+ func (e *DisconnectError) Unwrap() error

+ type Disconnecter interface

+ Disconnect func(overlay boson.Address, reason string) error

+ type Halter interface

+ Halt func()

+ type HandlerFunc func(context.Context, Peer, Stream) error

+ type HandlerMiddleware func(HandlerFunc) HandlerFunc

+ type Headers map[string][]byte

+ type HeadlerFunc func(Headers, boson.Address) Headers

+ type IncompatibleStreamError struct

+ func NewIncompatibleStreamError(err error) *IncompatibleStreamError

+ func (e *IncompatibleStreamError) Error() string

+ func (e *IncompatibleStreamError) Unwrap() error

+ type NetworkStatus int

+ const NetworkStatusAvailable

+ const NetworkStatusUnavailable

+ const NetworkStatusUnknown

+ func (ns NetworkStatus) String() string

+ type NetworkStatuser interface

+ NetworkStatus func() NetworkStatus

+ type Notifier interface

+ Announce func(ctx context.Context, peer boson.Address, fullnode bool) error

+ AnnounceTo func(ctx context.Context, addressee, peer boson.Address, fullnode bool) error

+ Connected func(context.Context, Peer, bool) error

+ Disconnected func(peer Peer, reason string)

+ NotifyPeerState func(peer PeerInfo)

+ type Peer struct

+ Address boson.Address

+ Mode address.Model

+ type PeerInfo struct

+ Mode []byte

+ Overlay boson.Address

+ Reason string

+ State PeerState

+ type PeerState int

+ const PeerStateConnectIn

+ const PeerStateConnectOut

+ const PeerStateDisconnect

+ type Picker interface

+ Pick func(Peer) bool

+ type PickyNotifier interface

+ type Pinger interface

+ Ping func(ctx context.Context, addr ma.Multiaddr) (rtt time.Duration, err error)

+ type ProtocolSpec struct

+ ConnectIn func(context.Context, Peer) error

+ ConnectOut func(context.Context, Peer) error

+ DisconnectIn func(Peer) error

+ DisconnectOut func(Peer) error

+ Name string

+ StreamSpecs []StreamSpec

+ Version string

+ type ReachabilityStatus network.Reachability

+ func (rs ReachabilityStatus) String() string

+ type ReachabilityUpdater interface

+ UpdateReachability func(ReachabilityStatus)

+ type ReachableNotifier interface

+ Reachable func(boson.Address, ReachabilityStatus)

+ type Reacher interface

+ Connected func(boson.Address, ma.Multiaddr)

+ Disconnected func(boson.Address)

+ type ReaderChan struct

+ Err chan error

+ R chan []byte

+ type Service interface

+ AddProtocol func(ProtocolSpec) error

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

+ BlocklistRemove func(overlay boson.Address) error

+ BlocklistedPeers func() ([]BlockPeers, error)

+ CallHandler func(ctx context.Context, last Peer, stream Stream) (relayData *pb.RouteRelayReq, w *WriterChan, r *ReaderChan, forward bool, ...)

+ CallHandlerWithConnChain func(ctx context.Context, last, src Peer, stream Stream, ...) error

+ NATAddresses func() ([]net.Addr, error)

+ PeerID func(overlay boson.Address) (id libp2ppeer.ID, found bool)

+ Peers func() []Peer

+ ResourceManager func() network.ResourceManager

+ SetPickyNotifier func(PickyNotifier)

+ type Stream interface

+ FullClose func() error

+ Headers func() Headers

+ Reset func() error

+ ResponseHeaders func() Headers

+ type StreamSpec struct

+ Handler HandlerFunc

+ Headler HeadlerFunc

+ Name string

+ type StreamVirtual struct

+ ReadPipe *io.PipeReader

+ WritePipe *io.PipeWriter

+ func (s *StreamVirtual) Close() error

+ func (s *StreamVirtual) FullClose() error

+ func (s *StreamVirtual) Read(p []byte) (int, error)

+ func (s *StreamVirtual) Reset() error

+ type Streamer interface

+ NewConnChainRelayStream func(ctx context.Context, target boson.Address, h Headers, ...) (Stream, error)

+ NewRelayStream func(ctx context.Context, address boson.Address, h Headers, ...) (Stream, error)

+ NewStream func(ctx context.Context, address boson.Address, h Headers, ...) (Stream, error)

+ type StreamerDisconnecter interface

+ type StreamerPinger interface

+ type VirtualStream interface

+ Done func() chan struct{}

+ Reader func() *ReaderChan

+ RealStream func() Stream

+ UpdateStatRealStreamClosed func()

+ Writer func() *WriterChan

+ type WriterChan struct

+ Err chan error

+ W chan []byte

v1.2.6

Oct 21, 2022

v1.2.5

Sep 28, 2022

v1.2.4

Sep 11, 2022

v1.2.3

Sep 6, 2022

v1.2.2

Aug 24, 2022

v1.2.1

Aug 17, 2022

Changes in this version

+ func NewVirtualStream(s p2p.Stream) *virtualStream

+ type BuffMessage struct

+ func (b *BuffMessage) Marshal() ([]byte, error)

+ func (b *BuffMessage) ProtoMessage()

+ func (b *BuffMessage) Unmarshal(p []byte) error

v1.2.0

Jul 28, 2022

v1.1.2

Jul 8, 2022

v1.1.1

Jul 4, 2022

v1.1.0

Jul 1, 2022