libp2p

Documentation

Index

• func NewStream(s network.Stream) p2p.Stream
• type Options
• type Service
  • func New(ctx context.Context, signer beecrypto.Signer, networkID uint64, ...) (*Service, error)
  • func (s *Service) AddProtocol(p p2p.ProtocolSpec) (err error)
  • func (s *Service) Addresses() (addreses []ma.Multiaddr, err error)
  • func (s *Service) ApplyRoute(self boson.Address, rt routetab.RelayStream, mode address.Model)
  • func (s *Service) Blocklist(overlay boson.Address, duration time.Duration, reason string) error
  • func (s *Service) BlocklistRemove(overlay boson.Address) error
  • func (s *Service) BlocklistedPeers() ([]p2p.BlockPeers, error)
  • func (s *Service) CallHandler(ctx context.Context, src p2p.Peer, stream p2p.Stream) (_ *pb.RouteRelayReq, _ *p2p.WriterChan, r *p2p.ReaderChan, _ bool, err error)
  • func (s *Service) CallHandlerWithConnChain(ctx context.Context, last, src p2p.Peer, stream p2p.Stream, ...) (err error)
  • func (s *Service) Close() error
  • func (s *Service) Connect(ctx context.Context, addr ma.Multiaddr) (peer *p2p.Peer, err error)
  • func (s *Service) Disconnect(overlay boson.Address, reason string) error
  • func (s *Service) GetWelcomeMessage() string
  • func (s *Service) Halt()
  • func (s *Service) Metrics() []prometheus.Collector
  • func (s *Service) NATAddresses() (addresses []net.Addr, err error)
  • func (s *Service) NATManager() basichost.NATManager
  • func (s *Service) NetworkStatus() p2p.NetworkStatus
  • func (s *Service) NewConnChainRelayStream(ctx context.Context, target boson.Address, headers p2p.Headers, ...) (p2p.Stream, error)
  • func (s *Service) NewRelayStream(ctx context.Context, target boson.Address, headers p2p.Headers, ...) (p2p.Stream, error)
  • func (s *Service) NewStream(ctx context.Context, overlay boson.Address, headers p2p.Headers, ...) (p2p.Stream, error)
  • func (s *Service) PeerID(overlay boson.Address) (id libp2ppeer.ID, found bool)
  • func (s *Service) Peers() []p2p.Peer
  • func (s *Service) Ping(ctx context.Context, addr ma.Multiaddr) (rtt time.Duration, err error)
  • func (s *Service) Ready() error
  • func (s *Service) ResourceManager() network.ResourceManager
  • func (s *Service) SetPickyNotifier(n p2p.PickyNotifier)
  • func (s *Service) SetWelcomeMessage(val string) error
• type UpnpAddressResolver
  • func (r *UpnpAddressResolver) Resolve(observedAddress ma.Multiaddr) (ma.Multiaddr, error)

Functions

func NewStream

func NewStream(s network.Stream) p2p.Stream

Types

type Options

type Options struct {
	PrivateKey     crypto.PrivKey
	NATAddr        string
	EnableWS       bool
	EnableQUIC     bool
	NodeMode       address.Model
	LightNodeLimit int
	KadBinMaxPeers int
	WelcomeMessage string
	Transaction    []byte
	// contains filtered or unexported fields
}

type Service

type Service struct {
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, signer beecrypto.Signer, networkID uint64, overlay boson.Address, addr string, ab addressbook.Putter, storer storage.StateStorer, lightNodes *lightnode.Container, bootNodes *bootnode.Container, logger logging.Logger, tracer *tracing.Tracer, o Options) (*Service, error)

func (*Service) AddProtocol

func (s *Service) AddProtocol(p p2p.ProtocolSpec) (err error)

func (*Service) Addresses

func (s *Service) Addresses() (addreses []ma.Multiaddr, err error)

func (*Service) ApplyRoute

func (s *Service) ApplyRoute(self boson.Address, rt routetab.RelayStream, mode address.Model)

func (*Service) Blocklist

func (s *Service) Blocklist(overlay boson.Address, duration time.Duration, reason string) error

func (*Service) BlocklistRemove

func (s *Service) BlocklistRemove(overlay boson.Address) error

func (*Service) BlocklistedPeers

func (s *Service) BlocklistedPeers() ([]p2p.BlockPeers, error)

func (*Service) CallHandler

func (s *Service) CallHandler(ctx context.Context, src p2p.Peer, stream p2p.Stream) (_ *pb.RouteRelayReq, _ *p2p.WriterChan, r *p2p.ReaderChan, _ bool, err error)

func (*Service) CallHandlerWithConnChain

func (s *Service) CallHandlerWithConnChain(ctx context.Context, last, src p2p.Peer, stream p2p.Stream, protocolName, protocolVersion, streamName string) (err error)

func (*Service) Close

func (s *Service) Close() error

func (*Service) Connect

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

func (*Service) Disconnect

func (s *Service) Disconnect(overlay boson.Address, reason string) error

func (*Service) GetWelcomeMessage

func (s *Service) GetWelcomeMessage() string

GetWelcomeMessage returns the value of the welcome message.

func (*Service) Halt

func (s *Service) Halt()

func (*Service) Metrics

func (s *Service) Metrics() []prometheus.Collector

func (*Service) NATAddresses

func (s *Service) NATAddresses() (addresses []net.Addr, err error)

func (*Service) NATManager

func (s *Service) NATManager() basichost.NATManager

func (*Service) NetworkStatus

func (s *Service) NetworkStatus() p2p.NetworkStatus

NetworkStatus implements the p2p.NetworkStatus interface.

func (*Service) NewConnChainRelayStream

func (s *Service) NewConnChainRelayStream(ctx context.Context, target boson.Address, headers p2p.Headers, protocolName, protocolVersion, streamName string) (p2p.Stream, error)

func (*Service) NewRelayStream

func (s *Service) NewRelayStream(ctx context.Context, target boson.Address, headers p2p.Headers, protocolName, protocolVersion, streamName string, midCall bool) (p2p.Stream, error)

func (*Service) NewStream

func (s *Service) NewStream(ctx context.Context, overlay boson.Address, headers p2p.Headers, protocolName, protocolVersion, streamName string) (p2p.Stream, error)

func (*Service) PeerID

func (s *Service) PeerID(overlay boson.Address) (id libp2ppeer.ID, found bool)

func (*Service) Peers

func (s *Service) Peers() []p2p.Peer

func (*Service) Ping

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

func (*Service) Ready

func (s *Service) Ready() error

func (*Service) ResourceManager

func (s *Service) ResourceManager() network.ResourceManager

func (*Service) SetPickyNotifier

func (s *Service) SetPickyNotifier(n p2p.PickyNotifier)

func (*Service) SetWelcomeMessage

func (s *Service) SetWelcomeMessage(val string) error

SetWelcomeMessage sets the welcome message for the handshake protocol.

type UpnpAddressResolver

type UpnpAddressResolver struct {
	// contains filtered or unexported fields
}

func (*UpnpAddressResolver) Resolve

func (r *UpnpAddressResolver) Resolve(observedAddress ma.Multiaddr) (ma.Multiaddr, error)

Resolve checks if there is a possible better advertisable underlay then the provided observed address. In some NAT situations, for example in the case when nodes are behind upnp, observer might send the observed address with a wrong port. In this case, observed address is compared to addresses provided by host, and if there is a same address but with different port, that one is used as advertisable address instead of provided observed one. TODO: this is a quickfix and it will be improved in the future