hyperspace

Feb 25, 2020

Changes in this version

+ const ErrNoPeersToAsk

+ type CryptoPublicKeyPeerPeerSyncMap struct

+ 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 (r *Discoverer) Lookup(ctx context.Context, opts ...peer.LookupOption) (<-chan *peer.Peer, error)

type Store

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

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

Jul 24, 2019

Changes in this version

+ const ContentHashesBloomRequestType

+ const ContentHashesBloomType

+ type ContentHashesBloom struct

+ BloomFilter []int

+ Signature *crypto.Signature

+ func (ch *ContentHashesBloom) Bloom() []int

+ func (s *ContentHashesBloom) FromObject(o object.Object) error

+ func (s ContentHashesBloom) GetType() string

+ func (s ContentHashesBloom) ToObject() object.Object

+ type ContentHashesBloomRequest struct

+ BloomFilter []int

+ func (ch *ContentHashesBloomRequest) Bloom() []int

+ func (s *ContentHashesBloomRequest) FromObject(o object.Object) error

+ func (s ContentHashesBloomRequest) GetType() string

+ func (s ContentHashesBloomRequest) ToObject() object.Object

+ type CryptoFingerprintContentHashesBloomSyncMap struct

+ func NewCryptoFingerprintContentHashesBloomSyncMap() *CryptoFingerprintContentHashesBloomSyncMap

+ func (m *CryptoFingerprintContentHashesBloomSyncMap) Delete(k crypto.Fingerprint)

+ func (m *CryptoFingerprintContentHashesBloomSyncMap) Get(k crypto.Fingerprint) (*ContentHashesBloom, bool)

+ func (m *CryptoFingerprintContentHashesBloomSyncMap) Put(k crypto.Fingerprint, v *ContentHashesBloom)

+ func (m *CryptoFingerprintContentHashesBloomSyncMap) Range(i func(k crypto.Fingerprint, v *ContentHashesBloom) bool)

+ type CryptoFingerprintPeerPeerSyncMap struct

+ func NewCryptoFingerprintPeerPeerSyncMap() *CryptoFingerprintPeerPeerSyncMap

+ func (m *CryptoFingerprintPeerPeerSyncMap) Delete(k crypto.Fingerprint)

+ func (m *CryptoFingerprintPeerPeerSyncMap) Get(k crypto.Fingerprint) (*peer.Peer, bool)

+ func (m *CryptoFingerprintPeerPeerSyncMap) Put(k crypto.Fingerprint, v *peer.Peer)

+ func (m *CryptoFingerprintPeerPeerSyncMap) Range(i func(k crypto.Fingerprint, v *peer.Peer) bool)

type Discoverer

+ func (r *Discoverer) LookupContentProvider(ctx context.Context, q bloom.Bloomer) ([]crypto.Fingerprint, error)

+ func (r *Discoverer) LookupPeer(ctx context.Context, q *peer.PeerRequest) ([]*peer.Peer, error)

type Store

+ func (s *Store) AddContentHashes(c *ContentHashesBloom)

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

+ func (s *Store) FindClosestContentProvider(q bloom.Bloomer) []*ContentHashesBloom

+ func (s *Store) FindClosestPeer(f crypto.Fingerprint) []*peer.Peer

+ type StringSyncList struct

+ func NewStringValueTypeSyncMap() *StringSyncList

+ func (m *StringSyncList) Delete(k string)

+ func (m *StringSyncList) Exists(k string) bool

+ func (m *StringSyncList) Put(k string)

+ func (m *StringSyncList) Range(i func(k string) bool)

Jul 23, 2019

Changes in this version

+ func CosineSimilarity(a, b mat.Vector) float64

+ func Hash(b []byte) int32

+ func HashChunked(prefix string, o []byte) []int

+ func SimpleSimilarity(a, b *sparse.Vector) float64

+ func Vectorise(q *peer.PeerInfoRequest) *sparse.Vector

+ type Discoverer struct

+ func NewDiscoverer(ctx context.Context, network net.Network, exc exchange.Exchange, ...) (*Discoverer, error)

+ func (r *Discoverer) FindByContent(ctx context.Context, contentHash string, opts ...discovery.Option) ([]*peer.PeerInfo, error)

+ func (r *Discoverer) FindByFingerprint(ctx context.Context, fingerprint string, opts ...discovery.Option) ([]*peer.PeerInfo, error)

+ func (r *Discoverer) LookupPeerInfo(ctx context.Context, q *peer.PeerInfoRequest) ([]*peer.PeerInfo, error)

+ type Distance interface

+ Compare func()

+ type Store struct

+ func NewStore() *Store

+ func (s *Store) Add(cs ...*peer.PeerInfo)

+ func (s *Store) FindByContent(contentHash string) []*peer.PeerInfo

+ func (s *Store) FindByFingerprint(fingerprint string) []*peer.PeerInfo

+ func (s *Store) FindClosest(q *peer.PeerInfoRequest) []*peer.PeerInfo