lstoremem

Documentation

Index

• Variables
• 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)

Variables

var AllowEmptyRestore = true

Define if storage will accept empty dumps.

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.