discovery

Documentation

Index

• type Discoverer
• type PeerStorer
  • func NewPeerStorer(store *sqlobjectstore.Store) PeerStorer
• type StringPeerPeerSyncMap
  • func NewStringPeerPeerSyncMap() *StringPeerPeerSyncMap
  • func (m *StringPeerPeerSyncMap) Delete(k string)
  • func (m *StringPeerPeerSyncMap) Get(k string) (*peer.Peer, bool)
  • func (m *StringPeerPeerSyncMap) Put(k string, v *peer.Peer)
  • func (m *StringPeerPeerSyncMap) Range(i func(k string, v *peer.Peer) bool)

Types

type Discoverer

type Discoverer interface {
	Lookup(
		ctx context.Context,
		opts ...peer.LookupOption,
	) (<-chan *peer.Peer, error)
}

Discoverer defines the interface for a addressBook provider, eg our DHT

type PeerStorer

type PeerStorer interface {
	Add(*peer.Peer, bool)
	AddDiscoverer(Discoverer) error
	Lookup(
		context.Context,
		...peer.LookupOption,
	) (<-chan *peer.Peer, error)
}

PeerStorer interface

func NewPeerStorer

func NewPeerStorer(store *sqlobjectstore.Store) PeerStorer

NewPeerStorer creates a new empty addressBook with no providers

type StringPeerPeerSyncMap

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

StringPeerPeerSyncMap -

func NewStringPeerPeerSyncMap

func NewStringPeerPeerSyncMap() *StringPeerPeerSyncMap

NewStringPeerPeerSyncMap constructs a new SyncMap

func (*StringPeerPeerSyncMap) Delete

func (m *StringPeerPeerSyncMap) Delete(k string)

Delete -

func (*StringPeerPeerSyncMap) Get

func (m *StringPeerPeerSyncMap) Get(k string) (*peer.Peer, bool)

Get -

func (*StringPeerPeerSyncMap) Put

func (m *StringPeerPeerSyncMap) Put(k string, v *peer.Peer)

Put -

func (*StringPeerPeerSyncMap) Range

func (m *StringPeerPeerSyncMap) Range(i func(k string, v *peer.Peer) bool)

Range -