pstoremem

Documentation

Index

• func NewAddrBook() pstore.AddrBook
• func NewKeyBook() pstore.KeyBook
• func NewPeerMetadata() pstore.PeerMetadata
• func NewPeerstore() pstore.Peerstore
• type AddrSubManager
  • func NewAddrSubManager() *AddrSubManager
  • func (mgr *AddrSubManager) AddrStream(ctx context.Context, p peer.ID, initial []ma.Multiaddr) <-chan ma.Multiaddr
  • func (mgr *AddrSubManager) BroadcastAddr(p peer.ID, addr ma.Multiaddr)

Functions

func NewAddrBook

func NewAddrBook() pstore.AddrBook

func NewKeyBook

func NewKeyBook() pstore.KeyBook

noop new, but in the future we may want to do some init work.

func NewPeerMetadata

func NewPeerMetadata() pstore.PeerMetadata

func NewPeerstore

func NewPeerstore() pstore.Peerstore

NewPeerstore creates an in-memory threadsafe collection of peers.

Types

type AddrSubManager

type AddrSubManager struct {
	// contains filtered or unexported fields
}

An abstracted, pub-sub manager for address streams. Extracted from memoryAddrBook in order to support additional implementations.

func NewAddrSubManager

func NewAddrSubManager() *AddrSubManager

NewAddrSubManager initializes an AddrSubManager.

func (*AddrSubManager) AddrStream

func (mgr *AddrSubManager) AddrStream(ctx context.Context, p peer.ID, initial []ma.Multiaddr) <-chan ma.Multiaddr

AddrStream creates a new subscription for a given peer ID, pre-populating the channel with any addresses we might already have on file.

func (*AddrSubManager) BroadcastAddr

func (mgr *AddrSubManager) BroadcastAddr(p peer.ID, addr ma.Multiaddr)

BroadcastAddr broadcasts a new address to all subscribed streams.