swarm

Jan 18, 2022

Changes in this version

type Conn

+ func (c *Conn) Scope() network.ConnScope

type Option

+ func WithDialTimeout(t time.Duration) Option

+ func WithDialTimeoutLocal(t time.Duration) Option

+ func WithResourceManager(m network.ResourceManager) Option

type Stream

+ func (s *Stream) Scope() network.StreamScope

type Swarm

+ func (s *Swarm) ResourceManager() network.ResourceManager

Sep 8, 2021

Changes in this version

+ type Option func(*Swarm) error

+ func WithConnectionGater(gater connmgr.ConnectionGater) Option

+ func WithMetrics(reporter metrics.Reporter) Option

Sep 2, 2020

Changes in this version

type Stream

+ func (s *Stream) CloseRead() error

+ func (s *Stream) CloseWrite() error

Jun 5, 2020

Changes in this version

type Conn

+ func (c *Conn) ID() string

type Stream

+ func (s *Stream) ID() string

May 20, 2020

Changes in this version

type Swarm

+ func (s *Swarm) IsFdConsumingAddr(addr ma.Multiaddr) bool

May 15, 2020

Changes in this version

+ var ErrGaterDisallowedConnection = errors.New("gater disallows connection to peer")

Apr 2, 2020

Changes in this version

+ var ErrDialTimeout = errors.New("dial timed out")

type DialError

+ func (e *DialError) Timeout() bool

Apr 25, 2019

Changes in this version

+ var ErrAllDialsFailed = errors.New("all dials failed")

+ var ErrNoAddresses = errors.New("no addresses")

+ var ErrNoGoodAddresses = errors.New("no good addresses")

+ type DialError struct

+ Cause error

+ DialErrors []TransportError

+ Peer peer.ID

+ Skipped int

+ func (e *DialError) Error() string

+ func (e *DialError) Unwrap() error

+ type TransportError struct

+ Address ma.Multiaddr

+ Cause error

+ func (e *TransportError) Error() string

Mar 2, 2019

Changes in this version

+ const ConcurrentFdDials

+ const DefaultPerPeerRateLimit

+ const DialAttempts

+ var BackoffBase = time.Second * 5

+ var BackoffCoef = time.Second

+ var BackoffMax = time.Minute * 5

+ var DialTimeoutLocal = 5 * time.Second

+ var ErrAddrFiltered = errors.New("address filtered")

+ var ErrConnClosed = errors.New("connection closed")

+ var ErrDialBackoff = errors.New("dial backoff")

+ var ErrDialFailed = errors.New("dial attempt failed")

+ var ErrDialToSelf = errors.New("dial to self attempted")

+ var ErrNoTransport = errors.New("no transport for protocol")

+ var ErrSwarmClosed = errors.New("swarm closed")

+ type Conn struct

+ func (c *Conn) Close() error

+ func (c *Conn) GetStreams() []inet.Stream

+ func (c *Conn) LocalMultiaddr() ma.Multiaddr

+ func (c *Conn) LocalPeer() peer.ID

+ func (c *Conn) LocalPrivateKey() ic.PrivKey

+ func (c *Conn) NewStream() (inet.Stream, error)

+ func (c *Conn) RemoteMultiaddr() ma.Multiaddr

+ func (c *Conn) RemotePeer() peer.ID

+ func (c *Conn) RemotePublicKey() ic.PubKey

+ func (c *Conn) Stat() inet.Stat

+ func (c *Conn) String() string

+ type DialBackoff struct

+ func (db *DialBackoff) AddBackoff(p peer.ID)

+ func (db *DialBackoff) Backoff(p peer.ID) (backoff bool)

+ func (db *DialBackoff) Clear(p peer.ID)

+ type DialFunc func(context.Context, peer.ID) (*Conn, error)

+ type DialSync struct

+ func NewDialSync(dfn DialFunc) *DialSync

+ func (ds *DialSync) CancelDial(p peer.ID)

+ func (ds *DialSync) DialLock(ctx context.Context, p peer.ID) (*Conn, error)

+ type Stream struct

+ func (s *Stream) Close() error

+ func (s *Stream) Conn() inet.Conn

+ func (s *Stream) Protocol() protocol.ID

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

+ func (s *Stream) Reset() error

+ func (s *Stream) SetDeadline(t time.Time) error

+ func (s *Stream) SetProtocol(p protocol.ID)

+ func (s *Stream) SetReadDeadline(t time.Time) error

+ func (s *Stream) SetWriteDeadline(t time.Time) error

+ func (s *Stream) Stat() inet.Stat

+ func (s *Stream) String() string

+ func (s *Stream) Write(p []byte) (int, error)

+ type Swarm struct

+ Filters *filter.Filters

+ func NewSwarm(ctx context.Context, local peer.ID, peers pstore.Peerstore, ...) *Swarm

+ func (s *Swarm) AddAddrFilter(f string) error

+ func (s *Swarm) AddListenAddr(a ma.Multiaddr) error

+ func (s *Swarm) AddTransport(t transport.Transport) error

+ func (s *Swarm) Backoff() *DialBackoff

+ func (s *Swarm) Close() error

+ func (s *Swarm) ClosePeer(p peer.ID) error

+ func (s *Swarm) ConnHandler() inet.ConnHandler

+ func (s *Swarm) Connectedness(p peer.ID) inet.Connectedness

+ func (s *Swarm) Conns() []inet.Conn

+ func (s *Swarm) ConnsToPeer(p peer.ID) []inet.Conn

+ func (s *Swarm) Context() context.Context

+ func (s *Swarm) DialPeer(ctx context.Context, p peer.ID) (inet.Conn, error)

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

+ func (s *Swarm) Listen(addrs ...ma.Multiaddr) error

+ func (s *Swarm) ListenAddresses() []ma.Multiaddr

+ func (s *Swarm) LocalPeer() peer.ID

+ func (s *Swarm) NewStream(ctx context.Context, p peer.ID) (inet.Stream, error)

+ func (s *Swarm) Notify(f inet.Notifiee)

+ func (s *Swarm) Peers() []peer.ID

+ func (s *Swarm) Peerstore() pstore.Peerstore

+ func (s *Swarm) Process() goprocess.Process

+ func (s *Swarm) SetConnHandler(handler inet.ConnHandler)

+ func (s *Swarm) SetStreamHandler(handler inet.StreamHandler)

+ func (s *Swarm) StopNotify(f inet.Notifiee)

+ func (s *Swarm) StreamHandler() inet.StreamHandler

+ func (s *Swarm) String() string

+ func (s *Swarm) TransportForDialing(a ma.Multiaddr) transport.Transport

+ func (s *Swarm) TransportForListening(a ma.Multiaddr) transport.Transport