swarm

Nov 16, 2016

Changes in this version

type Network

+ func NewNetworkWithProtector(ctx context.Context, listen []ma.Multiaddr, local peer.ID, ...) (*Network, error)

type Swarm

+ func NewSwarmWithProtector(ctx context.Context, listenAddrs []ma.Multiaddr, local peer.ID, ...) (*Swarm, error)

Nov 8, 2016

Changes in this version

type Stream

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

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

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

Nov 3, 2016

Changes in this version

type Conn

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

Oct 5, 2016

Changes in this version

+ var ConnSetupTimeout = time.Minute * 5

+ var DialTimeout = time.Second * 10

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

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

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

+ var PSTransport pst.Transport

+ type Conn ps.Conn

+ func (c *Conn) Close() error

+ 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) NewSwarmStream() (*Stream, error)

+ func (c *Conn) RawConn() iconn.Conn

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

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

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

+ func (c *Conn) StreamConn() *ps.Conn

+ func (c *Conn) String() string

+ type ConnHandler func(*Conn)

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

+ type DialSync struct

+ func NewDialSync(dfn DialFunc) *DialSync

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

+ type Network Swarm

+ func NewNetwork(ctx context.Context, listen []ma.Multiaddr, local peer.ID, ...) (*Network, error)

+ func (n *Network) Close() error

+ func (n *Network) ClosePeer(p peer.ID) error

+ func (n *Network) Connectedness(p peer.ID) inet.Connectedness

+ func (n *Network) Conns() []inet.Conn

+ func (n *Network) ConnsToPeer(p peer.ID) []inet.Conn

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

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

+ func (n *Network) Listen(addrs ...ma.Multiaddr) error

+ func (n *Network) ListenAddresses() []ma.Multiaddr

+ func (n *Network) LocalPeer() peer.ID

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

+ func (n *Network) Notify(f inet.Notifiee)

+ func (n *Network) Peers() []peer.ID

+ func (n *Network) Peerstore() pstore.Peerstore

+ func (n *Network) Process() goprocess.Process

+ func (n *Network) SetConnHandler(h inet.ConnHandler)

+ func (n *Network) SetStreamHandler(h inet.StreamHandler)

+ func (n *Network) StopNotify(f inet.Notifiee)

+ func (n *Network) String() string

+ func (n *Network) Swarm() *Swarm

+ 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) (n int, err error)

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

+ func (s *Stream) Stream() *ps.Stream

+ func (s *Stream) SwarmConn() *Conn

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

+ type Swarm struct

+ Filters *filter.Filters

+ func NewBlankSwarm(ctx context.Context, id peer.ID, privkey ci.PrivKey, pstpt pst.Transport) *Swarm

+ func NewSwarm(ctx context.Context, listenAddrs []ma.Multiaddr, local peer.ID, ...) (*Swarm, error)

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

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

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

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

+ func (s *Swarm) Close() error

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

+ func (s *Swarm) Connections() []*Conn

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

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

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

+ func (s *Swarm) HaveConnsToPeer(p peer.ID) bool

+ 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) NewStreamWithPeer(ctx context.Context, p peer.ID) (*Stream, error)

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

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

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

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

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

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

+ func (s *Swarm) StreamSwarm() *ps.Swarm

+ func (s *Swarm) StreamsWithPeer(p peer.ID) []*Stream