lstoremem

Documentation

Index

• func NewAddrBook() core.AddrBook
• func NewHeadBook() core.HeadBook
• func NewKeyBook() core.KeyBook
• func NewLogstore() core.Logstore
• func NewThreadMetadata() core.ThreadMetadata
• type AddrSubManager
  • func NewAddrSubManager() *AddrSubManager
  • func (mgr *AddrSubManager) AddrStream(ctx context.Context, p peer.ID, initial []ma.Multiaddr) (<-chan ma.Multiaddr, error)
  • func (mgr *AddrSubManager) BroadcastAddr(p peer.ID, addr ma.Multiaddr)

Functions

func NewAddrBook

func NewAddrBook() core.AddrBook

func NewHeadBook

func NewHeadBook() core.HeadBook

func NewKeyBook

func NewKeyBook() core.KeyBook

func NewLogstore

func NewLogstore() core.Logstore

NewLogstore creates an in-memory threadsafe collection of thread logs.

func NewThreadMetadata

func NewThreadMetadata() core.ThreadMetadata

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, error)

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.