peerstore

May 18, 2019

Changes in this version

+ type ProtoBook interface

+ AddProtocols func(peer.ID, ...string) error

+ GetProtocols func(peer.ID) ([]string, error)

+ SetProtocols func(peer.ID, ...string) error

+ SupportsProtocols func(peer.ID, ...string) ([]string, error)

Apr 12, 2019

Changes in this version

type PeerInfo

+ func (pi PeerInfo) String() string

Feb 28, 2019

Changes in this version

+ const ConnectedAddrTTL

+ const PermanentAddrTTL

+ var AddressTTL = time.Hour

+ var ErrInvalidAddr = fmt.Errorf("invalid p2p multiaddr")

+ var ErrNotFound = errors.New("item not found")

+ var LatencyEWMASmoothing = 0.1

+ var OwnObservedAddrTTL = time.Minute * 10

+ var ProviderAddrTTL = time.Minute * 10

+ var RecentlyConnectedAddrTTL = time.Minute * 10

+ var TempAddrTTL = time.Second * 10

+ func InfoToP2pAddrs(pi *PeerInfo) ([]ma.Multiaddr, error)

+ func NewMetrics() *metrics

+ func PeerInfoIDs(pis []PeerInfo) peer.IDSlice

+ type AddrBook interface

+ AddAddr func(p peer.ID, addr ma.Multiaddr, ttl time.Duration)

+ AddAddrs func(p peer.ID, addrs []ma.Multiaddr, ttl time.Duration)

+ AddrStream func(context.Context, peer.ID) <-chan ma.Multiaddr

+ Addrs func(p peer.ID) []ma.Multiaddr

+ ClearAddrs func(p peer.ID)

+ PeersWithAddrs func() peer.IDSlice

+ SetAddr func(p peer.ID, addr ma.Multiaddr, ttl time.Duration)

+ SetAddrs func(p peer.ID, addrs []ma.Multiaddr, ttl time.Duration)

+ UpdateAddrs func(p peer.ID, oldTTL time.Duration, newTTL time.Duration)

+ type KeyBook interface

+ AddPrivKey func(peer.ID, ic.PrivKey) error

+ AddPubKey func(peer.ID, ic.PubKey) error

+ PeersWithKeys func() peer.IDSlice

+ PrivKey func(peer.ID) ic.PrivKey

+ PubKey func(peer.ID) ic.PubKey

+ type Metrics interface

+ LatencyEWMA func(peer.ID) time.Duration

+ RecordLatency func(peer.ID, time.Duration)

+ type PeerInfo struct

+ Addrs []ma.Multiaddr

+ ID peer.ID

+ func InfoFromP2pAddr(m ma.Multiaddr) (*PeerInfo, error)

+ func PeerInfos(ps Peerstore, peers peer.IDSlice) []PeerInfo

+ func (pi *PeerInfo) Loggable() map[string]interface{}

+ func (pi *PeerInfo) UnmarshalJSON(b []byte) error

+ func (pi PeerInfo) MarshalJSON() ([]byte, error)

+ type PeerMetadata interface

+ Get func(p peer.ID, key string) (interface{}, error)

+ Put func(p peer.ID, key string, val interface{}) error

+ type Peerstore interface

+ AddProtocols func(peer.ID, ...string) error

+ GetProtocols func(peer.ID) ([]string, error)

+ PeerInfo func(peer.ID) PeerInfo

+ Peers func() peer.IDSlice

+ SetProtocols func(peer.ID, ...string) error

+ SupportsProtocols func(peer.ID, ...string) ([]string, error)

+ func NewPeerstore(kb KeyBook, ab AddrBook, md PeerMetadata) Peerstore