hyperspace

Documentation

Index

• Constants
• type CryptoPublicKeyPeerPeerSyncMap
  • func NewCryptoPublicKeyPeerPeerSyncMap() *CryptoPublicKeyPeerPeerSyncMap
  • func (m *CryptoPublicKeyPeerPeerSyncMap) Delete(k crypto.PublicKey)
  • func (m *CryptoPublicKeyPeerPeerSyncMap) Get(k crypto.PublicKey) (*peer.Peer, bool)
  • func (m *CryptoPublicKeyPeerPeerSyncMap) Put(k crypto.PublicKey, v *peer.Peer)
  • func (m *CryptoPublicKeyPeerPeerSyncMap) Range(i func(k crypto.PublicKey, v *peer.Peer) bool)
• type Discoverer
  • func NewDiscoverer(ctx context.Context, ps discovery.PeerStorer, exc exchange.Exchange, ...) (*Discoverer, error)
  • func (r *Discoverer) Lookup(ctx context.Context, opts ...peer.LookupOption) (<-chan *peer.Peer, error)
• type Store
  • func NewStore() *Store
  • func (s *Store) AddPeer(p *peer.Peer)
  • func (s *Store) Get(q bloom.Bloom) []*peer.Peer
  • func (s *Store) GetClosest(q bloom.Bloom) []*peer.Peer

Constants

const (
	ErrNoPeersToAsk = errors.Error("no peers to ask")
)

Types

type CryptoPublicKeyPeerPeerSyncMap

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

CryptoPublicKeyPeerPeerSyncMap -

func NewCryptoPublicKeyPeerPeerSyncMap

func NewCryptoPublicKeyPeerPeerSyncMap() *CryptoPublicKeyPeerPeerSyncMap

NewCryptoPublicKeyPeerPeerSyncMap constructs a new SyncMap

func (*CryptoPublicKeyPeerPeerSyncMap) Delete

func (m *CryptoPublicKeyPeerPeerSyncMap) Delete(k crypto.PublicKey)

Delete -

func (*CryptoPublicKeyPeerPeerSyncMap) Get

func (m *CryptoPublicKeyPeerPeerSyncMap) Get(k crypto.PublicKey) (*peer.Peer, bool)

Get -

func (*CryptoPublicKeyPeerPeerSyncMap) Put

func (m *CryptoPublicKeyPeerPeerSyncMap) Put(k crypto.PublicKey, v *peer.Peer)

Put -

func (*CryptoPublicKeyPeerPeerSyncMap) Range

func (m *CryptoPublicKeyPeerPeerSyncMap) Range(i func(k crypto.PublicKey, v *peer.Peer) bool)

Range -

type Discoverer

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

Discoverer hyperspace

func NewDiscoverer

func NewDiscoverer(
	ctx context.Context,
	ps discovery.PeerStorer,
	exc exchange.Exchange,
	local *peer.LocalPeer,
	bootstrapAddresses []string,
) (*Discoverer, error)

NewDiscoverer returns a new hyperspace discoverer

func (*Discoverer) Lookup

func (r *Discoverer) Lookup(
	ctx context.Context,
	opts ...peer.LookupOption,
) (<-chan *peer.Peer, error)

Lookup finds and returns peer infos from a fingerprint

type Store

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

Store holds peer content blooms and their fingerprints

func NewStore

func NewStore() *Store

NewStore retuns empty store

func (*Store) AddPeer

func (s *Store) AddPeer(p *peer.Peer)

Add peers

func (*Store) Get

func (s *Store) Get(q bloom.Bloom) []*peer.Peer

Get returns peers that match a query

func (*Store) GetClosest

func (s *Store) GetClosest(q bloom.Bloom) []*peer.Peer

GetClosest returns peers that closest resemble the query