tnet

Dec 19, 2020

Changes in this version

+ var ZeroLocalTCPAddress = ma.NewMultiaddr("/ip4/127.0.0.1/tcp/0")

+ func FindNetworkLimit(testFunc NetworkTestFunc) (int, error)

+ func ParallelismSlowdown(testFunc NetworkTestFunc, kbps int, l time.Duration) (slowdown float64, err error)

+ func RandLocalTCPAddress() ma.Multiaddr

+ type Identity interface

+ Address func() ma.Multiaddr

+ ID func() peer.ID

+ PrivateKey func() ci.PrivKey

+ PublicKey func() ci.PubKey

+ func NewIdentity(ID peer.ID, addr ma.Multiaddr, privk ci.PrivKey, pubk ci.PubKey) Identity

+ func RandIdentity() (Identity, error)

+ func RandIdentityOrFatal(t *testing.T) Identity

+ type LatencyConfig struct

+ BlockstoreLatency time.Duration

+ NetworkLatency time.Duration

+ RoutingLatency time.Duration

+ func (c LatencyConfig) AllInstantaneous() LatencyConfig

+ func (c LatencyConfig) Blockstore7200RPM() LatencyConfig

+ func (c LatencyConfig) BlockstoreFastSSD2014() LatencyConfig

+ func (c LatencyConfig) BlockstoreSlowSSD2014() LatencyConfig

+ func (c LatencyConfig) NetworkIntraDatacenter2014() LatencyConfig

+ func (c LatencyConfig) NetworkNYtoSF() LatencyConfig

+ func (c LatencyConfig) RoutingSlow() LatencyConfig

+ type NetworkTestFunc func(b *testing.B, n1, n2 net.Conn)

+ type PeerNetParams struct

+ Addr ma.Multiaddr

+ ID peer.ID

+ PrivKey ci.PrivKey

+ PubKey ci.PubKey

+ func RandPeerNetParams() (*PeerNetParams, error)

+ func RandPeerNetParamsOrFatal(t *testing.T) PeerNetParams

+ type WriteTrackedConn struct

+ WriteCount atomic.Uint32

+ func ConnectionForNetwork(n *latency.Network) (n1, n2 *WriteTrackedConn, err error)

+ func (c *WriteTrackedConn) Write(b []byte) (n int, err error)