peerstore

Jan 5, 2018

Changes in this version

type AddrBook

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

type AddrManager

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

Apr 28, 2017

Changes in this version

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

Apr 1, 2017

Changes in this version

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

type PeerInfo

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

Aug 19, 2016

Changes in this version

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

type Peerstore

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

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

Jun 10, 2016

Changes in this version

type Peerstore

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

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

Apr 27, 2016

Changes in this version

+ func IDB58Encode(id ID) string

+ func IDHexEncode(id ID) string

+ type ID string

+ func IDB58Decode(s string) (ID, error)

+ func IDFromBytes(b []byte) (ID, error)

+ func IDFromPrivateKey(sk ic.PrivKey) (ID, error)

+ func IDFromPublicKey(pk ic.PubKey) (ID, error)

+ func IDFromString(s string) (ID, error)

+ func IDHexDecode(s string) (ID, error)

+ func (id ID) Loggable() map[string]interface{}

+ func (id ID) MatchesPrivateKey(sk ic.PrivKey) bool

+ func (id ID) MatchesPublicKey(pk ic.PubKey) bool

+ func (id ID) Pretty() string

+ func (id ID) String() string

+ type IDSlice []ID

+ func (es IDSlice) Len() int

+ func (es IDSlice) Less(i, j int) bool

+ func (es IDSlice) Swap(i, j int)

+ type Set map[ID]struct

May 31, 2016

Changes in this version

+ const AddressTTL

+ const ConnectedAddrTTL

+ const OwnObservedAddrTTL

+ const PermanentAddrTTL

+ const ProviderAddrTTL

+ const RecentlyConnectedAddrTTL

+ const TempAddrTTL

+ var LatencyEWMASmoothing = 0.1

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

+ 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)

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

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

+ type AddrManager struct

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

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

+ func (mgr *AddrManager) AddrStream(ctx context.Context, p peer.ID) <-chan ma.Multiaddr

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

+ func (mgr *AddrManager) ClearAddrs(p peer.ID)

+ func (mgr *AddrManager) Peers() []peer.ID

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

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

+ type KeyBook interface

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

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

+ 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)

+ func NewMetrics() Metrics

+ type PeerInfo struct

+ Addrs []ma.Multiaddr

+ ID peer.ID

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

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

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

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

+ type Peerstore interface

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

+ PeerInfo func(peer.ID) PeerInfo

+ Peers func() []peer.ID

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

+ func NewPeerstore() Peerstore