mocknet

Apr 11, 2016

Changes in this version

+ func NewRatelimiter(bandwidth float64) *ratelimiter

+ func NewStream(w io.Writer, r io.Reader) *stream

+ type Link interface

+ Networks func() []inet.Network

+ Options func() LinkOptions

+ Peers func() []peer.ID

+ SetOptions func(LinkOptions)

+ type LinkMap map[string]map[string]map[Link]struct

+ type LinkOptions struct

+ Bandwidth float64

+ Latency time.Duration

+ type Mocknet interface

+ AddPeer func(ic.PrivKey, ma.Multiaddr) (host.Host, error)

+ AddPeerWithPeerstore func(peer.ID, peer.Peerstore) (host.Host, error)

+ ConnectAllButSelf func() error

+ ConnectNets func(inet.Network, inet.Network) (inet.Conn, error)

+ ConnectPeers func(peer.ID, peer.ID) (inet.Conn, error)

+ DisconnectNets func(inet.Network, inet.Network) error

+ DisconnectPeers func(peer.ID, peer.ID) error

+ GenPeer func() (host.Host, error)

+ Host func(peer.ID) host.Host

+ Hosts func() []host.Host

+ LinkAll func() error

+ LinkDefaults func() LinkOptions

+ LinkNets func(inet.Network, inet.Network) (Link, error)

+ LinkPeers func(peer.ID, peer.ID) (Link, error)

+ Links func() LinkMap

+ LinksBetweenNets func(a, b inet.Network) []Link

+ LinksBetweenPeers func(a, b peer.ID) []Link

+ Net func(peer.ID) inet.Network

+ Nets func() []inet.Network

+ Peers func() []peer.ID

+ SetLinkDefaults func(LinkOptions)

+ Unlink func(Link) error

+ UnlinkNets func(inet.Network, inet.Network) error

+ UnlinkPeers func(peer.ID, peer.ID) error

+ func FullMeshConnected(ctx context.Context, n int) (Mocknet, error)

+ func FullMeshLinked(ctx context.Context, n int) (Mocknet, error)

+ func New(ctx context.Context) Mocknet

+ func WithNPeers(ctx context.Context, n int) (Mocknet, error)

+ type Printer interface

+ MocknetLinks func(mn Mocknet)

+ NetworkConns func(ni inet.Network)

+ func PrinterTo(w io.Writer) Printer